gpt4 book ai didi

java - 简单服务器/客户端套接字 : BLOCKING - Java

转载 作者:行者123 更新时间:2023-12-01 18:19:46 25 4
gpt4 key购买 nike

我有一个客户端和一个服务器,这是一个尝试以非常简单的方式模拟 http 协议(protocol)的经典示例。首先客户端发送数据,服务器打印数据,然后相反。在以下代码中,服务器或客户端由于未知原因而阻塞。客户端向服务器发送数据,服务器接收数据并打印。但它只是在打印数据后阻塞。如果我关闭客户端的输出流(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) {}
}
}
}

最佳答案

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

首先,取出 out.close() ,而不是检查 -1,尝试创建一个“exit”字符串。如果服务器读取退出字符串,则认识到它需要停止处于 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() 才会流。

关于java - 简单服务器/客户端套接字 : BLOCKING - Java,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27954147/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com