閱讀553 返回首頁    go 阿裏雲 go 技術社區[雲棲]

Google GO與C#之間的TCP通信案例

我本人也才接觸GO兩個多月的曆史,看了幾本英文教程，讀了些Github上麵的源碼，但已經被GO的語言的簡潔和強大的並發能力所吸收，也打算繼續深入的學習，並應用到自己的工作之中。GO語言目前主要適用於服務端的開發，我參考了一些網絡上的教程，做了一些TCP服務端的小練習，其中服務端用GO語言開發，客戶端采用C#。具體參考如下的代碼：https://github.com/yfl8910/gotcpserver

效果圖如下：

服務端代碼：



    

  1. package main 
    2. 

  2. import ( 
    3. 

  3. "net" 
    4. 

  4. "fmt" 
    5. 

  5. ) 
    6. 

  6.  
    7. 

  7. var ( maxRead = 25 
    8. 

  8.  msgStop = []byte("cmdStop") 
    9. 

  9.  msgStart = []byte("cmdContinue") 
    10. 

  10.  ) 
    11. 

  11. func main() { 
    12. 

  12.  
    13. 

  13.  hostAndPort := "localhost:54321" 
    14. 

  14.  listener := initServer(hostAndPort) 
    15. 

  15.  for { 
    16. 

  16.  conn, err := listener.Accept() 
    17. 

  17.  checkError(err, "Accept: ") 
    18. 

  18.  go connectionHandler(conn) 
    19. 

  19.  } 
    20. 

  20. } 
    21. 

  21. func initServer(hostAndPort string) *net.TCPListener { 
    22. 

  22.  serverAddr, err := net.ResolveTCPAddr("tcp", hostAndPort) 
    23. 

  23.  checkError(err, "Resolving address:port failed: '" + hostAndPort + "'") 
    24. 

  24.  //listener, err := net.ListenTCP("tcp", serverAddr) 
    25. 

  25.  listener, err := net.ListenTCP("tcp", serverAddr) 
    26. 

  26.  checkError(err, "ListenTCP: ") 
    27. 

  27.  println("Listening to: ", listener.Addr().String()) 
    28. 

  28.  return listener 
    29. 

  29. } 
    30. 

  30. func connectionHandler(conn net.Conn) { 
    31. 

  31.  connFrom := conn.RemoteAddr().String() 
    32. 

  32.  println("Connection from: ", connFrom) 
    33. 

  33.  talktoclients(conn) 
    34. 

  34.  for { 
    35. 

  35.  var ibuf []byte = make([]byte, maxRead + 1) 
    36. 

  36.  length, err := conn.Read(ibuf[0:maxRead]) 
    37. 

  37.  ibuf[maxRead] = 0 // to prevent overflow 
    38. 

  38.  switch err { 
    39. 

  39.  case nil: 
    40. 

  40.  handleMsg(length, err, ibuf) 
    41. 

  41.  
    42. 

  42.  default: 
    43. 

  43.  goto DISCONNECT 
    44. 

  44.  } 
    45. 

  45.  } 
    46. 

  46.  DISCONNECT: 
    47. 

  47.  err := conn.Close() 
    48. 

  48.  println("Closed connection:" , connFrom) 
    49. 

  49.  checkError(err, "Close:" ) 
    50. 

  50.  } 
    51. 

  51. func talktoclients(to net.Conn) { 
    52. 

  52.  wrote, err := to.Write(msgStart) 
    53. 

  53.  checkError(err, "Write: wrote " + string(wrote) + " bytes.") 
    54. 

  54. } 
    55. 

  55. func handleMsg(length int, err error, msg []byte) { 
    56. 

  56.  if length > 0 { 
    57. 

  57.  for i := 0; ; i++ { 
    58. 

  58.  if msg[i] == 0 { 
    59. 

  59.  break 
    60. 

  60.  } 
    61. 

  61.  } 
    62. 

  62.  fmt.Printf("Received data: %v", string(msg[0:length])) 
    63. 

  63.  fmt.Println(" length:",length) 
    64. 

  64.  } 
    65. 

  65. } 
    66. 

  66. func checkError(error error, info string) { 
    67. 

  67.  if error != nil { 
    68. 

  68. panic("ERROR: " + info + " " + error.Error()) // terminate program 
    69. 

  69. } 
    70. 

  70. } 
    71. 



