客户端不从套接字读取数据?
Posted
技术标签:
【中文标题】客户端不从套接字读取数据?【英文标题】:Client not reading data from socket? 【发布时间】:2016-03-02 21:07:00 【问题描述】:我花了一段时间阅读其他帖子,但似乎没有人和我有同样的情况。我已经尝试了所有我读过的解决方案,但没有结果,所以我决定提出这个问题。
我一直在开发服务器/客户端应用程序,客户端似乎没有从套接字读取数据,但服务器可以读取客户端发送的数据。客户端在尝试读取该行时冻结。这是我的代码:
客户:
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
import java.util.Timer;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JLabel;
public class Main
public static Socket s = connect();
public static void sendMessage(String msg)
if (s != null)
PrintWriter outWriter = null;
try
outWriter = new PrintWriter(s.getOutputStream(), true);
outWriter.println(msg);
outWriter.flush();
catch (IOException ex)
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
outWriter.close();
finally
else
System.err.println("Error, socket is null!");
public static String readMessage()
if (s != null)
Scanner in = null;
try
in = new Scanner(s.getInputStream());
catch (IOException ex)
ex.printStackTrace();
String ss = "";
while (in.hasNext())
ss += in.next();
System.out.println("REPONSE:" + ss);
return ss;
else
System.err.println("Error, socket is null!");
return "err/readMessage";
public static Socket connect()
try
Socket sss = new Socket("localhost", 25586);
sss.setKeepAlive(true);
return sss;
catch (IOException ex)
ex.printStackTrace();
System.exit(-1);
return null;
public static void main(String args[])
java.awt.EventQueue.invokeLater(new Runnable()
public void run()
Thread t = new Thread(new Runnable()
@Override
public void run()
sendMessage("HELO");
System.out.println("Thread initialized.");
while (true)
try
System.out.println("Awaiting message...");
Thread.sleep(100);
String messages = readMessage();
System.out.println("Message recieved! '" + messages + "'");
String[] message = messages.split("/");
System.out.println(messages);
if (message[0].equalsIgnoreCase("DERP")) // err/reason
System.out.println("IT'S FINALLY WORKING!");
else
System.out.println("Didn't work :( response:" + messages);
catch (InterruptedException ex)
ex.printStackTrace();
);
t.start();
);
服务器:
import java.util.List;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
public class Main /* SERVER */
public static List<EchoThread> list = new ArrayList<>();
public static int PORT = 25586;
public static void main(String[] args) throws IOException
new Main(PORT);
public Main(int port) throws IOException
this.PORT = port;
ServerSocket serverSocket = null;
Socket socket = null;
try
serverSocket = new ServerSocket(PORT);
catch (IOException e)
e.printStackTrace();
while (true)
try
socket = serverSocket.accept();
catch (IOException e)
System.out.println("I/O error: " + e);
// new threa for a client
EchoThread s = new EchoThread(socket);
s.start();
list.add(s);
public static void sendMessageToAll(String ss)
for (EchoThread s : list)
s.allMessage(ss);
class EchoThread extends Thread
protected Socket socket;
InputStream inp = null;
BufferedReader brinp = null;
public EchoThread(Socket clientSocket)
this.socket = clientSocket;
try
inp = socket.getInputStream();
brinp = new BufferedReader(new InputStreamReader(inp));
catch (IOException e)
e.printStackTrace();
public void run()
String line;
while (true)
try
line = brinp.readLine();
if ((line == null) || line.equalsIgnoreCase("EXIT"))
socket.close();
return;
else
handle(line);
catch (IOException e)
e.printStackTrace();
return;
public void handle(String s)
String[] keys = s.split("/");
System.out.println("random: Handling request\"" + s + "\"");
System.out.println("Response: DERP");
if (s.equalsIgnoreCase("HELO"))
System.out.println("Message recieved:" + s);
respond("DERP");
public void respond(String s)
try
System.out.println("Response_WILLBE:" + s);
OutputStream os = socket.getOutputStream();
PrintWriter pw = new PrintWriter(os, true);
pw.println(s);
pw.flush();
System.out.println("Message sent!");
catch (Exception ex)
Logger.getLogger(EchoThread.class.getName()).log(Level.SEVERE, null, ex);
public void allMessage(String s)
respond(s);
我尝试了flush()
代码和\r\n
和println
修复,但都没有奏效!
-- 感谢您的阅读!
【问题讨论】:
无论您是否尝试过换行符和刷新,但它们都不起作用,您都应该使用它们(它们是必要的)。确保使用 PrintWriter(或任何基于文本的输出流)发送的每条消息都以 \n 结尾,并确保在发送每条消息后调用flush
。
+Nerdizzle 感谢您的回答!我已经尝试过了,但是没有用。我想既然我使用的是 println 而不是 print,它应该可以使用或不使用 \n,但以防万一,我尝试了它,但它仍然失败。我检查了,我正在使用 PrintWriter,我正在刷新(如上面的代码所示)
您的服务器可能会产生无限的数据流。除非服务器关闭连接,否则客户端中的while (in.hasNext())
永远不会终止。您可以用String ss = in.next();
或if (in.hasNext())
替换所有这些。您的客户正在接收数据,但过于贪婪
由于其中包含将其优先于其他问题的请求,因此我遗憾地投反对票。这里的读者大多是志愿者,他们会回答他们感兴趣的问题,而且他们会在闲暇时回答。 (否则你的问题是一个很好的问题)。
【参考方案1】:
我很好奇客户端和服务器的通信方式之间的差异。例如,客户端使用Scanner
来读取输入,而服务器使用BufferedReader
(这是我个人的偏好)。只是一个建议:保持一致。
现在——首先,客户端只发送一条消息,然后开始无限循环地读取。看到您确切地知道服务器在您向其发送“HELO”后应该如何响应(它应该用一行“DERP”响应),没有理由在任何类型的循环中从服务器读取。
服务器上也存在同样的问题。就像客户端现在一样,它总是只会向服务器发送一行(“HELO”)。因此,服务器应该只期望一行并且只读取一行。绝对没有理由在循环中读取输入。但是,实际问题只存在于客户端的代码中:
您当前有while(in.hasNext())
作为客户端从服务器读取输入的时间长度的条件。 The hasNext method differs in logical function depending on the method of communication. 在套接字通信的情况下,hasNext
需要一个流,因此,除非套接字关闭,否则它将始终返回 true。
除非您不知道要读取多少行,否则一般应避免在套接字通信中使用循环。在这种情况下,您应该首先让发送者向接收者发送某种数字,然后接收者应该在 for 循环中读取后续行,读取 'n' 次(其中 n 是接收到的数字)。
这是一个使用PrintWriters
和BufferedReaders.
的非常基本的客户端/服务器通信程序
客户
public static void main(String[] args)
try
Socket socket = new Socket("localhost", 12345);
PrintWriter out = new PrintWriter(socket.getOutputStream());
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out.write("HELO\n"); //print("HELO\n") and println("HELO") should work too.
out.flush();
System.out.println("Server says " + in.readLine());
in.close();
out.close();
socket.close();
catch(IOException e)e.printStackTrace();
服务器
public static void main(String[] args)
try
ServerSocket serverSocket = new ServerSocket(12345);
while(true)
new Thread(new ClientConnectionThread(serverSocket.accept())).start();
catch(IOException e)e.printStackTrace();
private class ClientConnectionThread implements Runnable
private Socket socket;
public ClientConnectionThread(Socket socket)
this.socket = socket;
@Override
public void run()
try
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream());
System.out.println("Client says " + in.readLine());
out.write("HELO Back!\n"); //again, print("HELO Back!\n") and
//println("HELO Back!") should also work
out.flush();
out.close();
in.close();
socket.close();
catch(IOException e)e.printStackTrace();
请注意,在实际通信中不需要循环。
【讨论】:
非常感谢!它现在完全完全可用!你刚刚为我节省了很多时间! :) HELO 和 DERP 只是简化程序的示例。 感谢我的示例,这是一个很好的起点。我已经复制粘贴了您的代码,但它不起作用:1) 客户端中的新 BuffereReader(new InputeStreamReader(..)) 和 2) 对于我的 JDK 9.0 版本,它仅在我添加 out.flush 后才有效。客户端中的 println。看完这个问答我做的2***.com/questions/40004783/printwriter-wont-write @Nikita 谢谢,很久以前写的,我的 Java 生锈了。添加了刷新调用(尽管服务器调用是不必要的,因为它在关闭时刷新),并修复了客户端BufferedReader
构造函数【参考方案2】:
正如@zapl 所说,您的客户端在从服务器读取数据时非常贪婪。让我们看看你用来从服务器读取数据的过程:
String ss = "";
while (in.hasNext())
ss += in.next();
System.out.println("REPONSE:" + ss);
此代码将不断从服务器拉取数据,直到流关闭。在从文件读取数据或解析字符串时,您可能会使用这种类型的代码块,这非常适合这些情况,因为您希望将流中的所有数据都放入您的字符串中。
您要做的是从新行\n
指定的服务器读取第一个响应。而不是做while(in.hasNext())
,你应该只检查是否in.hasNext()
,如果是,则将其作为响应。
String ss = "";
if (in.hasNext())
ss += in.next();
System.out.println("REPONSE:" + ss);
或者更优雅
if (in.hasNext())
String response = in.next();
System.out.println("REPONSE:" + response);
return response;
....
【讨论】:
假设在输入流的实例化中出现 IOException(在这种情况下是扫描仪,但 BufferedReader 更容易处理),其处理方式与意外关闭流的处理方式相同(意思是在. hasNext() 返回 false),我相信hasNext
方法只会使处理错误更加困难和重复(因为相同的代码将出现在扫描仪实例化 try 块的 catch 子句以及 if(in.hasNext())
的 else 语句中)。仅使用BufferedReader
并以相同的方式捕获所有 IOExceptions 不是更有意义吗?
@Nerdizzle 我同意在使用 Socket 时不建议使用 Scanner。然而,鉴于 OP 的问题,为什么他的代码不能正常工作,这就是原因。如果这是 StackExchange 的代码审查部分,我会倾向于写更多关于我对他/她的代码的个人意见。【参考方案3】:
首先,对于套接字,我总是喜欢通过 localhost 运行服务器并 telnet 进入它。当我用你的那样做时,我来回没有问题。因此,现在只需修复您的客户即可。
对于客户端,(暂时)摆脱对 Scanner 类的使用。这个类还有一整套可能导致问题的用法。相反,请保持简单。
更改您的客户端以使用 BufferedReader。这是您的新 readMessage() 方法:
public String readMessage()
if (s != null)
BufferedReader in = null;
try
System.out.println("Creating reader");
in = new BufferedReader(new InputStreamReader(s.getInputStream()));
catch (IOException ex)
String ss = "";
try
ss = in.readLine();
catch (IOException e)
System.out.println("REPONSE:" + ss);
return ss;
您的客户端现在可以正常工作(对我而言),这意味着您在使用扫描仪时遇到了问题。
我会让你调试它,因为这不是你的问题。玩得开心! ;)
【讨论】:
以上是关于客户端不从套接字读取数据?的主要内容,如果未能解决你的问题,请参考以下文章