117.info
人生若只如初见

如何实现Java Socket的双向通信

要实现Java Socket的双向通信,你需要创建一个服务器端和客户端,它们可以通过套接字(Socket)进行数据的发送和接收。以下是一个简单的示例,展示了如何实现双向通信。

首先,我们创建一个服务器端:

import java.io.*;
import java.net.*;

public class Server {
    public static void main(String[] args) throws IOException {
        int port = 12345;
        ServerSocket serverSocket = new ServerSocket(port);

        System.out.println("Server is running on port: " + port);

        Socket socket = serverSocket.accept();
        System.out.println("Client connected");

        InputStream input = socket.getInputStream();
        OutputStream output = socket.getOutputStream();

        BufferedReader reader = new BufferedReader(new InputStreamReader(input));
        PrintWriter writer = new PrintWriter(output, true);

        String line;
        while (true) {
            line = reader.readLine();
            if (line != null) {
                System.out.println("Received from client: " + line);
                writer.println("Server received: " + line);
            }
        }
    }
}

接下来,我们创建一个客户端:

import java.io.*;
import java.net.*;

public class Client {
    public static void main(String[] args) throws IOException {
        String host = "localhost";
        int port = 12345;

        Socket socket = new Socket(host, port);
        System.out.println("Connected to server");

        InputStream input = socket.getInputStream();
        OutputStream output = socket.getOutputStream();

        BufferedReader reader = new BufferedReader(new InputStreamReader(input));
        PrintWriter writer = new PrintWriter(output, true);

        BufferedReader userInput = new BufferedReader(new InputStreamReader(System.in));

        String line;
        while (true) {
            System.out.print("Enter message: ");
            line = userInput.readLine();
            writer.println(line);

            line = reader.readLine();
            if (line != null) {
                System.out.println("Server response: " + line);
            }
        }
    }
}

在这个示例中,服务器端和客户端都使用了Socket对象来创建连接。服务器端使用ServerSocket对象监听指定端口,等待客户端连接。当客户端连接后,服务器端和客户端可以通过InputStreamOutputStream进行数据的读取和写入,从而实现双向通信。

要运行此示例,请先运行服务器端,然后运行客户端。你将看到它们之间的双向通信。

未经允许不得转载 » 本文链接:https://www.117.info/ask/feeb7AzsBAQNXAQ.html

推荐文章

  • java中异常类会影响性能吗

    在Java中,异常类本身不会对性能产生显著影响。异常处理机制是为了在程序运行时处理错误或异常情况,而不是为了优化性能。然而,在使用异常时,需要注意以下几点...

  • java中异常类如何避免

    在Java中,避免异常的最好方法是编写健壮的代码并遵循一些最佳实践。以下是一些建议: 预期和处理异常:使用try-catch语句来捕获和处理可能发生的异常。确保处理...

  • java中异常类有哪些常见类型

    Java中的异常类主要分为两大类:受检异常(Checked Exceptions)和非受检异常(Unchecked Exceptions)。以下是具体的异常类型:
    受检异常(Checked Except...

  • java中异常类怎么捕获

    在Java中,我们使用try-catch语句来捕获异常。当程序执行过程中遇到异常时,Java运行时系统会抛出一个异常对象。你可以使用try块来包含可能引发异常的代码,然后...

  • Java Socket编程中如何处理异常

    在Java Socket编程中,处理异常是非常重要的,因为网络编程涉及到许多不确定性因素,例如连接失败、数据传输错误等。为了确保程序的稳定性和健壮性,我们需要适当...

  • InputStream的mark和reset方法有什么作用

    InputStream 类中的 mark() 和 reset() 方法是用于在输入流中记录和重置位置的。它们常常与 markSupported() 方法一起使用,以确定输入流是否支持这些操作。 mar...

  • 如何在InputStream中实现数据的压缩和解压

    在Java中,可以使用java.util.zip包中的类来实现对InputStream中数据的压缩和解压。以下是一个简单的示例,展示了如何使用GZIP格式进行压缩和解压缩。
    首先...

  • InputStream如何与BufferedReader结合使用

    在Java中,InputStream和BufferedReader可以结合使用,以提高读取文本文件或其他输入流的效率。BufferedReader是一个字符流,它将字符数据从底层的Reader对象中读...