使用同一个客户端套接字向服务器套接字发送多条消息

Question

关于使用Java套接字的例子有上百万个——每个都是一样的！每一个都显示了一个正在创建的客户机套接字，一些文本正在发送，并且套接字已关闭。

我正在编写一些测试代码。我希望我的客户端循环并发送相当多的消息。每次关闭客户端套接字并重新创建似乎很傻，所以我想我只创建一个客户端套接字，循环循环并在同一个套接字上发送数据。问题是——我的服务器套接字不会打印出它收到的内容，直到客户端发送最后一条消息并且客户端套接字关闭。

服务器：

Socket  sock;
ClientConnection    client;

ServerSocket ss = new ServerSocket(portNumber);
ss.setSoTimeout(0); // 0=infinite

while (true) {
    sock = ss.accept();
    client = new ClientConnection(sock);
    new Thread(client).start();
    // ClientConnection reads from sock, prints, and closes sock
}

ClientConnection（服务器端的一个单独类）：

public class ClientConnection implements Runnable
{
    private Socket  m_socket;
    private BufferedReader m_in = null;

    public ClientConnection(Socket socket)
    {
        m_socket = socket;

        try {
            InputStream inStream = socket.getInputStream();
            m_in = new BufferedReader(new InputStreamReader(inStream));
        }
        catch (IOException ioe) {
            ioe.printStackTrace();
        }
    }

    public String getMessage()
    {
        String line = null;
        StringBuffer    completeMessage = new StringBuffer();

        try {
            while ((line = m_in.readLine()) != null)
            {
                completeMessage.append(line);
            }
         }
         catch (IOException ioe) {
             ioe.printStackTrace();
             return "";
         }

         return completeMessage.toString();
    }

    public void run()
    {
        try {
            String message = getMessage();
            System.out.println("Received: " +message);
        }
        finally
        {
            try {
                m_socket.close();
            }
            catch (IOException ioe) {
                ioe.printStackTrace();
            }
        }
    }
}

客户：

socket = new java.net.Socket(m_destination, m_portNumber);
outputStream = socket.getOutputStream();
printStream = new java.io.PrintStream(outputStream);

while (more-stuff-to-send)
{
    printStream.print(text);
    printStream.print("\n");
    printStream.flush();
}

prinStream.close();
socket.close();

ClientConnection是在启动客户端时由服务器创建的，但在客户端完成发送之前，它不会打印已发送的内容。

我觉得我错过了这条线的某个地方。聊天示例非常常见，所以如果我有一个聊天客户端，那么它想发送给聊天服务器的每条消息都会创建一个客户端套接字，发送消息，然后关闭套接字？只是看起来有点不对劲。

谢谢你。

Answer 1

client = new ClientConnection(sock);

您正在构造函数中传递套接字。

所以你不应该这样做：

socket = new java.net.Socket(m_destination, m_portNumber);

只需将constructor提供的梵蒂冈缓存为：this。袜子=袜子 读取和写入都正常，服务器也正常。

我会使用一个Vector来同步发送消息的队列，而while（more-eset-to-send）循环会检查队列和id是否为空，如果有东西要发送，比弹出第一个并发送它，而他必须做的事情，或者套接字关闭了我的客户端。