我来自波兰,对我的任何错误深表歉意。
当我停止烦人的问题时,我已经为小型服务器和客户端连接编写了一段时间。当我从客户端向服务器发送信息(字符串)时,服务器可以获取它,但无法对其进行响应。
这是代码。
客户
private static Socket socket;
public static void main(String args[]){
try{
String host = "localhost";
int port = 25002;
InetAddress address = InetAddress.getByName(host);
socket = new Socket();
socket.connect(new InetSocketAddress(host, port), 5000);
//Send the message to the server
System.out.println("< "+sendMessage(socket));
//socket.shutdownOutput();
System.out.println("> "+getMessage(socket));
}catch (SocketTimeoutException e){
System.out.println(e.getMessage()); // changed
}catch (IOException e){
System.out.println(e.getMessage()); // changed
}catch (IllegalBlockingModeException e){
System.out.println(e.getMessage()); // changed
}catch(IllegalArgumentException e){
System.out.println(e.getMessage()); // changed
}finally{
//Closing the socket
try{
socket.close();
}catch(Exception e){
System.out.println(e.getMessage()); // changed
}
}
}
public static String sendMessage(Socket client){
try {
String message = "test";
PrintWriter writer = new PrintWriter(client.getOutputStream(), true);
writer = new PrintWriter(client.getOutputStream(), true);
writer.print(message);
writer.flush();
writer.close();
return message;
} catch (IOException e) {
System.out.println(e.getMessage()); // changed
return "false";
}
}
public static String getMessage(Socket client){
try {
BufferedReader socketReader = new BufferedReader(new InputStreamReader(client.getInputStream()));
return socketReader.readLine();
} catch (IOException e){
System.out.println(e.getMessage()); // changed
return "false";
}
}
和..服务器
public class kRcon{
private static Socket socket;
private static ServerSocket serverSocket;
private static Thread u;
private static class Server extends Thread {
public void run() {
int port = 25002;
try {
serverSocket = new ServerSocket(port);
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
while(true) {
try {
socket = serverSocket.accept();
BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
BufferedWriter socketWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
String str = socketReader.readLine();
socketReader.close();
System.out.println(str);
socketWriter.write("test");
socketWriter.flush();
socketWriter.close();
}
}catch (IOException e1) {
e1.printStackTrace();
}
}
public static void init(){
try {
u = new Server();
u.setName("Server");
u.start();
} catch (IOException e) {
System.out.println(e.getMessage()); // changed
}
}
}
结果
如果我先启动服务器,一切看起来都很好。因此,我使用参数“ test”启动客户端,输出到控制台的nad是:
< test
Socket is closed // changed
在控制台的服务器端,我有:
"test"
Socket is closed // changed
我试图关闭输入和输出,但无法正常工作..我现在不知道该怎么做。请帮忙:c
编辑于2015-04-03,
我更改了注释为“ changed”的行。
对于Google和读者来说,要解决问题,请不要关闭客户端的StreamReaders nad和StreamWriters。感谢EJP的帮助!
来自波兰的问候。
收到异常后,将其打印出来。不要只是丢掉所有这些信息。而且也不返回魔术Strings
。在这种情况下,应该让异常传播。如果您做了所有的一切,您将看到SocketException: socket closed
抛出的异常,getMessage(),
并且您将需要进行一些具体的调查,而不是一个完整的谜。
这是由于关闭PrintWriter
in导致的。关闭sendMessage().
一个套接字的输入或输出流会关闭另一个流和该套接字。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句