You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/10/23 03:42:16 UTC
[incubator-eventmesh] branch master updated: RedirectClientByIpPortHandler:stringBuildr-replace-operator
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 32f5216a RedirectClientByIpPortHandler:stringBuildr-replace-operator
new 3da1f9e0 Merge pull request #1760 from SunnyBoy-WYH/stringBuildr-replace-operator
32f5216a is described below
commit 32f5216ae701a50de309bba7e481bc3b84ba6dc3
Author: 1289220708 <12...@qq.com>
AuthorDate: Sun Oct 23 11:20:12 2022 +0800
RedirectClientByIpPortHandler:stringBuildr-replace-operator
---
.../admin/handler/RedirectClientByIpPortHandler.java | 15 +++++++++------
1 file changed, 9 insertions(+), 6 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByIpPortHandler.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByIpPortHandler.java
index df045581..bf397f7a 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByIpPortHandler.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByIpPortHandler.java
@@ -73,16 +73,17 @@ public class RedirectClientByIpPortHandler implements HttpHandler {
port, destEventMeshIp, destEventMeshPort);
ClientSessionGroupMapping clientSessionGroupMapping = eventMeshTCPServer.getClientSessionGroupMapping();
ConcurrentHashMap<InetSocketAddress, Session> sessionMap = clientSessionGroupMapping.getSessionMap();
- String redirectResult = "";
+ StringBuilder redirectResult = new StringBuilder();
try {
if (!sessionMap.isEmpty()) {
for (Session session : sessionMap.values()) {
if (session.getClient().getHost().equals(ip) && String.valueOf(
session.getClient().getPort()).equals(port)) {
- redirectResult += "|";
- redirectResult += EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
+ redirectResult.append("|");
+ redirectResult.append(
+ EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
destEventMeshIp, Integer.parseInt(destEventMeshPort),
- session, clientSessionGroupMapping);
+ session, clientSessionGroupMapping));
}
}
}
@@ -93,7 +94,8 @@ public class RedirectClientByIpPortHandler implements HttpHandler {
result = String.format("redirectClientByIpPort fail! sessionMap size {%d}, {clientIp=%s clientPort=%s "
+
"destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
- sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort, redirectResult, e
+ sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort,
+ redirectResult.toString(), e
.getMessage());
httpExchange.sendResponseHeaders(200, 0);
out.write(result.getBytes(Constants.DEFAULT_CHARSET));
@@ -102,7 +104,8 @@ public class RedirectClientByIpPortHandler implements HttpHandler {
result = String.format("redirectClientByIpPort success! sessionMap size {%d}, {ip=%s port=%s "
+
"destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
- sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort, redirectResult);
+ sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort,
+ redirectResult.toString());
httpExchange.sendResponseHeaders(200, 0);
out.write(result.getBytes(Constants.DEFAULT_CHARSET));
} catch (Exception e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org