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

V2EX = way to explore

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

现在注册

已注册用户请登录

The Go Programming Language

› http://golang.org/

› Go Playground

Go Projects

› Revel Web Framework

这是一个创建于 1325 天前的主题，其中的信息可能已经有所发展或是发生改变。

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(conn 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 条回复 • 2021-05-06 17:42:10 +08:00

codehz

2021-04-06 22:55:28 +08:00

time 的 add 默认单位是纳秒（

awanganddong

2021-04-06 23:04:07 +08:00

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

codehz

2021-04-06 23:07:42 +08:00

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

awanganddong

2021-04-06 23:09:24 +08:00

@codehz 我把制表符剔除试下

djoiwhud

2021-04-07 01:44:10 +08:00 via Android

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

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

writesome6

2021-04-07 09:43:13 +08:00

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

1000172

2021-04-07 10:45:53 +08:00

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

bruce0

2021-04-07 10:52:24 +08:00

```
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

2021-04-07 12:55:35 +08:00

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

skiy

2021-04-07 12:56:14 +08:00

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

crescentBLADE

2021-04-08 18:11:26 +08:00

你这是意识流

awanganddong

2021-04-08 19:40:51 +08:00

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

awanganddong

2021-04-30 11:01:37 +08:00

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

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

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