问题描述
我正在编写一个使用线程池的客户端/服务器应用程序,以便多个客户端可以同时与服务器通信并向其发送命令:
I am writing a client/server application that uses a threadpool, so that several clients can communicate with the server at the same time and send commands to it:
但是,即使使用非常简单的客户端,它也不起作用:
But it does not work, even with an extremely simple client:
这是我的客户端:
if(args.length==0) {
host="127.0.0.1";
port=11111;
} else {
host=args[0];
String portString = args[1];
try {
port = Integer.parseInt(portString);
} catch(Exception e) {
e.printStackTrace();
port = 11111;
}
}
try {
System.out.println("Client connects to host=" + host + " port=" + port);
Socket skt = new Socket(host, port);//line 30 in the exception
BufferedReader myInput = new BufferedReader(new InputStreamReader(skt.getInputStream()));
PrintWriter myOutput = new PrintWriter(skt.getOutputStream(), true);
myOutput.println("Hello I am the Client!");
String buf=myInput.readLine();
System.out.println(buf + "=buf");
if(buf!=null) {
System.out.println("Client receives " + buf + " from the Server!");
buf=myInput.readLine();
System.out.println(buf);
}
myOutput.close();
myInput.close();
skt.close();
但我得到:
所以我我的服务器可能是错误的,因为我无法在客户端中看到它:
so I thought my server is probably the mistake, because I cannot see it in the client:
ServerMain.java
ServerMain.java
public static void main(String[] args) {
try {
clientlistener = new ClientListener(server);
//serversocket = new ServerSocket();
} catch (IOException e) {
System.out.println("Could not listen on tcpPort: " + tcpPort);
e.printStackTrace();
System.exit(-1);
}
}
在这里,我用新的
here i open the clientlistener with a new
private static Server server = new Server();
并想将其添加到serverSocket而不是threadPool:
and want to add it to the serverSocket and than to the threadPool:
public ClientListener(Server server) throws ServerException{
this.server=server;
try {
serverSocket = new ServerSocket(server.getTcpPort());
} catch (IOException e) {
throw new ServerException(e.getMessage());
}
System.out.println(String.format("Accepting new clients " +
"on %s", serverSocket.getLocalSocketAddress()));
}
/**
* Spawns new threads on incoming connection requests from clients.
* */
@Override
public void run() {
while(true){
try {
ClientCommunicator cc = new ClientCommunicator(serverSocket.accept(), pool);
threadPool.execute(cc);
clientComms.add(cc);
} catch (SocketException e) {
System.out.println(e.getMessage());
return;
} catch (IOException e) {
System.out.println(e.getMessage());
return;
}
}
}
ClientCommunicator只是一个类可以从命令行中读取。
The ClientCommunicator is just a class to read from the command line.
我的问题是:
我的套接字连接怎么了?
Whats wron with my socket connection?
我要打开一个并从客户那里接受吗?
I am opening one and accepting it from the client?
我真的很感谢您的回答!!!
I really much appreaciate your answer!!!
推荐答案
我认为您的服务器已关闭,因此您收到的连接被拒绝。我看不到您的server.accept()调用,它使服务器套接字等待新客户端来并返回不是SocketServer的Socket对象。
I think your server is down and that's why you receive a connection refused. I don't see your server.accept() call that makes server socket wait for new clients to come and returns a Socket object not SocketServer.
我已经完成了这段代码为了你。希望对您有所帮助。
I have done this code for you. I hope it helps.
package com.sockets.exam1;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerCode {
public static void main(String[] args) {
try {
ServerSocket server = new ServerSocket(11111);
while (true) {
new ThreadSocket(server.accept());
}
} catch (Exception e) {
}
}
}
class ThreadSocket extends Thread{
private Socket insocket;
ThreadSocket(Socket insocket){
this.insocket = insocket;
this.start();
}
@Override
public void run() {
try {
System.out.println("procesing request");
BufferedReader in = new BufferedReader(new InputStreamReader(
insocket.getInputStream()));
PrintWriter out = new PrintWriter(insocket.getOutputStream(),
true);
String instring = in.readLine();
out.println("The server got this: " + instring.toUpperCase());
insocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
这篇关于使用线程池的客户端/服务器连接?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!