✨ 简化代码

lets-mica · Mar 30, 2024 · b90c952 · b90c952
1 parent 4318161
commit b90c952
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...er/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java b/...er/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java
@@ -168,7 +168,7 @@ public void processConnect(ChannelContext context, MqttConnectMessage mqttMessag
 			willMessage.setTimestamp(System.currentTimeMillis());
 			Node clientNode = context.getClientNode();
 			// 客户端 ip:端口
-			willMessage.setPeerHost(clientNode.getIp() + ':' + clientNode.getPort());
+			willMessage.setPeerHost(clientNode.getPeerHost());
 			willMessage.setNode(serverCreator.getNodeName());
 			messageStore.addWillMessage(uniqueId, willMessage);
 		}
@@ -204,7 +204,7 @@ private void sendConnected(ChannelContext context, String uniqueId) {
 		message.setNode(serverCreator.getNodeName());
 		message.setTimestamp(System.currentTimeMillis());
 		Node clientNode = context.getClientNode();
-		message.setPeerHost(clientNode.getIp() + ':' + clientNode.getPort());
+		message.setPeerHost(clientNode.getPeerHost());
 		messageDispatcher.send(message);
 	}
 
@@ -476,7 +476,7 @@ private void invokeListenerForPublish(ChannelContext context, String clientId, M
 				retainMessage.setTimestamp(System.currentTimeMillis());
 				Node clientNode = context.getClientNode();
 				// 客户端 ip:端口
-				retainMessage.setPeerHost(clientNode.getIp() + ':' + clientNode.getPort());
+				retainMessage.setPeerHost(clientNode.getPeerHost());
 				retainMessage.setNode(serverCreator.getNodeName());
 				this.messageStore.addRetainMessage(topicName, retainMessage);
 			}
@@ -500,7 +500,7 @@ private void invokeListenerForPublish(ChannelContext context, String clientId, M
 		message.setTimestamp(System.currentTimeMillis());
 		Node clientNode = context.getClientNode();
 		// 客户端 ip:端口
-		message.setPeerHost(clientNode.getIp() + ':' + clientNode.getPort());
+		message.setPeerHost(clientNode.getPeerHost());
 		message.setNode(serverCreator.getNodeName());
 		// 3. 消息发布
 		if (messageListener != null) {