【golang】tcp协议实现

Golang 评论
1、client端client.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
//tcpclient 为client.go所在的上一层目录
package tcpclient

import (
	"net"
	"fmt"
	//"io/ioutil"
	"strconv"
	//"../log"
	//"strings"
	//"bytes"
	//"encoding/xml"
)
//组装tcp请求
func RequestMsg(serialNum string, randomNum string, toAddr string, fromAddr string) string {
	
	body := "<?xml version=\"1.0\"?>\r\n" +
	"<Config>\r\n" +
	"<CmdType>ACTIVE</CmdType>\r\n" +
	"<CmdInfo>GetActiveInfo</CmdInfo>\r\n" +
	"<SerialNumInfo>\r\n" +
		"<SerialNum>" + serialNum + "</SerialNum>\r\n" +
	"</SerialNumInfo>\r\n" +
	"</Config>"

	head := "HIK-PRODUCT\r\n" +
		"Via:HIKSTOR/1.0/TCP\r\n" +
		"From:" + fromAddr + "\r\n" +
		"To:" + toAddr + "\r\n" +
		"Call-ID:" + randomNum + "\r\n" +
		"Content-Type:xml\r\n" +
		"Content-Length:" + strconv.Itoa(len(body)) + "\r\n\r\n" 
		
		
	return head + body
	//return body
}
//向server端发起请求
func GetBomInfoFromThirdServ(serialNum string,randomNum string, toAddr string, fromAddr string) (string,error) {

	//主动发起连接请求
	conn,err :=net.Dial("tcp","10.192.44.183:35004")
	if err != nil {

		fmt.Println("dial err",err)
        return "", err
	}
	defer conn.Close()
	//向服务端发送请求
	reqmsg := RequestMsg(serialNum,randomNum,toAddr,fromAddr)
	_, err = conn.Write([]byte(reqmsg))
	if err != nil {
		fmt.Println("send err=", err) //出错退出
		return "",err
	 }
	//接收响应
	buf := make([]byte, 1024)
	//response, err :=ioutil.ReadAll(conn)
	//if err != nil {

	//	fmt.Println("rec err",err)
    //   return "", err
	//}
	
	n, err :=conn.Read(buf)
	//fmt.Println("n=", n)
	if err != nil {
		fmt.Println("服务器read err=", err) //出错退出
		return "",err
	 }
	return string(buf[:n-1]),nil
	//return buf,nil

	
}
2、server端server.go

HongxunSystem Developer