package com.walker.tcp.connect;
|
|
import com.fasterxml.jackson.annotation.JsonIgnore;
|
import com.walker.infrastructure.utils.NumberGenerator;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.tcp.Connection;
|
import com.walker.tcp.ProtocolResolver;
|
import com.walker.tcp.Request;
|
import com.walker.tcp.Response;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
public class AbstractConnection implements Connection {
|
|
protected final transient Logger logger = LoggerFactory.getLogger(getClass());
|
|
private String id;
|
private String name;
|
private long createTimeMills = 0;
|
private boolean longConnection = true;
|
private boolean idle = false;
|
|
private boolean authenticated = false;
|
private int engineId = 0;
|
private long lastTime = 0;
|
|
private String connectionHost;
|
|
public AbstractConnection(String id){
|
this.id = id;
|
// this.name = name;
|
if(this.supportLongConnection()){
|
this.createTimeMills = NumberGenerator.getSequenceNumber();
|
}
|
}
|
|
public AbstractConnection(){}
|
|
@Override
|
public String getId() {
|
return id;
|
}
|
|
@Override
|
public String getName() {
|
return name;
|
}
|
|
@Override
|
public long getCreateTimeMills() {
|
return createTimeMills;
|
}
|
|
@Override
|
public boolean supportLongConnection() {
|
return longConnection;
|
}
|
|
@Override
|
public boolean isIdle() {
|
return idle;
|
}
|
|
@JsonIgnore
|
@Override
|
public Request<?> read() {
|
return null;
|
}
|
|
@JsonIgnore
|
@Override
|
public void write(Response<?> response) {
|
if(response == null){
|
logger.warn("响应对象为null，不能发送出去");
|
}
|
}
|
|
@JsonIgnore
|
@Override
|
public void disconnect() {
|
|
}
|
|
@Override
|
public String toString(){
|
return new StringBuilder().append("[ id=").append(id)
|
.append(", name=").append(name)
|
.append(", createTIme=").append(createTimeMills)
|
.append(", authenticated=").append(this.authenticated)
|
.append(", alreadyLogin=").append(this.alreadyLogin)
|
.append(", connectionHost=").append(this.connectionHost)
|
.append(", longConnection=").append(this.longConnection)
|
.append("]").toString();
|
}
|
|
@Override
|
public boolean equals(Object obj){
|
if(obj == null){
|
return false;
|
}
|
if(obj instanceof AbstractConnection){
|
AbstractConnection c = (AbstractConnection)obj;
|
if(c.getName() != null && c.getName().equals(this.name)){
|
return true;
|
}
|
if(c.getId().equals(this.id)){
|
return true;
|
}
|
}
|
return false;
|
}
|
|
@Override
|
public int hashCode(){
|
if(StringUtils.isNotEmpty(this.name)){
|
return 31 + this.name.hashCode() * 13;
|
}
|
return 31 + this.id.hashCode() * 13;
|
}
|
|
@Override
|
public void setName(String name) {
|
this.name = name;
|
}
|
|
@Override
|
public boolean isAuthenticated() {
|
return authenticated;
|
}
|
|
protected void setAuthenticated(boolean result){
|
this.authenticated = result;
|
}
|
|
public boolean getAuthenticated(){
|
return this.authenticated;
|
}
|
|
@Override
|
public int getEngineId() {
|
return engineId;
|
}
|
|
public void setEngineId(int id){
|
this.engineId = id;
|
}
|
|
@Override
|
public long getLastTime() {
|
return lastTime;
|
}
|
|
public void setLastTime(long mills){
|
this.lastTime = mills;
|
}
|
|
@JsonIgnore
|
@Override
|
public void bindName(String name) {
|
if(StringUtils.isNotEmpty(this.name)){
|
throw new IllegalStateException("连接已经绑定了名称，不能重复绑定");
|
}
|
this.name = name;
|
this.setAuthenticated(true);
|
// 是否已登录，json转换添加新字段，authenticated一直不生效。2023-09-27
|
this.setAlreadyLogin(1);
|
}
|
|
@Override
|
public boolean isConnected() {
|
return false;
|
}
|
|
@JsonIgnore
|
private ProtocolResolver protocolResolver;
|
|
@Override
|
public ProtocolResolver getProtocolResolver() {
|
return protocolResolver;
|
}
|
|
@Override
|
public void setProtocolResolver(ProtocolResolver protocolResolver) {
|
this.protocolResolver = protocolResolver;
|
}
|
|
@Override
|
public String getConnectionHost() {
|
return this.connectionHost;
|
}
|
@Override
|
public void setConnectionHost(String connectionHost) {
|
this.connectionHost = connectionHost;
|
}
|
|
// 为序列化生成的方法。
|
// 2023-09-27
|
public void setId(String id) {
|
this.id = id;
|
}
|
|
public void setCreateTimeMills(long createTimeMills) {
|
this.createTimeMills = createTimeMills;
|
}
|
|
public boolean getLongConnection() {
|
return longConnection;
|
}
|
|
public void setLongConnection(boolean longConnection) {
|
this.longConnection = longConnection;
|
}
|
|
public void setIdle(boolean idle) {
|
this.idle = idle;
|
}
|
|
@Override
|
public int getAlreadyLogin() {
|
return alreadyLogin;
|
}
|
|
public void setAlreadyLogin(int alreadyLogin) {
|
this.alreadyLogin = alreadyLogin;
|
}
|
|
private int alreadyLogin = 0;
|
}
|
