第65 章 TCP续1

    也可以使用 java 或 c++ 实现 tcp 粘包处理。以下是使用 java 实现的简单粘包处理示例：

    java 示例

    服务器端代码（tcpserverjava）：

    ```java

    import javaio;

    ;

    public class tcpserver {

    public static void main(string[] args) throws ioexception {

    serversocket serversocket = new serversocket(12345);

    systemoutprintln(&34;服务器已启动，等待客户端连接&34;);

    while (true) {

    socket clientsocket = serversocketaccept();

    systemoutprintln(&34;客户端已连接&34;);

    bufferedreader input = new bufferedreader(new inputstreamreader(clientsocketgetinputstream()));

    dataoutputstream output = new dataoutputstream(clientsocketgetoutputstream());

    string line;

    while ((line = inputreadline()) != null) {

    systemoutprintln(&34;收到客户端消息: &34; + line);

    // 这里添加粘包处理

    while (!lineisempty()) {

    string pletemand = linesubstring(0, lineindexof(&39;\n&39;));

    line = linesubstring(pletemandlength() + 1);

    // 执行命令并获取结果

    string result = executemand(pletemand);

    // 将结果发送回客户端

    outputwritebytes(result + &34;\n&34;);

    }

    }

    clientsocketclose();

    systemoutprintln(&34;客户端已断开连接&34;);

    }

    }

    private static string executemand(string mand) {

    // 在这里实现命令执行逻辑

    return &34;mand executed: &34; + mand;

    }

    }

    ```

    客户端代码（tcpclientjava）：

    ```java

    import javaio;

    ;

    public class tcpclient {

    public static void main(string[] args) throws ioexception {

    socket clientsocket = new socket(&34;&34;, 12345);

    systemoutprintln(&34;已连接服务器&34;);

    bufferedreader input = new bufferedreader(new inputstreamreader(systemin));

    printwriter output = new printwriter(clientsocketgetoutputstream(), true);

    bufferedreader serverresponse = new bufferedreader(new inputstreamreader(clientsocketgetinputstream()));

    string mand;

    while (!(mand = inputreadline())isempty()) {

    outputprintln(mand);

    // 这里添加粘包处理

    string responseline;

    stringbuilder response = new stringbuilder();

    while (!(responseline = serverresponsereadline())isempty()) {

    responseappend(responseline);

    responseappend(&34;\n&34;);

    }

    systemoutprintln(&34;收到服务器响应: &34; + responsetostring());

    }

    clientsocketclose();

    systemoutprintln(&34;客户端已断开连接&34;);

    }

    }

    ```

    在这个示例中，服务器端和客户端实现了一个简单的命令执行功能。服务器端收到客户端发送的命令后，执行命令并将结果发送回客户端。