| 123456789101112131415161718192021222324252627282930313233343536373839404142434445 | package networkimport (	"fmt"	"io"	"net"	"time")// Body 通过 defaultPool 分配 byte 数组func Body() (p []byte) {	p = defaultPool.Get().([]byte)	defaultPool.Put(p)	return}// Dial 拨号. network 可选 NetTCP 或 NetUDP 表示使用 TCP 或 UDP 协议, address 为服务器地址// Dial 实现 net.Conn 接口func Dial(network, address string) (net.Conn, error) {	return DialTimout(network, address, DefaultDialTimout)}// DialTimout 拨号并指定超时时间func DialTimout(network, address string, timout time.Duration) (net.Conn, error) {	conn, err := net.DialTimeout(network, address, timout)	if err != nil {		return nil, err	}	switch network {	case NetTCP:		return createTCPClient(conn), nil	case NetUDP:		panic("not implemented")	default:		panic(fmt.Sprintf("unsupported protocol: %s", network))	}}// NewModbusClient 每秒使用 data 创建数据并发送至服务器// modbusClient 每 1 秒调用 ModbusCreator 创建需要写入的数据并发送至服务器, 然后将服务器返回的数据保存在内部.// Read 即获取服务器返回的数据, 当 Read 返回非 ErrReconnect 的错误时, 应调用 Close 关闭// Write 始终返回 len(p) 和 nilfunc NewModbusClient(conn net.Conn, data ModbusCreator) io.ReadWriteCloser {	return createModbusClient(conn, data)}
 |