Solace重复创建TcpClientChannel致连接被拒及复用方案咨询

核心思路 #

频繁新建TcpClientChannel会触发两类问题：一是本地系统临时端口耗尽，二是Solace端判定为异常请求触发限流/连接拒绝。解决核心是复用已建立的长连接，避免重复创建连接实例。

具体实现方案 #

1. 用单例模式维护全局连接实例

把Solace连接的初始化逻辑封装成单例类，确保整个应用生命周期内只创建一个TcpClientChannel实例，所有消息发布、队列重放操作复用该实例。同时加入连接状态检查，自动重连失效连接：

public class SolaceChannelHolder {
    private static volatile TcpClientChannel activeChannel;
    // Solace连接配置参数
    private static final String SOLACE_HOST = "your-solace-host";
    private static final int SOLACE_PORT = 55555;
    private static final String USERNAME = "your-username";
    private static final String PASSWORD = "your-password";

    private SolaceChannelHolder() {} // 私有构造防止外部实例化

    public static TcpClientChannel getActiveChannel() {
        if (activeChannel == null || !activeChannel.isConnected()) {
            synchronized (SolaceChannelHolder.class) {
                if (activeChannel == null || !activeChannel.isConnected()) {
                    // 初始化并建立连接
                    activeChannel = new TcpClientChannel();
                    activeChannel.setConnectRetries(3); // 设置重连次数
                    activeChannel.connect(SOLACE_HOST, SOLACE_PORT);
                    activeChannel.login(USERNAME, PASSWORD);
                }
            }
        }
        return activeChannel;
    }
}

使用时直接调用SolaceChannelHolder.getActiveChannel()获取连接，所有业务逻辑复用该实例即可。

2. 清理业务代码中的重复连接创建逻辑

排查遍历CSV、消息重放的循环代码，绝对不要在循环内创建连接。比如：

错误写法（导致频繁新建连接）：

// 遍历CSV记录时每次新建连接
for (CsvRecord record : csvFileRecords) {
    TcpClientChannel tempChannel = new TcpClientChannel();
    tempChannel.connect();
    tempChannel.publish(record.toMessage());
    tempChannel.disconnect();
}

正确写法（复用单一连接）：

// 提前获取连接，循环内复用
TcpClientChannel channel = SolaceChannelHolder.getActiveChannel();
for (CsvRecord record : csvFileRecords) {
    try {
        channel.publish(record.toMessage());
    } catch (SolaceException e) {
        // 捕获异常后检查连接状态，必要时重新获取连接
        if (!channel.isConnected()) {
            channel = SolaceChannelHolder.getActiveChannel();
            channel.publish(record.toMessage());
        }
    }
}
// 应用退出时再断开连接，不要频繁断开
// channel.disconnect();

3. 优化Solace客户端连接参数

通过配置客户端参数增强连接稳定性和复用性：

• 设置connectRetries和reconnectRetryWaitInMillis，让连接断开后自动重试重连，避免直接新建连接。
• 确认启用持久化连接（默认通常开启，不要显式设置短连接模式）。
• 调整发送缓冲区大小，减少因消息发送频繁导致的连接异常。

4. 配合Solace服务端配置调整

如果确认是Solace端触发了连接限制，联系管理员：

• 检查Solace Broker的max-client-connections配置，放宽并发连接数上限。
• 调整连接频率限流阈值，避免合法的批量操作被判定为恶意请求。
• 开启连接复用的服务端支持，允许客户端保持长连接。

内容的提问来源于stack exchange，提问作者pebble unit