Java<->;C#套接字:无法接收消息
本文关键字:消息 套接字 lt- gt Java | 更新日期: 2023-09-27 18:29:09
我需要在我自己编写的java
服务器和C#
客户端之间进行套接字通信,问题是C#
客户端无法从我的java服务器接收任何消息,但向我的java server发送消息是可行的。
我的工作流程:
- Java:创建服务器
- Java:正在等待客户端连接
- c#:创建客户端
- c#:建立与服务器的连接
- c#:向服务器发送消息
- Java:收到消息
- java:向c#客户端发送消息
- c#:从服务器接收消息<-这是客户端等待消息但从未得到消息的地方
Java服务器代码:
public class Communicator {
private int m_port;
private Socket m_socket;
private ServerSocket m_serverSocket;
public Communicator(int port) {
this.m_port = port;
initConnection();
}
private void initConnection() {
try {
System.out.println("Creating Server");
m_serverSocket = new ServerSocket(m_port);
System.out.println("Waiting for client connection");
m_socket = m_serverSocket.accept();
System.out.println("Connection made");
} catch (IOException e) {
e.printStackTrace();
}
}
public String sendMsg(JSONMessage msg) {
try {
//get msg
BufferedReader bufferedReader = new BufferedReader(
new InputStreamReader(m_socket.getInputStream()));
System.out.println("Waiting for msg...");
String answer = bufferedReader.readLine();
System.out.println("Received: " + answer);
//send msg
PrintWriter writer = new PrintWriter(m_socket.getOutputStream(),true);
writer.print(msg.getMsg());
System.out.println("Sending: " + msg.getMsg());
writer.flush();
} catch (IOException e) {
e.printStackTrace();
}
return "";
}
}
我的C#客户端代码:
class Communicator
{
private int m_port;
private Thread mainThread;
public Communicator(int port)
{
m_port = port;
mainThread = new Thread(new ThreadStart(this.initConnection));
mainThread.Start();
}
public void initConnection()
{
IPEndPoint ip = new IPEndPoint(IPAddress.Parse("127.0.0.1"), m_port);
Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
Console.WriteLine("Trying to build connection");
server.Connect(ip);
Console.WriteLine("Connection successful");
NetworkStream ns = new NetworkStream(server);
StreamReader sr = new StreamReader(ns);
StreamWriter sw = new StreamWriter(ns);
string data;
string welcome = "Hello";
Console.WriteLine("Sending: " + welcome);
sw.WriteLine(welcome);
sw.Flush();
Console.WriteLine("Receiving...");
data = sr.ReadLine();
// --> NEVER REACHING THIS POINT <---
Console.WriteLine("Received: " + data);
}
catch (SocketException e)
{
Console.WriteLine("Connection failed.");
return;
}
}
}
有人知道为什么它从未到达我的客户端代码Console.WriteLine("Received: " + data);
吗?
我已经试过两边都等待了。我没有得到任何异常或错误,所以我真的不知道我的问题在哪里。
感谢
如果接收方期望行,则发送方必须发送行。你的发送者不发送线路,所以接收者会一直等待,直到收到一条线路。
为了避免将来出现此类问题,您应该始终制作一份规范文档,解释协议的工作方式,最好是在字节级别。它应该指定协议是否包含消息,如果包含,发送方如何标记消息边界,接收方如何识别它们。
在这里,您的接收者通过查找行尾来识别消息边界。但您的发件人不会用行尾标记邮件边界。因此,接收者将永远等待。
如果您有一个协议规范,这将是显而易见的。在未来,我强烈敦促您投入时间来指定您实现的每一个协议。
您需要使用println()来添加新行,而不是print()。在Java中,readLine等待一个新行,我希望它在C#中也能这样做。println也会自动刷新,所以你也不需要刷新。
如果您打算多次使用此连接mreo,则需要保留该连接的BufferedReader和PrintWriter。(因此,我建议您在创建/接受套接字之后创建这些套接字)为同一个套接字多次创建这些套接字可能容易出错且令人困惑。