Google GO与C#之间的TCP通信案例

我本人也才接触GO两个多月的历史,看了几本英文教程，读了些Github上面的源码，但已经被GO的语言的简洁和强大的并发能力所吸收，也打算继续深入的学习，并应用到自己的工作之中。GO语言目前主要适用于服务端的开发，我参考了一些网络上的教程，做了一些TCP服务端的小练习，其中服务端用GO语言开发，客户端采用C#。具体参考如下的代码：https://github.com/yfl8910/gotcpserver

效果图如下：

服务端代码：

1. package main
2. import (
3. "net"
4. "fmt"
5. )
7. var ( maxRead = 25
8. msgStop = []byte("cmdStop")
9. msgStart = []byte("cmdContinue")
10. )
11. func main() {
13. hostAndPort := "localhost:54321"
14. listener := initServer(hostAndPort)
15. for {
16. conn, err := listener.Accept()
17. checkError(err, "Accept: ")
18. go connectionHandler(conn)
19. }
20. }
21. func initServer(hostAndPort string) *net.TCPListener {
22. serverAddr, err := net.ResolveTCPAddr("tcp", hostAndPort)
23. checkError(err, "Resolving address:port failed: '" + hostAndPort + "'")
24. //listener, err := net.ListenTCP("tcp", serverAddr)
25. listener, err := net.ListenTCP("tcp", serverAddr)
26. checkError(err, "ListenTCP: ")
27. println("Listening to: ", listener.Addr().String())
28. return listener
29. }
30. func connectionHandler(conn net.Conn) {
31. connFrom := conn.RemoteAddr().String()
32. println("Connection from: ", connFrom)
33. talktoclients(conn)
34. for {
35. var ibuf []byte = make([]byte, maxRead + 1)
36. length, err := conn.Read(ibuf[0:maxRead])
37. ibuf[maxRead] = 0 // to prevent overflow
38. switch err {
39. case nil:
40. handleMsg(length, err, ibuf)
42. default:
43. goto DISCONNECT
44. }
45. }
46. DISCONNECT:
47. err := conn.Close()
48. println("Closed connection:" , connFrom)
49. checkError(err, "Close:" )
50. }
51. func talktoclients(to net.Conn) {
52. wrote, err := to.Write(msgStart)
53. checkError(err, "Write: wrote " + string(wrote) + " bytes.")
54. }
55. func handleMsg(length int, err error, msg []byte) {
56. if length > 0 {
57. for i := 0; ; i++ {
58. if msg[i] == 0 {
59. break
60. }
61. }
62. fmt.Printf("Received data: %v", string(msg[0:length]))
63. fmt.Println(" length:",length)
64. }
65. }
66. func checkError(error error, info string) {
67. if error != nil {
68. panic("ERROR: " + info + " " + error.Error()) // terminate program
69. }
70. }

客户端代码：

1. using System;
2. using System.Collections.Generic;
3. using System.ComponentModel;
4. using System.Data;
5. using System.Drawing;
6. using System.Text;
7. using System.Windows.Forms;
8. using System.Net;
9. using System.Net.Sockets;
10. using System.Threading;
12. namespace TcpClient
13. {
14. public partial class Form1 : Form
15. {
16. private IPAddress _ipServer; //服务器IP
17. private IPEndPoint _myServer; //服务器终端
18. private Socket _connectSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//连接套接字
19. private int _port; //端口
20. private Thread receiveThread = null;
21. public Form1()
22. {
23. InitializeComponent();
24. }
26. private bool ValidateInfo() //检验所填信息是否合法
27. {
28. if (!IPAddress.TryParse(txtbxIP.Text, out _ipServer))
29. {
30. MessageBox.Show("IP地址不合法!", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
31. return false;
32. }
33. if (!int.TryParse(txtbxPortNum.Text, out _port))
34. {
35. MessageBox.Show("端口号不合法!", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
36. return false;
37. }
38. else
39. {
40. if (_port < 1024 || _port > 65535)
41. {
42. MessageBox.Show("端口号不合法!", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
43. return false;
44. }
45. }
46. return true;
47. }
50. private bool ConnectServer() //连接服务器
51. {
52. try
53. {
54. _connectSocket.Connect(_myServer);
55. _connectSocket.Send(System.Text.Encoding.UTF8.GetBytes(txtbxUser.Text.ToString()));
57. return true;
58. }
59. catch
60. {
61. MessageBox.Show("服务器连接异常", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
62. return false;
63. }
64. }
67. private void button1_Click(object sender, EventArgs e)
68. {
69. try
70. {
71. _connectSocket.Send(System.Text.Encoding.UTF8.GetBytes(comboBox1.Text.ToString()));
72. }
73. catch
74. {
75. MessageBox.Show("服务器连接异常", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
76. }
78. }
80. private void button3_Click(object sender, EventArgs e)
81. {
83. if (!ValidateInfo())
84. {
85. return;
86. }
87. _myServer = new IPEndPoint(_ipServer, _port);
89. if (ConnectServer() == true)
90. {
91. MessageBox.Show("连接成功！");
93. }
94. }
95. private void button2_Click(object sender, EventArgs e)
96. {
97. this.Close();
98. }
100. private void button4_Click(object sender, EventArgs e)
101. {
102. for (int i = 0; i < 1000; i++) {
103. Socket _connectSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
104. _connectSocket.Connect(_myServer);
105. _connectSocket.Send(System.Text.Encoding.UTF8.GetBytes(comboBox1.Text.ToString()+i));
106. Thread.Sleep(2);
108. }
111. }
113. }
114. }