Java<->;C#套接字:无法接收消息

本文关键字:消息 套接字 lt- gt Java | 更新日期: 2023-09-27 18:29:09

我需要在我自己编写的java服务器和C#客户端之间进行套接字通信,问题是C#客户端无法从我的java服务器接收任何消息,但向我的java server发送消息是可行的。

我的工作流程:

  1. Java:创建服务器
  2. Java:正在等待客户端连接
  3. c#:创建客户端
  4. c#:建立与服务器的连接
  5. c#:向服务器发送消息
  6. Java:收到消息
  7. java:向c#客户端发送消息
  8. 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);吗?

我已经试过两边都等待了。我没有得到任何异常或错误,所以我真的不知道我的问题在哪里。

感谢

Java<->;C#套接字:无法接收消息

如果接收方期望,则发送方必须发送。你的发送者不发送线路,所以接收者会一直等待,直到收到一条线路。

为了避免将来出现此类问题,您应该始终制作一份规范文档,解释协议的工作方式,最好是在字节级别。它应该指定协议是否包含消息,如果包含,发送方如何标记消息边界,接收方如何识别它们。

在这里,您的接收者通过查找行尾来识别消息边界。但您的发件人不会用行尾标记邮件边界。因此,接收者将永远等待。

如果您有一个协议规范,这将是显而易见的。在未来,我强烈敦促您投入时间来指定您实现的每一个协议。

您需要使用println()来添加新行,而不是print()。在Java中,readLine等待一个新行,我希望它在C#中也能这样做。println也会自动刷新,所以你也不需要刷新。

如果您打算多次使用此连接mreo,则需要保留该连接的BufferedReader和PrintWriter。(因此,我建议您在创建/接受套接字之后创建这些套接字)为同一个套接字多次创建这些套接字可能容易出错且令人困惑。