gnet.Conn 接口：
type Conn interface {
// 唯一标识符
ID() uint32
// 远程地址
RemoteAddr() net.Addr
// 本地地址
LocalAddr() net.Addr
// 发送数据
Send(data []byte) error
// 接收数据
Recv(size int) ([]byte, error)
// 关闭连接
Close() error
}
- ID() uint32： 获取连接的唯一标识符。
- RemoteAddr() net.Addr： 获取远程地址。
- LocalAddr() net.Addr： 获取本地地址。
- Send(data []byte) error： 发送数据。
- Recv(size int) ([]byte, error)： 接收数据。
- Close() error： 关闭连接。
使用连接对象：
你可以通过连接对象执行以下操作：
获取连接信息：
id := conn.ID() // 获取连接的唯一标识符
remoteAddr := conn.RemoteAddr() // 获取远程地址
localAddr := conn.LocalAddr() // 获取本地地址
发送数据：
data := []byte("Hello, Server!")
err := conn.Send(data)
if err != nil {
// 发送失败
}
接收数据：
response, err := conn.Recv(-1) // 接收任意大小的数据
if err != nil {
// 接收失败
}
在 Recv 方法中，可以指定要接收的数据大小，如果大小为 -1，则表示接收任意大小的数据。
关闭连接：
err := conn.Close()
if err != nil {
// 关闭连接失败
}
在回调函数中使用连接对象：
在 gnet 中，通常通过回调函数处理连接事件。在回调函数中，你可以获取到连接对象，进行连接管理、数据读写等操作。
type ConnCallback func(conn gnet.Conn) (out []byte, action gnet.Action)
func callback(conn gnet.Conn) (out []byte, action gnet.Action) {
// 处理连接事件
fmt.Printf("New connection: %d\n", conn.ID())
// 发送数据
conn.Send([]byte("Hello, Client!"))
// 关闭连接
conn.Close()
return
}
在这个例子中，回调函数会在每个新连接建立时被触发，输出连接的唯一标识符，并向客户端发送消息后关闭连接。
通过使用连接对象，你可以方便地管理连接、进行数据读写等操作，构建出高性能的 TCP 服务器和客户端。
转载请注明出处：http://www.pingtaimeng.com/article/detail/7874/GoFrame