|
@@ -106,6 +106,7 @@ func(c *TcpClient)Start() {
|
|
|
for {
|
|
for {
|
|
|
select {
|
|
select {
|
|
|
case data := <-c.pchan:
|
|
case data := <-c.pchan:
|
|
|
|
|
+ c.conn.SetWriteDeadline(time.Now().Add(time.Second * 2))
|
|
|
_, err := c.conn.Write(data.toBytes())
|
|
_, err := c.conn.Write(data.toBytes())
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
fmt.Println("写入内容错误", err.Error())
|
|
fmt.Println("写入内容错误", err.Error())
|