qiminbao
47 lines
1.6 KiB
Java
47 lines
1.6 KiB
Java
package com.tongran.agent.client.utils;
|
|
|
|
|
|
import com.tongran.agent.client.netty.config.ConnectionConfig;
|
|
|
|
import java.util.Arrays;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
public class ClientExample {
|
|
public static void main(String[] args) {
|
|
EnhancedConnectionManager manager = new EnhancedConnectionManager();
|
|
|
|
try {
|
|
// 配置多个连接
|
|
List<ConnectionConfig> configs = Arrays.asList(
|
|
// new ConnectionConfig("db_server", "192.168.1.101", 3306, 5),
|
|
// new ConnectionConfig("redis_server", "192.168.1.102", 6379, 3),
|
|
// new ConnectionConfig("api_server", "api.example.com", 8080, 10),
|
|
new ConnectionConfig("server1", "127.0.0.1", 6610, 5)
|
|
);
|
|
|
|
// 批量创建连接
|
|
Map<String, Boolean> results = manager.createConnections(configs);
|
|
System.out.println("连接创建结果: " + results);
|
|
|
|
// 等待连接建立
|
|
Thread.sleep(3000);
|
|
|
|
// 根据消息类型路由
|
|
manager.routeMessageByType("TYPE_A", "Database query");
|
|
// manager.routeMessageByType("TYPE_B", "Cache operation");
|
|
// manager.routeMessageByType("UNKNOWN", "Broadcast message");
|
|
|
|
// 检查连接状态
|
|
Map<String, Boolean> status = manager.getConnectionStatus();
|
|
System.out.println("连接状态: " + status);
|
|
|
|
Thread.sleep(5000);
|
|
|
|
} catch (InterruptedException e) {
|
|
Thread.currentThread().interrupt();
|
|
} finally {
|
|
// manager.shutdown();
|
|
}
|
|
}
|
|
} |