首页 文章

Golang TCP客户端不会将“End of Stream”发送到Java TCP Server

提问于
浏览 906
0

我正在编写一个与Java TCP Server对话的简单Golang TCP客户端 .

我已经成功地让我的Golang客户端向我的Java服务器发送消息 .

但是,我的Java代码期望 End of Stream (其中 inputStream.read() 返回 -1 )知道是时候停止读取客户端消息了 .

看起来Golang不会通过 connection.Write() 发送 End of Stream 消息,除非我先连接 Close() .

下面是我的Java Server代码:

package com.mycompany.app;

import com.google.gson.*;
import com.google.common.primitives.Bytes;
import java.io.*;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.net.ServerSocket;
import java.net.SocketException;

public class MyApp {
    public static void main(String[] args) {
        int port = 9000;

        // Start listening for messages.
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("Listening on port " + port + "...");

            // Never stop listening for messages.
            while (true) {
                try {
                    // Accept a client connection.
                    Socket socket = serverSocket.accept();

                    // Read message from the client.
                    DataInputStream inputStream = new DataInputStream(socket.getInputStream());

                    List<Byte> list = new ArrayList<Byte>();
                    int input = inputStream.read();

                    while (input != -1) {
                        list.add((byte) input);
                        input = inputStream.read();
                    }

                    byte[] jsonBytes = Bytes.toArray(list);

                    if (jsonBytes.length > 0) {
                        String jsonString = new String(jsonBytes);

                        System.out.println("Received: " + jsonString);

                        // Unmarshal from JSON.
                        Person person = new Gson().fromJson(jsonString, Person.class);

                        System.out.println("Person: " + person.Name + " " + person.Age);
                    }
                } catch (EOFException e) {
                    // A client has disconnected. Do nothing.
                } catch (SocketException e) {
                    // A client connection has been terminated unexpectedly. Do nothing.
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

class Person {
    String Name;
    int Age;
}

以下是我的Golang客户端代码:

package main

import (
    "bufio"
    "encoding/json"
    "fmt"
    "net"
    "os"
    "strings"
)

type Person struct {
    Name string
    Age  int
}

func main() {
    reader := bufio.NewReader(os.Stdin)

    for {
        func() {
            // Dial the Java Server.
            conn, err := net.Dial("tcp", "localhost:9000")
            if err != nil {
                fmt.Println(err)
            }

            defer conn.Close()

            fmt.Print("Enter Name: ")
            strName, err := reader.ReadString('\n')
            strName = strings.TrimSpace(strName)

            var person Person
            person.Name = strName
            person.Age = 18

            jsonBytes, err := json.Marshal(person)
            if err != nil {
                fmt.Println(err)
                return
            }

            // Write our message to the connection.
            _, err = conn.Write(jsonBytes)
            if err != nil {
                fmt.Println(err)
                return
            }

            fmt.Println("Sent: " + string(jsonBytes))
        }()
    }
}

关于如何告诉Java我们已经完成了从Golang编写消息的任何建议?或者有更好的方法来处理Java x Golang TCP客户端 - 服务器连接吗?

这是一个非常严重的问题,因为TCP连接的基本方案之一是发送和接收:

例如

  • 客户端发送消息并等待结果 .

  • Server处理消息并返回结果 .

  • 客户端对结果做了一些事情 .

2 回答

  • 2

    我终于让它按照@nos的建议去调用 CloseWrite() 而不是 Close() .

    不得不稍微改变我的TCP连接代码,但它就像一个魅力 .

    这个解决方案非常适合我的目的,因为我只打算从客户端连接发送1个,在关闭它之前可能只读1个 .

    非常感谢所有帮助过的人!

    以下是我更新的Golang客户端代码:

    package main
    
    import (
        "bufio"
        "encoding/json"
        "fmt"
        "net"
        "os"
        "strings"
    )
    
    // Person struct.
    type Person struct {
        Name string
        Age  int
    }
    
    func main() {
        reader := bufio.NewReader(os.Stdin)
    
        for {
            func() {
                // Dial the Java Server.
                tcpAddr, err := net.ResolveTCPAddr("tcp", "localhost:9000")
                if err != nil {
                    fmt.Println(err)
                    return
                }
    
                conn, err := net.DialTCP("tcp", nil, tcpAddr)
                if err != nil {
                    fmt.Println(err)
                    return
                }
    
                defer conn.Close()
    
                fmt.Print("Enter Name: ")
                strName, err := reader.ReadString('\n')
                strName = strings.TrimSpace(strName)
    
                var person Person
                person.Name = strName
                person.Age = 18
    
                jsonBytes, err := json.Marshal(person)
                if err != nil {
                    fmt.Println(err)
                    return
                }
    
                // Write our message to the connection.
                _, err = conn.Write(jsonBytes)
                if err != nil {
                    fmt.Println(err)
                    return
                }
    
                // Tell the server that we're done writing.
                err = conn.CloseWrite()
                if err != nil {
                    fmt.Println(err)
                    return
                }
    
                // Read Message From Server code goes here.
    
                fmt.Println("Sent: " + string(jsonBytes))
            }()
        }
    }
    
  • 0

    对于初学者,您可能希望确保您的客户端代码可靠地关闭套接字 . 但这不是你应该做的全部 .

    由于关闭套接字,客户端进程应触发TCP FIN . 由于客户端进程干净地退出,套接字应该关闭 . 不知道为什么不是这种情况 . 你在等待足够长的时间吗?

    但是,为了使您的服务器无法无限期挂起,您需要防范这种情况 . 考虑客户端和服务器之间存在活动TCP连接的情况 . 当服务器正在等待来自客户端的数据时,电源会在客户端所在的位置消失 . 因为客户端无法发送FIN,所以服务器连接不会有任何流量 . TCP连接将永远保持挂起,除非....

    您可以在服务器端设置保持活动选项或超时选项 .

    保持活力:https://docs.oracle.com/javase/7/docs/api/java/net/SocketOptions.html#SO_KEEPALIVE

    超时:https://docs.oracle.com/javase/7/docs/api/java/net/SocketOptions.html#SO_TIMEOUT

相关问题