提交 630aa184 编写于 作者: 浅梦2013's avatar 浅梦2013

服务端 ip,默认为空,可不设置

上级 0f47dc07
......@@ -61,9 +61,9 @@ public class MqttServerCreator {
*/
private String name = "Mica-Mqtt-Server";
/**
* 服务端 ip
* 服务端 ip,默认为空,可不设置
*/
private String ip = "127.0.0.1";
private String ip;
/**
* 端口
*/
......
......@@ -36,8 +36,8 @@ public class MqttServerTest {
public static void main(String[] args) {
// 注意:为了能接受更多链接(降低内存),请添加 jvm 参数 -Xss129k
MqttServer mqttServer = MqttServer.create()
// 默认:127.0.0.1
.ip("127.0.0.1")
// 服务端 ip 默认为空,0.0.0.0
.ip("0.0.0.0")
// 默认:1883
.port(1883)
// 默认为: 8092(mqtt 默认最大消息大小),为了降低内存可以减小小此参数,如果消息过大 t-io 会尝试解析多次(建议根据实际业务情况而定)
......
......@@ -18,7 +18,7 @@
<properties>
<java.version>1.8</java.version>
<mica.version>2.5.3</mica.version>
<mica.mqtt.version>1.0.2-RC</mica.mqtt.version>
<mica.mqtt.version>1.0.3-RC</mica.mqtt.version>
<spring.boot.version>2.5.3</spring.boot.version>
</properties>
......
......@@ -37,8 +37,8 @@ public class MqttServerTest {
public static void main(String[] args) {
// 注意:为了能接受更多链接(降低内存),请添加 jvm 参数 -Xss129k
MqttServer mqttServer = MqttServer.create()
// 默认:127.0.0.1
.ip("127.0.0.1")
// 服务端 ip 默认为空,0.0.0.0
.ip("0.0.0.0")
// 默认:1883
.port(3883)
// 默认为: 8092(mqtt 默认最大消息大小),为了降低内存可以减小小此参数,如果消息过大 t-io 会尝试解析多次(建议根据实际业务情况而定)
......
mqtt:
server:
enabled: true # 是否开启服务端,默认:true
ip: 127.0.0.1 # 服务端 ip 默认:127.0.0.1
# ip: 0.0.0.0 # 服务端 ip 默认为空,0.0.0.0
port: 5883 # 端口,默认:1883
name: Mica-Mqtt-Server # 名称,默认:Mica-Mqtt-Server
buffer-allocator: HEAP # 堆内存和堆外内存,默认:堆内存
......
mqtt:
server:
enabled: true # 是否开启服务端,默认:true
ip: 127.0.0.1 # 服务端 ip 默认:127.0.0.1
# ip: 0.0.0.0 # 服务端 ip 默认为空,0.0.0.0
port: 5883 # 端口,默认:1883
name: Mica-Mqtt-Server # 名称,默认:Mica-Mqtt-Server
buffer-allocator: HEAP # 堆内存和堆外内存,默认:堆内存
......
......@@ -49,11 +49,10 @@ public class MqttServerLauncher implements SmartLifecycle, Ordered {
public void start() {
// 1. 启动 mqtt tcp server
TioServer tioServer = mqttServer.getTioServer();
String ip = serverCreator.getIp();
try {
int port = serverCreator.getPort();
tioServer.start(ip, serverCreator.getPort());
log.info("Mica mqtt tcp start successful on {}:{}", ip, port);
tioServer.start(serverCreator.getIp(), serverCreator.getPort());
log.info("Mica mqtt tcp start successful on {}:{}", tioServer.getServerNode().getIp(), port);
running = true;
} catch (IOException e) {
throw new IllegalStateException("Mica mqtt server start fail.", e);
......@@ -75,7 +74,7 @@ public class MqttServerLauncher implements SmartLifecycle, Ordered {
wsTioConfig.share(tioConfig);
try {
websocketServer.start(tioServer.getServerNode().getIp(), wsServerConfig.getBindPort());
log.info("Mica mqtt websocket start successful on {}:{}", ip, websocketPort);
log.info("Mica mqtt websocket start successful on {}:{}", tioServer.getServerNode().getIp(), websocketPort);
} catch (IOException e) {
throw new IllegalStateException("Mica mqtt websocket server start fail.", e);
}
......
......@@ -47,7 +47,7 @@ public class MqttServerProperties {
/**
* 服务端 ip
*/
private String ip = "127.0.0.1";
private String ip;
/**
* 端口
*/
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册