织梦网站字体大小,做网站费用多少,网站站群建设,营销推广活动策划方案大全Java实现 服务端起10个线程ID监听40-49这10个端口#xff0c;这10个端口注册到注册中心#xff0c;提供同一个服务#xff0c;发个A#xff0c;响应B#xff0c;客户端起10个线程去注册中心请求 好的#xff0c;我们可以通过实现一个简单的服务端、注册中心和客户端来达到…Java实现 服务端起10个线程ID监听40-49这10个端口这10个端口注册到注册中心提供同一个服务发个A响应B客户端起10个线程去注册中心请求 好的我们可以通过实现一个简单的服务端、注册中心和客户端来达到这个目的。以下是详细的代码示例
服务端代码
import java.io.*;
import java.net.*;
import java.util.concurrent.*;public class MultiPortServer {private static final int PORT_START 40;private static final int PORT_END 49;private static final ExecutorService executor Executors.newFixedThreadPool(PORT_END - PORT_START 1);public static void main(String[] args) {for (int port PORT_START; port PORT_END; port) {int finalPort port;executor.submit(() - startServer(finalPort));RegistryCenter.registerService(finalPort, localhost);}}private static void startServer(int port) {try (ServerSocket serverSocket new ServerSocket(port)) {System.out.println(Server listening on port port);while (true) {Socket clientSocket serverSocket.accept();handleClient(clientSocket);}} catch (IOException e) {e.printStackTrace();}}private static void handleClient(Socket clientSocket) {try (BufferedReader in new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));PrintWriter out new PrintWriter(clientSocket.getOutputStream(), true)) {String message in.readLine();if (A.equals(message)) {out.println(B);} else {out.println(Unknown message);}} catch (IOException e) {e.printStackTrace();}}
}注册中心代码
import java.util.*;
import java.util.concurrent.*;public class RegistryCenter {private static final MapInteger, String serviceRegistry new ConcurrentHashMap();public static void registerService(int port, String address) {serviceRegistry.put(port, address);System.out.println(Service registered on port port at address address);}public static String lookupService(int port) {return serviceRegistry.get(port);}public static ListInteger getAllServicePorts() {return new ArrayList(serviceRegistry.keySet());}
}客户端代码
import java.io.*;
import java.net.*;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Client {private static final int CLIENT_COUNT 10;private static final ExecutorService executor Executors.newFixedThreadPool(CLIENT_COUNT);public static void main(String[] args) {ListInteger servicePorts RegistryCenter.getAllServicePorts();for (int i 0; i CLIENT_COUNT; i) {executor.submit(() - {int portIndex (int) (Math.random() * servicePorts.size());int servicePort servicePorts.get(portIndex);queryService(servicePort);});}executor.shutdown();}private static void queryService(int servicePort) {String serviceAddress RegistryCenter.lookupService(servicePort);if (serviceAddress ! null) {try (Socket socket new Socket(serviceAddress, servicePort);PrintWriter out new PrintWriter(socket.getOutputStream(), true);BufferedReader in new BufferedReader(new InputStreamReader(socket.getInputStream()))) {out.println(A);String response in.readLine();System.out.println(Response from server on port servicePort : response);} catch (IOException e) {e.printStackTrace();}} else {System.out.println(No service found on port servicePort);}}
}运行步骤 启动服务端 运行 MultiPortServer 类。它将启动10个线程每个线程监听一个端口40-49并将这些服务注册到注册中心。 启动客户端 运行 Client 类。它将启动10个客户端线程每个线程随机选择一个服务端口从注册中心获取该端口的服务地址并发送消息 “A”。
说明 服务端 MultiPortServer 类创建一个线程池每个线程监听一个特定端口并将该端口的服务注册到 RegistryCenter。每个服务端口接收到消息 “A” 后响应消息 “B”。 注册中心 RegistryCenter 类负责管理服务的注册和查询。提供了 registerService 方法用于注册服务lookupService 方法用于查询服务地址getAllServicePorts 方法用于获取所有注册的服务端口。 客户端 Client 类创建一个线程池启动10个客户端线程每个线程随机选择一个服务端口向服务端发送消息 “A”并打印服务端的响应。
