试图编写一个简单的服务器来回显文本,需要给它多个线程。每当客户端连接时,我都会关闭一个套接字我不太确定出了什么问题,而且我才刚刚开始学这个,所以我知识不渊博。如果有人能告诉我哪里出了问题,我将不胜感激。注意:这段代码显然还没有完全完成,我主要需要解决上述问题
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.BufferedReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.IOException;
public final class EchoServer
{
public static void main(String[] args) throws Exception
{
try (ServerSocket serverSocket = new ServerSocket(22222))
{
while (true)
{
try (Socket socket = serverSocket.accept())
{
Thread newThread = new Thread(new server(socket));
newThread.start();
}
}
}
}
}
class server implements Runnable
{
Socket mySocket;
server(Socket s)
{
mySocket = s;
}
public void run()
{
//while(true)
//{
try
{
System.out.println("Client connected ");
InputStream is = mySocket.getInputStream();
InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
OutputStream os = mySocket.getOutputStream();
PrintStream out = new PrintStream(os);
String input = ("...");
while(!input.equals("exit"))
{
input = br.readLine();
out.println("Server> " + input);
}
}
catch(IOException e)
{
System.out.println(e);
}
//}
}
}
尝试使用资源块,当它们退出时立即关闭资源,因此
try (Socket socket = serverSocket.accept())
{
Thread newThread = new Thread(new server(socket));
newThread.start();
}
// socket is closed by here, but newThread may still be running.
所以,只需移除try
:
Socket socket = serverSocket.accept();
Thread newThread = new Thread(new server(socket));
newThread.start();
// socket is still open here.
但请记住(最终)关闭server
类中的套接字。