Java Socket套接字如何实现服务发现

在Java中，使用Socket进行服务发现通常涉及以下几个步骤：

1. 服务端启动：服务端程序启动时，会创建一个ServerSocket并绑定到一个特定的端口上。这个端口就是服务端监听客户端连接的地址。

2. 客户端查询：客户端程序需要知道服务端的地址和端口，以便能够发起连接请求。这通常是通过配置文件、环境变量或者硬编码的方式获得的。

3. 客户端连接：客户端使用Socket类的构造函数或者connect方法来连接到服务端的地址和端口。

4. 数据交换：一旦连接建立，客户端和服务端就可以通过Socket对象进行数据交换。

下面是一个简单的Java 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("服务端启动，监听端口：" + port);

        try {
            while (true) {
                Socket clientSocket = serverSocket.accept(); // 接受客户端连接
                System.out.println("客户端已连接：" + clientSocket.getInetAddress());

                // 处理客户端请求...
                InputStream input = clientSocket.getInputStream();
                BufferedReader reader = new BufferedReader(new InputStreamReader(input));
                String request = reader.readLine();
                System.out.println("收到客户端请求：" + request);

                // 发送响应给客户端
                OutputStream output = clientSocket.getOutputStream();
                PrintWriter writer = new PrintWriter(output, true);
                writer.println("服务端已收到请求：" + request);

                clientSocket.close(); // 关闭连接
            }
        } finally {
            serverSocket.close(); // 关闭ServerSocket
        }
    }
}

客户端代码示例：

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

public class Client {
    public static void main(String[] args) throws IOException {
        String host = "localhost"; // 服务端地址
        int port = 12345; // 服务端端口

        try (Socket socket = new Socket(host, port)) {
            System.out.println("已连接到服务端：" + host + ":" + port);

            // 发送请求到服务端
            OutputStream output = socket.getOutputStream();
            PrintWriter writer = new PrintWriter(output, true);
            writer.println("Hello, Server!");

            // 接收服务端的响应
            InputStream input = socket.getInputStream();
            BufferedReader reader = new BufferedReader(new InputStreamReader(input));
            String response = reader.readLine();
            System.out.println("收到服务端响应：" + response);
        }
    }
}

在实际应用中，服务发现可能会更加复杂，特别是在动态环境中，服务实例可能会频繁地启动和关闭。在这种情况下，可能需要一个服务注册中心（如Consul、Eureka等）来跟踪服务实例的状态，并提供服务发现的功能。客户端可以通过查询服务注册中心来发现可用的服务实例，并动态地建立连接。