简单的服务器/客户端套接字：阻塞 - Java答案

【问题标题】：Simple Server/Client Socket: BLOCKING - Java简单的服务器/客户端套接字：阻塞 - Java
【发布时间】：2015-01-15 07:21:33
【问题描述】：

我有一个客户端和一个服务器，这是一个尝试以非常简单的方式模拟 http 协议的经典示例。首先客户端发送数据，而服务器打印数据，然后相反。在以下代码中，服务器或客户端因未知原因而阻塞。客户端向服务器发送数据，服务器接收数据并打印。但它只是在打印数据后阻塞。如果我关闭客户端的输出流（out.close()），客户端应该获取服务器的数据，但会抛出 IOException 并显示消息：套接字已关闭。

我的问题是它为什么会阻塞？我必须用 EOS 触发输出吗？

客户

import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.util.*;
import java.io.IOException;
import java.io.*;


public class block_client_webclient
{
    public static void main(String [] args)
    {
        try{

            Socket s = new Socket("localhost", 8080);

            OutputStreamWriter out = new OutputStreamWriter(s.getOutputStream());
            InputStreamReader in = new InputStreamReader(s.getInputStream());

            //WRITE
            out.write("GET / HTTP/1.1\r\nUser-agent: Agent 2.0 Browser\r\nAccept: */*\r\nAccept-Language: en-US,en;q=0.5\r\nConnection: keep-alive\r\n\r\n");
            out.flush();
            out.close();

            if (s.isConnected()==true && s.isClosed()==false) System.out.println("OPEN");
            else System.out.println("CLOSED");

            char[] bin = new char[400];
            int r=0;

            //READ
            while((r=in.read(bin))!=-1) { System.out.println("Input data: "+r+" bytes"); System.out.print(bin); bin= new char[400]; };
            System.out.println(r);

            s.close();

        }
        catch (IOException ex) {System.out.println(ex.getMessage());}
    }
}

服务器

import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.util.*;
import java.io.IOException;
import java.io.*;


public class block_server_webserver
{
    public static void main(String [] args)
    {
        while(true)
        {
        try{
            ServerSocket server = new ServerSocket(8080);
            Socket connection = server.accept();
            try{
            OutputStreamWriter out = new OutputStreamWriter( connection.getOutputStream());
            InputStreamReader in = new InputStreamReader( connection.getInputStream());

            char[] bin = new char[400];
            int r=0;
            int readsofar=0;

            //READ
            while((r=in.read(bin))!=-1) { System.out.print(bin); bin= new char[400]; };
            System.out.println("END");

            //WRITE
            out.write("Server: BlockServer 1.0\r\nHost: 192.168.1.1\r\n\r\n");
            out.flush();
            System.out.println("Just written data to "+connection.getRemoteSocketAddress());
            connection.close();

            } catch (IOException ex) { connection.close();}
        }catch (IOException ex) {}
     }
    }
}

【问题讨论】：

标签： java network-programming

【解决方案1】：

执行 out.close() 会导致套接字关闭异常，因为当您关闭输入/输出流时，与之相关的套接字也会关闭。这意味着在您的客户端程序中，您将无法在关闭套接字后读取。

首先，取出 out.close() 而不是检查 -1，尝试创建一个“退出”字符串。如果服务器读取了退出字符串，请认识到它需要停止在 while 循环中并直接中断；（可以用一个简单的 if 语句来完成）。另外，通常我会使用缓冲读取器、String x 和 readLine() 而不是 char 数组 + read()。

while (true) {
    in.read(bin);
    if (bin[0] == '^') { // or something like that
        break;
    }
    System.out.print(bin);
    bin = new char[400];
}

只有在你完全使用完套接字后才使用 close() 流。

【讨论】：

【解决方案2】：

服务器不应等待套接字关闭（因为一旦发生这种情况，它将无法回写）。

而不是读取直到它返回 -1（关闭），它应该读取到请求的末尾（如果是 http 标头，则需要两个新行），并在发生这种情况时立即开始发送输出，然后，可能，关闭连接通知客户端没有更多数据（在http中，连接通常保持打开一段时间，客户端根据Content-length标头知道在收到足够的字节后停止读取）。

【讨论】：