在Java中发送和接收消息

Question

我目前正在使用Java处理TCP/IP套接字请求响应系统，我能够设置某些客户端/服务器接口，客户端可以在其中将消息发送到服务器，并且服务器打印了消息，以便控制台。我希望服务器还能够向客户端和Vis-Versa发送响应。我有可能实现这一目标吗？

这是客户端代码

     import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Main {
        public static void main(String[] args) throws IOException {
            String localhost = "127.0.0.1";
            int port = 8091;
            sendMessage(localhost, port);
        }
    
        public static void sendMessage(String server, int port) throws IOException {
            // Client
            Socket socket = new Socket(server, port);
            DataOutputStream output = new DataOutputStream(socket.getOutputStream());
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
    
            while(true){
                String input = bufferedReader.readLine();
                output.writeUTF(input);
                System.out.println("message sent " + input );
    //           receiveResponse(port);
                if(input.equalsIgnoreCase("exit"))
                    break;
    //            if(output.writeUTF(input)){}
            }
            socket.close();
    
        }
    
        public static void receiveResponse(int port) {
            try {
                ServerSocket serverSocket = new ServerSocket(port);
                Socket as = serverSocket.accept();
                DataInputStream in = new DataInputStream(as.getInputStream());
                String yoo = in.readUTF();
                System.out.println("Client: " + yoo);
                if(!yoo.isEmpty()){
                    System.out.println("message received");
                }
                if(yoo.equalsIgnoreCase("exit")){
                    System.out.println("Hello world");
                }
    
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }```


Below is the server code

    ``` 
    import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Server {
        public static void main(String[] args) throws IOException {
            int port = 8091;
          receiveMessage(port);
    
        }
    
        public static void receiveMessage(int port) throws IOException {
            ServerSocket serverSocket = new ServerSocket(port);
            Socket as = serverSocket.accept();
            System.out.println("Connected");
            System.out.println("incoming = " + as.getInputStream());
            DataInputStream in = new DataInputStream(as.getInputStream());
    
    
    
            System.out.println(in.readUTF());
            // ==========================
    
            while(true){
                String yoo = in.readUTF();
                System.out.println("Client: " + yoo);
                if(!yoo.isEmpty()){
    //                sendResult();
                    System.out.println("message received");
                }
                if(yoo.equalsIgnoreCase("exit"))
                    break;
            }
            as.close();
        }
    
        public static void sendResult( ) {
            try {
                System.out.println("HELLO WORLD");
                System.out.println("Connected to client");
    //            ObjectOutputStream os = new ObjectOutputStream(as.getOutputStream());
    //
    //            os.writeObject(result);
    //            System.out.println("Result sent");
    
                String str = "Hello World";
                OutputStreamWriter osw;
                Socket socket = null;
                socket = new Socket("localhost", 8090);
                osw =new OutputStreamWriter(socket.getOutputStream(), "UTF-8");
                osw.write(str, 0, str.length());
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }
    
    
     ```

Answer 1

所有事物是平等的（从您已经拥有的东西开始）您可以做这样的事情：

        public static void receiveResponse(Socket socket) {
            try {                
                DataInputStream in = new DataInputStream(socket.getInputStream());
                String yoo = in.readUTF();
                System.out.println("Client: " + yoo);
                if(!yoo.isEmpty()){
                    System.out.println("message received");
                }
                if(yoo.equalsIgnoreCase("exit")){
                    System.out.println("Hello world");
                }
    
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }

您需要查看一些事情：

• 用client client main 类>管理通信的类。这将允许您维护套接字，inseameam和of of tof -code作为实例变量。
• 也许查看使用更具体 /一致的传输协议方法（字节计数，定界符等）替换datainputStream < / code>。