客戶端代碼：




    

  1. using System; 
    2. 

  2. using System.Collections.Generic; 
    3. 

  3. using System.ComponentModel; 
    4. 

  4. using System.Data; 
    5. 

  5. using System.Drawing; 
    6. 

  6. using System.Text; 
    7. 

  7. using System.Windows.Forms; 
    8. 

  8. using System.Net; 
    9. 

  9. using System.Net.Sockets; 
    10. 

  10. using System.Threading; 
    11. 

  11.  
    12. 

  12. namespace TcpClient 
    13. 

  13. { 
    14. 

  14.  public partial class Form1 : Form 
    15. 

  15.  { 
    16. 

  16.  private IPAddress _ipServer; //服務器IP 
    17. 

  17.  private IPEndPoint _myServer; //服務器終端 
    18. 

  18.  private Socket _connectSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//連接套接字 
    19. 

  19.  private int _port; //端口 
    20. 

  20.  private Thread receiveThread = null; 
    21. 

  21.  public Form1() 
    22. 

  22.  { 
    23. 

  23.  InitializeComponent(); 
    24. 

  24.  } 
    25. 

  25.  
    26. 

  26.  private bool ValidateInfo() //檢驗所填信息是否合法 
    27. 

  27.  { 
    28. 

  28.  if (!IPAddress.TryParse(txtbxIP.Text, out _ipServer)) 
    29. 

  29.  { 
    30. 

  30.  MessageBox.Show("IP地址不合法!", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information); 
    31. 

  31.  return false; 
    32. 

  32.  } 
    33. 

  33.  if (!int.TryParse(txtbxPortNum.Text, out _port)) 
    34. 

  34.  { 
    35. 

  35.  MessageBox.Show("端口號不合法!", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information); 
    36. 

  36.  return false; 
    37. 

  37.  } 
    38. 

  38.  else 
    39. 

  39.  { 
    40. 

  40.  if (_port < 1024 || _port > 65535) 
    41. 

  41.  { 
    42. 

  42.  MessageBox.Show("端口號不合法!", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information); 
    43. 

  43.  return false; 
    44. 

  44.  } 
    45. 

  45.  } 
    46. 

  46.  return true; 
    47. 

  47.  } 
    48. 

  48.  
    49. 

  49.  
    50. 

  50.  private bool ConnectServer() //連接服務器 
    51. 

  51.  { 
    52. 

  52.  try 
    53. 

  53.  { 
    54. 

  54.  _connectSocket.Connect(_myServer); 
    55. 

  55.  _connectSocket.Send(System.Text.Encoding.UTF8.GetBytes(txtbxUser.Text.ToString())); 
    56. 

  56.  
    57. 

  57.  return true; 
    58. 

  58.  } 
    59. 

  59.  catch 
    60. 

  60.  { 
    61. 

  61.  MessageBox.Show("服務器連接異常", "錯誤", MessageBoxButtons.OK, MessageBoxIcon.Error); 
    62. 

  62.  return false; 
    63. 

  63.  } 
    64. 

  64.  } 
    65. 

  65.  
    66. 

  66.  
    67. 

  67.  private void button1_Click(object sender, EventArgs e) 
    68. 

  68.  { 
    69. 

  69.  try 
    70. 

  70.  { 
    71. 

  71.  _connectSocket.Send(System.Text.Encoding.UTF8.GetBytes(comboBox1.Text.ToString())); 
    72. 

  72.  } 
    73. 

  73.  catch 
    74. 

  74.  { 
    75. 

  75.  MessageBox.Show("服務器連接異常", "錯誤", MessageBoxButtons.OK, MessageBoxIcon.Error); 
    76. 

  76.  } 
    77. 

  77.  
    78. 

  78.  } 
    79. 

  79.  
    80. 

  80.  private void button3_Click(object sender, EventArgs e) 
    81. 

  81.  { 
    82. 

  82.  
    83. 

  83.  if (!ValidateInfo()) 
    84. 

  84.  { 
    85. 

  85.  return; 
    86. 

  86.  } 
    87. 

  87.  _myServer = new IPEndPoint(_ipServer, _port); 
    88. 

  88.  
    89. 

  89.  if (ConnectServer() == true) 
    90. 

  90.  { 
    91. 

  91.  MessageBox.Show("連接成功！"); 
    92. 

  92.  
    93. 

  93.  } 
    94. 

  94.  } 
    95. 

  95.  private void button2_Click(object sender, EventArgs e) 
    96. 

  96.  { 
    97. 

  97.  this.Close(); 
    98. 

  98.  } 
    99. 

  99.  
    100. 

  100.  private void button4_Click(object sender, EventArgs e) 
    101. 

  101.  { 
    102. 

  102.  for (int i = 0; i < 1000; i++) { 
    103. 

  103.  Socket _connectSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 
    104. 

  104.  _connectSocket.Connect(_myServer); 
    105. 

  105.  _connectSocket.Send(System.Text.Encoding.UTF8.GetBytes(comboBox1.Text.ToString()+i)); 
    106. 

  106.  Thread.Sleep(2); 
    107. 

  107.  
    108. 

  108.  } 
    109. 

  109.  
    110. 

  110.  
    111. 

  111.  } 
    112. 

  112.  
    113. 

  113.  } 
    114. 

  114. } 
    115. 



最後更新：2017-04-03 22:30:58
  上一篇：go Python+MongoDB 爬蟲實戰
  下一篇：go Python多線程下載有聲小說