golang tcp套接字-处理多条消息

Question

我有这个tcp插座

package main

import (
  "fmt"
  "io"
  "log"
  "net"
  "bytes"
)

func main() {

  l, err := net.Listen("tcp", ":1200")
  if err != nil {
    log.Fatal(err)
  }
  defer l.Close()
  for {

    conn, err := l.Accept()
    if err != nil {
      log.Fatal(err)
    }

    go func(c net.Conn) {

      var buf bytes.Buffer
      io.Copy(&buf, c)
      fmt.Println("total size:", buf.Len())
      s := buf.String()
      println(s)

      c.Close()
    }(conn)
  }
}

接受一条消息，将其转换为字符串并显示它，但是如果连接没有被客户端关闭，我就不能像预期的那样看到服务器上显示的消息

如何在不需要关闭客户端连接的情况下（由客户端）从客户端发送多条消息？

这里是NodeJs中的客户端

var net = require('net');

let packet = {
              Target: { Host: "", Port: "9000" },
              Name: { Family: "Newmarch", Personal: "Jan" },
              Email: [
                      { Kind: "home", Address: "[e-mail]"},
                      { Kind: "work", Address: "[e-mail]"}
                     ]
}


var client = new net.Socket();
client.connect(1200, '0.0.0.0', function() {
  console.log('Connected');
  client.write( (new Buffer(JSON.stringify(packet), 'UTF-8')) );
  client.end();
  //client.write('\n');
});

client.on('data', function(data) {
  console.log('Received: ' + data);
  client.destroy();
});

client.on('close', function() {
  console.log('Connection closed');
});

谢谢valeriano cossu

Answer 1

从io软件包文档中：https://golang.org/pkg/io/#Copy，复制函数将复制，直到遇到EOF。

您不手动发送EOF，但关闭连接的客户端会这样做，因此复制功能可以完成复制。

您可以使用bufiopackage读取带有分隔符的字符串：

line, err := bufio.NewReader(conn).ReadString('\n')

在上述情况下，分隔符是新行字符。您可以重用读卡器，反复调用读卡器上的ReadString来检索更多消息。

Answer 2

因为您得到的是一个恒定的数据流，服务器需要知道如何分离消息。一种方法是使用新的行字符。

我已经在下面修改了你的代码。

Go服务器：包主

import (
    "bufio"
    "log"
    "net"
)

func main() {

    l, err := net.Listen("tcp", ":1200")
    if err != nil {
        log.Fatal(err)
    }
    defer l.Close()
    for {

        conn, err := l.Accept()
        if err != nil {
            log.Fatal(err)
        }

        go func(c net.Conn) {
            for {
                message, err := bufio.NewReader(conn).ReadString('\n')
                if err != nil {
                    log.Printf("Error: %+v", err.Error())
                    return
                }

                log.Println("Message:", string(message))
            }
        }(conn)
    }
}

Nodejs客户端：

var net = require('net');

let packet = {
              Target: { Host: "", Port: "9000" },
              Name: { Family: "Newmarch", Personal: "Jan" },
              Email: [
                      { Kind: "home", Address: "[e-mail]"},
                      { Kind: "work", Address: "[e-mail]"}
                     ]
}


var client = new net.Socket();
client.connect(1200, '0.0.0.0', function() {
  console.log('Connected');

  // Send 10 messages
  for(var i = 0; i < 10; i++) {
    client.write( (new Buffer(JSON.stringify(packet), 'UTF-8')) );
    client.write('\n');
  }

  client.end();

});

client.on('data', function(data) {
  console.log('Received: ' + data);
  client.destroy();
});

client.on('close', function() {
  console.log('Connection closed');
});