package com.iplatform.tcp.lb;
|
|
import com.walker.tcp.lb.LongConnectionMeta;
|
|
/**
|
* 平台实现的长连接元数据对象。
|
* <pre>
|
* 1) 该对象表示一个物理连接的映射，会缓存到Redis中。
|
* 2) 本机节点只能获取自己的链路连接，并通过连接直接发送消息。
|
* 3) 连接元数据作用是，在其他节点中通过Redis中记录的连接映射以MQ消息形式发送出去。
|
* </pre>
|
* @author 时克英
|
* @date 2023-09-26
|
*/
|
public class MqConnectionMeta extends LongConnectionMeta {
|
|
// private final transient SendStatusCallback callback = new SendStatusCallback();
|
|
public MqConnectionMeta(){}
|
|
public MqConnectionMeta(String id) {
|
super(id);
|
}
|
|
// @JsonIgnore
|
// @Override
|
// public void write(Response<?> response) {
|
// // 通过MQ发送消息到目标主机，该目标就是当前连接绑定的主机标识。
|
// // 暂时使用异步任务发送，2023-09-26
|
// // 这里发送的主题就是全局连接对应的主机信息：
|
//// BeanContextAware.getBeanByType(RocketMQEnhanceTemplate.class)
|
//// .sendAsync(response.getTopic(), this.acquireMqResponse(response), callback);
|
// logger.info("+++++++++++++++++++++++++");
|
// BeanContextAware.getBeanByType(RocketMQEnhanceTemplate.class)
|
// .sendAsync(this.getConnectionHost(), this.acquireMqResponse(response), callback);
|
// if(this.logger.isDebugEnabled()){
|
// logger.debug("MqConnectionMeta 发送一个消息：{}", response);
|
// }
|
// }
|
|
// @Override
|
// protected void onWrite(Response<?> response){
|
// logger.info("+++++++++++++++++++++++++");
|
// BeanContextAware.getBeanByType(RocketMQEnhanceTemplate.class)
|
// .sendAsync(this.getConnectionHost(), this.acquireMqResponse(response), callback);
|
// if(this.logger.isDebugEnabled()){
|
// logger.debug("MqConnectionMeta 发送一个消息：{}", response);
|
// }
|
// }
|
|
// private MqResponse acquireMqResponse(Response<?> response){
|
// MqResponse data = new MqResponse();
|
// data.setResponse(response);
|
// data.setKey(IdUtils.fastSimpleUUID());
|
// data.setRetryTimes(1);
|
// data.setSource(response.getProtocolNum());
|
// data.setSendTime(DateUtils.getDateTimeNumber());
|
// data.setTopic(response.getTopic());
|
// return data;
|
// }
|
|
@Override
|
public void disconnect() {
|
// nothing;
|
}
|
|
@Override
|
public boolean isConnected() {
|
return true;
|
}
|
|
@Override
|
public String toString(){
|
return new StringBuilder("MqConnectionMeta{id=").append(this.getId())
|
.append(", alreadyLogin=").append(this.getAlreadyLogin())
|
.append(", host=").append(this.getConnectionHost())
|
.append(", name=").append(this.getName())
|
.append(", lastTime=").append(this.getLastTime())
|
.append("}").toString();
|
}
|
}
|
