2.7.18

shikeyin

2024-01-11 65da8373531677b1c37a98f53eaa30c892f35e5a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package com.iplatform.tcp.lb;
 
import com.walker.tcp.Connection;
import com.walker.tcp.lb.LoadBalanceConnectionManager;
import com.walker.tcp.lb.LongConnectionMeta;
 
/**
 * 支持集群的长连接管理器。
 * @author 时克英
 * @date 2023-09-26
 */
public class DefaultLbConnectionManager extends LoadBalanceConnectionManager {
 
//    private ResponseWriter responseWriter = new DefaultResponseWriter();
 
    @Override
    protected LongConnectionMeta acquireConnectionMeta(Connection connection) {
        MqConnectionMeta meta = new MqConnectionMeta(connection.getId());
        meta.setEngineId(connection.getEngineId());
        meta.setName(connection.getName());
        meta.setConnectionHost(connection.getConnectionHost());
        meta.setLastTime(connection.getLastTime());
        meta.setAlreadyLogin(connection.getAlreadyLogin());
        meta.setLongConnection(true);
//        meta.setProtocolResolver(connection.getProtocolResolver());
        meta.setResponseWriter(this.getResponseWriter());
        logger.debug("准备更新（保存或更新）一个链接：{}", meta);
        return meta;
    }
 
}