package com.iplatform.base.config;
|
|
import com.iplatform.base.Constants;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
|
@ConfigurationProperties(prefix = "iplatform.tcp")
|
public class TcpProperties {
|
|
public boolean isEnabled() {
|
return enabled;
|
}
|
|
public void setEnabled(boolean enabled) {
|
this.enabled = enabled;
|
}
|
|
public boolean isShowLog() {
|
return showLog;
|
}
|
|
public void setShowLog(boolean showLog) {
|
this.showLog = showLog;
|
}
|
|
/**
|
* 返回请求消息队列管理器的实现类型，目前只有内存实现。
|
* @return
|
*/
|
public String getQueueType() {
|
return queueType;
|
}
|
|
public void setQueueType(String queueType) {
|
this.queueType = queueType;
|
}
|
|
public String getScanPackagesTcp() {
|
return scanPackagesTcp;
|
}
|
|
public void setScanPackagesTcp(String scanPackagesTcp) {
|
this.scanPackagesTcp = scanPackagesTcp;
|
}
|
|
public String getScanPackagesWs() {
|
return scanPackagesWs;
|
}
|
|
public void setScanPackagesWs(String scanPackagesWs) {
|
this.scanPackagesWs = scanPackagesWs;
|
}
|
|
public int getPortTcp() {
|
return portTcp;
|
}
|
|
public void setPortTcp(int portTcp) {
|
this.portTcp = portTcp;
|
}
|
|
public String getWebsocketUri() {
|
return websocketUri;
|
}
|
|
public void setWebsocketUri(String websocketUri) {
|
this.websocketUri = websocketUri;
|
}
|
|
public int getBossThreadNum() {
|
return bossThreadNum;
|
}
|
|
public void setBossThreadNum(int bossThreadNum) {
|
this.bossThreadNum = bossThreadNum;
|
}
|
|
public int getWorkerThreadNum() {
|
return workerThreadNum;
|
}
|
|
public void setWorkerThreadNum(int workerThreadNum) {
|
this.workerThreadNum = workerThreadNum;
|
}
|
|
public int getPortWs() {
|
return portWs;
|
}
|
|
public void setPortWs(int portWs) {
|
this.portWs = portWs;
|
}
|
|
public boolean isOpenHeartBeat() {
|
return openHeartBeat;
|
}
|
|
public void setOpenHeartBeat(boolean openHeartBeat) {
|
this.openHeartBeat = openHeartBeat;
|
}
|
|
/**
|
* 是否开启自定义：长连接管理器，如果开启则需要业务（创建）配置该对象。
|
* @return
|
* @date 2023-07-19
|
*/
|
public boolean isCustomConnectionManager() {
|
return customConnectionManager;
|
}
|
|
public void setCustomConnectionManager(boolean customConnectionManager) {
|
this.customConnectionManager = customConnectionManager;
|
}
|
|
/**
|
* 返回心跳设置的时间，默认：60秒
|
* @return
|
* @date 2023-08-28
|
*/
|
public long getHeartBeatSeconds() {
|
return heartBeatSeconds;
|
}
|
|
public void setHeartBeatSeconds(long heartBeatSeconds) {
|
this.heartBeatSeconds = heartBeatSeconds;
|
}
|
|
/**
|
* 是否支持集群模式，true表示支持，会使用负载连接管理器，并启用MQ消息队列。
|
* @return
|
* @date 2023-09-26
|
*/
|
public boolean isLoadBalanceEnabled() {
|
return loadBalanceEnabled;
|
}
|
|
public void setLoadBalanceEnabled(boolean loadBalanceEnabled) {
|
this.loadBalanceEnabled = loadBalanceEnabled;
|
}
|
|
public String getConnectionHost() {
|
return connectionHost;
|
}
|
|
public void setConnectionHost(String connectionHost) {
|
this.connectionHost = connectionHost;
|
}
|
|
private String connectionHost;
|
private boolean loadBalanceEnabled = false;
|
private long heartBeatSeconds = 60;
|
private boolean customConnectionManager = false;
|
private boolean openHeartBeat = false;
|
private int portWs = 60000;
|
private boolean enabled = false;
|
private boolean showLog = true;
|
private String queueType = Constants.QUEUE_TYPE_MEMORY;
|
private String scanPackagesTcp;
|
private String scanPackagesWs;
|
private int portTcp = 7878;
|
private String websocketUri = "ws://localhost:60000/websocket";
|
private int bossThreadNum = 2;
|
private int workerThreadNum = 4;
|
}
|
