用 go 实现 socket ，帮忙看看问题处在哪里

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

The Go Programming Language

http://golang.org/

Go Playground

Go Projects

Revel Web Framework

This topic created in 1846 days ago, the information mentioned may be changed or developed.

package main import ( "bytes" "fmt" "net" "time" ) func main() { listener, err := net.Listen("tcp", "127.0.0.1:9527") defer listener.Close() if err != nil { fmt.Printf("server err %v\n", err) } else { for { conn, err := listener.Accept() if err == nil { go handleConn(conn) } } } } func Read(conn net.Conn) (string, error) { readBytes := make([]byte, 1) var buf bytes.Buffer for { _, err := conn.Read(readBytes) if err != nil { return "", err } readByte := readBytes[0] if readByte == '\t' { break } } return buf.String(), nil } func Write(conn net.Conn, content string) (int, error) { var buf bytes.Buffer buf.WriteString(content) buf.WriteByte('\t') return conn.Write(buf.Bytes()) } func handleConn(con net.Conn) { for { conn.SetReadDeadline(time.Now().Add(2)) if str, err := Read(conn); err == nil { fmt.Printf("收到的数据：%v\n", str) Write(conn, "server got:"+str) }else{ fmt.Printf("read err: %v\n",err) } } }

现在用 telnet 发送消息，然后报错 read err: read tcp 127.0.0.1:9527->127.0.0.1:56508: i/o timeout

14 replies 2021-05-06 17:42:10 +08:00

codehz

Apr 6, 2021

time 的 add 默认单位是纳秒（

awanganddong

Apr 6, 2021

设置为以下还是同样报错
conn.SetReadDeadline(time.Now().Add(10 * time.Second))

codehz

Apr 6, 2021

所以你发送的内容有没有包含制表符呢

awanganddong

Apr 6, 2021

@codehz 我把制表符剔除试下

djoiwhud

Apr 7, 2021 via Android

我看了两分钟也没看出你这个 read 里面定义的 buf 是什么用途。
每次读一个字节的操作看起来是学习练手的。看得出你没认真读过计算机网络卷一。

另外 read 的 len 返回值务必处理。

writesome6

Apr 7, 2021

其实就是你设置的超时时间有问题

1000172

Apr 7, 2021

我之前用框架写时遇到连不通是因为跨域的问题（因为我用网页测试，框架内默认进行跨域验证，我重写了跨域验证方法后就好了），你这个没太仔细看，只是送点参考意见

bruce0

Apr 7, 2021

```
func Read(conn net.Conn) (string, error) {
readBytes := make([]byte, 1)
var buf bytes.Buffer
for {
_, err := conn.Read(readBytes)
if err != nil {
return "", err
}
readByte := readBytes[0]
if readByte == '\t' {
break
}
}
return buf.String(), nil
}
```
readBytes := make([]byte, 1) 这里你创建的这个切片,长度是 1, 一般没有这样设置的. 一般都是客户端和服务端约定一个包最大长度,比如 1024, 每次客户端和服务端发的数据都不会超过这个最大长度,

n, err := conn.Read(readBytes) 通过这个函数读的时候, 返回的 n 是这次读取的长度

而你现在传了一个长度为 1 的切片, 假设这次客户端发来的数据长度为 10 因为你的切片长度为 1 就只能读到第位后面的都丢了

awanganddong

Apr 7, 2021

以上是我参照别人 demo 写的，里边逻辑确实有问题。

skiy

Apr 7, 2021

你的 buf.String() 永远是""

crescentBLADE

Apr 8, 2021

你这是意识流

awanganddong

Apr 8, 2021

属于瞎几把写，我再重新修改修改，里边逻辑不太对

awanganddong

Apr 30, 2021

socket 属于流的模式
这个要搞明白
以下是修改的代码

```
package main

import (
"fmt"
"io"
"net"
)

func main() {
listener, err := net.Listen("tcp", "127.0.0.1:9527")
if err != nil {
fmt.Printf("server err %v\n", err)
}
defer listener.Close()
for {
conn, err := listener.Accept()
if err == nil {
go handleConn(conn)
}
}

}

func handleConn(conn net.Conn) {

for {
readBytes := make([]byte, 1)
n, err := conn.Read(readBytes)
if err != nil && err != io.EOF {
fmt.Printf("read err:%v\n", err)
break
}
fmt.Printf("read content:%v", readBytes[:n])
_, err = conn.Write(readBytes[:n])
if err != nil {
fmt.Printf("write err:%v\n", err)
break
}
}
}

```

who1996

May 6, 2021

tcp 没有跨域，，跨域是因为 client 端的安全策略！！！