Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

pub/sub client fails to start #220

Closed
ewcchan opened this issue Feb 17, 2021 · 12 comments
Closed

pub/sub client fails to start #220

ewcchan opened this issue Feb 17, 2021 · 12 comments
Labels
bug Something isn't working kind
Milestone
1.2.0-release

Comments

@ewcchan
Copy link

ewcchan commented Feb 17, 2021

Hi

I was trying to follow the steps in https://github.com/WeBankFinTech/EventMesh/blob/develop/docs/en/instructions/eventmesh-sdk-java-quickstart.md to try eventMesh

My DeFiBus starts fine without error, as shown in sysout.

\DeFiBus-master\build\DeFiBus_1.0.1\bin>runnamesrv.cmd
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=320m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
load config properties file OK, ../conf/broker.properties
The Name Server boot success. serializeType=JSON

and

\DeFiBus-master\build\DeFiBus_1.0.1\bin>runbroker.cmd
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=320m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The broker[a2005155983, 172.17.109.161:10911] boot success. serializeType=JSON and name server is localhost:9876

I started com\webank\eventmesh\runtime\boot\ProxyStartup.java in IntelliJ with VM config stated here and I do not see any issues from the sysout.

console output 
2021-02-17 16:28:45,085 INFO  [main] ConfigurationWraper(ConfigurationWraper.java:65) - loading config: .\eventmesh-runtime\conf\proxy.properties
2021-02-17 16:28:47,061 DEBUG [main] InternalLoggerFactory(InternalLoggerFactory.java:45) - Using SLF4J as the default logging framework
2021-02-17 16:28:47,064 DEBUG [main] PlatformDependent(PlatformDependent.java:1015) - Platform: Windows
2021-02-17 16:28:47,070 DEBUG [main] PlatformDependent0(PlatformDependent0.java:408) - -Dio.netty.noUnsafe: false
2021-02-17 16:28:47,071 DEBUG [main] PlatformDependent0(PlatformDependent0.java:876) - Java version: 8
2021-02-17 16:28:47,073 DEBUG [main] PlatformDependent0(PlatformDependent0.java:125) - sun.misc.Unsafe.theUnsafe: available
2021-02-17 16:28:47,074 DEBUG [main] PlatformDependent0(PlatformDependent0.java:149) - sun.misc.Unsafe.copyMemory: available
2021-02-17 16:28:47,076 DEBUG [main] PlatformDependent0(PlatformDependent0.java:187) - java.nio.Buffer.address: available
2021-02-17 16:28:47,077 DEBUG [main] PlatformDependent0(PlatformDependent0.java:252) - direct buffer constructor: available
2021-02-17 16:28:47,079 DEBUG [main] PlatformDependent0(PlatformDependent0.java:326) - java.nio.Bits.unaligned: available, true
2021-02-17 16:28:47,079 DEBUG [main] PlatformDependent0(PlatformDependent0.java:391) - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9
2021-02-17 16:28:47,079 DEBUG [main] PlatformDependent0(PlatformDependent0.java:398) - java.nio.DirectByteBuffer.<init>(long, int): available
2021-02-17 16:28:47,079 DEBUG [main] PlatformDependent(PlatformDependent.java:1058) - sun.misc.Unsafe: available
2021-02-17 16:28:47,081 DEBUG [main] PlatformDependent(PlatformDependent.java:1177) - -Dio.netty.tmpdir: C:\Users\E00415~1\AppData\Local\Temp (java.io.tmpdir)
2021-02-17 16:28:47,081 DEBUG [main] PlatformDependent(PlatformDependent.java:1256) - -Dio.netty.bitMode: 64 (sun.arch.data.model)
2021-02-17 16:28:47,084 DEBUG [main] PlatformDependent(PlatformDependent.java:177) - -Dio.netty.maxDirectMemory: 3780640768 bytes
2021-02-17 16:28:47,084 DEBUG [main] PlatformDependent(PlatformDependent.java:184) - -Dio.netty.uninitializedArrayAllocationThreshold: -1
2021-02-17 16:28:47,087 DEBUG [main] CleanerJava6(CleanerJava6.java:92) - java.nio.ByteBuffer.cleaner(): available
2021-02-17 16:28:47,088 DEBUG [main] PlatformDependent(PlatformDependent.java:204) - -Dio.netty.noPreferDirect: false
2021-02-17 16:28:47,174 INFO  [main] ProxyHTTPServer(ProxyHTTPServer.java:144) - ==================ProxyHTTPServer Initialing==================
2021-02-17 16:28:47,189 DEBUG [main] MultithreadEventLoopGroup(MultithreadEventLoopGroup.java:44) - -Dio.netty.eventLoopThreads: 24
2021-02-17 16:28:47,236 DEBUG [main] InternalThreadLocalMap(InternalThreadLocalMap.java:56) - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024
2021-02-17 16:28:47,236 DEBUG [main] InternalThreadLocalMap(InternalThreadLocalMap.java:59) - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096
2021-02-17 16:28:47,267 DEBUG [main] NioEventLoop(NioEventLoop.java:106) - -Dio.netty.noKeySetOptimization: false
2021-02-17 16:28:47,268 DEBUG [main] NioEventLoop(NioEventLoop.java:107) - -Dio.netty.selectorAutoRebuildThreshold: 512
2021-02-17 16:28:47,290 DEBUG [main] PlatformDependent(PlatformDependent.java:919) - org.jctools-core.MpscChunkedArrayQueue: available
2021-02-17 16:28:48,111 INFO  [main] HTTPMetricsServer(HTTPMetricsServer.java:58) - HTTPMetricsServer inited......
2021-02-17 16:28:48,229 INFO  [main] ConsumerManager(ConsumerManager.java:56) - consumerManager inited......
2021-02-17 16:28:48,231 INFO  [main] ProducerManager(ProducerManager.java:40) - producerManager inited......
2021-02-17 16:28:48,239 INFO  [main] HttpRetryer(HttpRetryer.java:98) - HttpRetryer inited......
2021-02-17 16:28:48,276 INFO  [main] ProxyHTTPServer(ProxyHTTPServer.java:163) - --------------------------ProxyHTTPServer inited
2021-02-17 16:28:48,286 INFO  [main] ProxyTCPServer(ProxyTCPServer.java:130) - ==================ProxyTCPServer Initialing==================
2021-02-17 16:28:48,328 INFO  [main] ClientSessionGroupMapping(ClientSessionGroupMapping.java:409) - ClientSessionGroupMapping inited......
2021-02-17 16:28:48,332 INFO  [main] ProxyTcpRetryer(ProxyTcpRetryer.java:105) - ProxyTcpRetryer inited......
2021-02-17 16:28:48,334 INFO  [main] ProxyTcpMonitor(ProxyTcpMonitor.java:79) - ProxyTcpMonitor inited......
2021-02-17 16:28:48,334 INFO  [main] ProxyTCPServer(ProxyTCPServer.java:148) - --------------------------ProxyTCPServer Inited
2021-02-17 16:28:48,334 INFO  [main] ProxyServer(ProxyServer.java:57) - eventstore : null
2021-02-17 16:28:48,336 INFO  [main] ProxyServer(ProxyServer.java:61) - server state:INITED
2021-02-17 16:28:48,342 INFO  [main] HTTPMetricsServer(HTTPMetricsServer.java:87) - HTTPMetricsServer started......
2021-02-17 16:28:48,342 INFO  [main] ConsumerManager(ConsumerManager.java:60) - consumerManager started......
2021-02-17 16:28:48,346 INFO  [main] ProducerManager(ProducerManager.java:44) - producerManager started......
2021-02-17 16:28:48,346 INFO  [main] HttpRetryer(HttpRetryer.java:113) - HttpRetryer started......
2021-02-17 16:28:48,346 INFO  [main] ProxyHTTPServer(ProxyHTTPServer.java:173) - --------------------------ProxyHTTPServer started
2021-02-17 16:28:48,347 INFO  [main] ClientSessionGroupMapping(ClientSessionGroupMapping.java:413) - ClientSessionGroupMapping started......
2021-02-17 16:28:48,348 INFO  [main] ProxyTcpRetryer(ProxyTcpRetryer.java:184) - ProxyTcpRetryer started......
2021-02-17 16:28:48,352 INFO  [main] ProxyTcpMonitor(ProxyTcpMonitor.java:146) - ProxyTcpMonitor started......
2021-02-17 16:28:48,376 INFO  [main] ClientManageController(ClientManageController.java:77) - ClientManageController start success, port:10106
2021-02-17 16:28:48,376 INFO  [main] ProxyTCPServer(ProxyTCPServer.java:163) - --------------------------ProxyTCPServer Started
2021-02-17 16:28:48,377 INFO  [main] ProxyServer(ProxyServer.java:70) - server state:RUNNING
2021-02-17 16:28:48,467 DEBUG [proxy-tcp-server] ResourceLeakDetector(ResourceLeakDetector.java:130) - -Dio.netty.leakDetection.level: simple
2021-02-17 16:28:48,468 DEBUG [proxy-tcp-server] ResourceLeakDetector(ResourceLeakDetector.java:131) - -Dio.netty.leakDetection.targetRecords: 4
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:156) - -Dio.netty.allocator.numHeapArenas: 24
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:157) - -Dio.netty.allocator.numDirectArenas: 24
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:159) - -Dio.netty.allocator.pageSize: 8192
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:164) - -Dio.netty.allocator.maxOrder: 11
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:168) - -Dio.netty.allocator.chunkSize: 16777216
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:169) - -Dio.netty.allocator.tinyCacheSize: 512
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:170) - -Dio.netty.allocator.smallCacheSize: 256
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:171) - -Dio.netty.allocator.normalCacheSize: 64
2021-02-17 16:28:48,472 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:172) - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
2021-02-17 16:28:48,473 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:173) - -Dio.netty.allocator.cacheTrimInterval: 8192
2021-02-17 16:28:48,473 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:174) - -Dio.netty.allocator.cacheTrimIntervalMillis: 0
2021-02-17 16:28:48,473 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:175) - -Dio.netty.allocator.useCacheForAllThreads: true
2021-02-17 16:28:48,473 DEBUG [proxy-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:176) - -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
2021-02-17 16:28:48,502 DEBUG [proxy-tcp-server] DefaultChannelId(DefaultChannelId.java:79) - -Dio.netty.processId: 14836 (auto-detected)
2021-02-17 16:28:48,508 DEBUG [proxy-tcp-server] NetUtil(NetUtil.java:139) - -Djava.net.preferIPv4Stack: false
2021-02-17 16:28:48,508 DEBUG [proxy-tcp-server] NetUtil(NetUtil.java:140) - -Djava.net.preferIPv6Addresses: false
2021-02-17 16:28:49,084 DEBUG [proxy-tcp-server] NetUtil(NetUtil.java:224) - Loopback interface: lo (Software Loopback Interface 1, 127.0.0.1)
2021-02-17 16:28:49,085 DEBUG [proxy-tcp-server] NetUtil(NetUtil.java:289) - Failed to get SOMAXCONN from sysctl and file \proc\sys\net\core\somaxconn. Default: 200
2021-02-17 16:28:49,343 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:108) - ===========================================SERVER METRICS==================================================
2021-02-17 16:28:49,344 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:110) - {"maxHTTPTPS":"0.0","avgHTTPTPS":"0.0","maxHTTPCOST":"0","avgHTTPCOST":"0.0","avgHTTPBodyDecodeCost":"0.0", "httpDiscard":"0"}
2021-02-17 16:28:49,345 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:119) - {"maxBatchSendMsgTPS":"0.0","avgBatchSendMsgTPS":"0.0", "sum":"0", "sumFail":"0", "sumFailRate":"0.00", "discard":"0"}
2021-02-17 16:28:49,345 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:129) - {"maxSendMsgTPS":"0.0","avgSendMsgTPS":"0.0", "sum":"0", "sumFail":"0", "sumFailRate":"0.00", "replyMsg":"0", "replyFail":"0"}
2021-02-17 16:28:49,345 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:140) - {"maxPushMsgTPS":"0.0","avgPushMsgTPS":"0.0", "sum":"0", "sumFail":"0", "sumFailRate":"0.0", "maxClientLatency":"0.0", "avgClientLatency":"0.0"}
2021-02-17 16:28:49,347 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:151) - {"batchMsgQ":"0","sendMsgQ":"0","pushMsgQ":"0","httpRetryQ":"0"}
2021-02-17 16:28:49,347 INFO  [proxy-metrics-2] httpMonitor(HTTPMetricsServer.java:157) - {"batchAvgSend2MQCost":"0.0", "avgSend2MQCost":"0.0", "avgReply2MQCost":"0.0"}
2021-02-17 16:28:49,390 INFO  [proxy-http-server] ProxyHTTPServer(AbrstractHTTPServer.java:137) - HTTPServer[port=10105] started......
2021-02-17 16:28:49,573 DEBUG [proxy-tcp-server] DefaultChannelId(DefaultChannelId.java:101) - -Dio.netty.machineId: 04:33:c2:ff:fe:ba:57:98 (auto-detected)
2021-02-17 16:28:49,618 DEBUG [proxy-http-server] ByteBufUtil(ByteBufUtil.java:86) - -Dio.netty.allocator.type: pooled
2021-02-17 16:28:49,619 DEBUG [proxy-http-server] ByteBufUtil(ByteBufUtil.java:95) - -Dio.netty.threadLocalDirectBufferSize: 0
2021-02-17 16:28:49,619 DEBUG [proxy-http-server] ByteBufUtil(ByteBufUtil.java:98) - -Dio.netty.maxThreadLocalCharBufferSize: 16384
2021-02-17 16:28:49,643 WARN  [proxy-tcp-server] ServerBootstrap(AbstractBootstrap.java:452) - Unknown channel option 'TCP_NODELAY' for channel '[id: 0x37c19158]'
2021-02-17 16:28:49,643 WARN  [proxy-tcp-server] ServerBootstrap(AbstractBootstrap.java:452) - Unknown channel option 'SO_KEEPALIVE' for channel '[id: 0x37c19158]'
2021-02-17 16:28:49,643 WARN  [proxy-tcp-server] ServerBootstrap(AbstractBootstrap.java:452) - Unknown channel option 'SO_TIMEOUT' for channel '[id: 0x37c19158]'
2021-02-17 16:28:49,643 WARN  [proxy-tcp-server] ServerBootstrap(AbstractBootstrap.java:452) - Unknown channel option 'SO_LINGER' for channel '[id: 0x37c19158]'
2021-02-17 16:28:49,648 INFO  [proxy-tcp-server] ProxyTCPServer(ProxyTCPServer.java:112) - ProxyTCPServer[port=10000] started.....
2021-02-17 16:28:58,346 INFO  [pool-2-thread-1] ConsumerManager(ConsumerManager.java:64) - clientInfo check start.....
2021-02-17 16:28:58,353 INFO  [proxy-tcp-scheduler-2] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:28:59,352 INFO  [proxy-tcp-scheduler-3] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:00,352 INFO  [proxy-tcp-scheduler-5] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:01,352 INFO  [proxy-tcp-scheduler-4] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:02,352 INFO  [proxy-tcp-scheduler-2] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:03,353 INFO  [proxy-tcp-scheduler-1] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:04,353 INFO  [proxy-tcp-scheduler-5] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:05,352 INFO  [proxy-tcp-scheduler-4] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:06,353 INFO  [proxy-tcp-scheduler-2] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:07,353 INFO  [proxy-tcp-scheduler-1] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:08,346 INFO  [pool-2-thread-1] ConsumerManager(ConsumerManager.java:64) - clientInfo check start.....
2021-02-17 16:29:08,353 INFO  [proxy-tcp-scheduler-3] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:09,354 INFO  [proxy-tcp-scheduler-4] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:10,352 INFO  [proxy-tcp-scheduler-2] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:11,352 INFO  [proxy-tcp-scheduler-1] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:12,353 INFO  [proxy-tcp-scheduler-3] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:13,353 INFO  [proxy-tcp-scheduler-5] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:14,353 INFO  [proxy-tcp-scheduler-4] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:15,353 INFO  [proxy-tcp-scheduler-1] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:16,352 INFO  [proxy-tcp-scheduler-3] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:17,353 INFO  [proxy-tcp-scheduler-5] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}
2021-02-17 16:29:18,347 INFO  [pool-2-thread-1] ConsumerManager(ConsumerManager.java:64) - clientInfo check start.....
2021-02-17 16:29:18,353 INFO  [proxy-tcp-scheduler-2] appMonitor(ProxyTcpMonitor.java:143) - {"protocol":"tcp","s":"retryQueueSize","t":"0"}

Starting the demo client java\com\webank\eventmesh\client\http\demo\sub\SpringBootDemoApplication.java in IntelliJ also as shown in working state.

console output 
2021-02-17 16:44:05,383 DEBUG [main] PlatformDependent(PlatformDependent.java:927) - Platform: Windows
2021-02-17 16:44:05,390 DEBUG [main] PlatformDependent0(PlatformDependent0.java:395) - -Dio.netty.noUnsafe: false
2021-02-17 16:44:05,390 DEBUG [main] PlatformDependent0(PlatformDependent0.java:851) - Java version: 8
2021-02-17 16:44:05,393 DEBUG [main] PlatformDependent0(PlatformDependent0.java:120) - sun.misc.Unsafe.theUnsafe: available
2021-02-17 16:44:05,395 DEBUG [main] PlatformDependent0(PlatformDependent0.java:144) - sun.misc.Unsafe.copyMemory: available
2021-02-17 16:44:05,396 DEBUG [main] PlatformDependent0(PlatformDependent0.java:182) - java.nio.Buffer.address: available
2021-02-17 16:44:05,398 DEBUG [main] PlatformDependent0(PlatformDependent0.java:243) - direct buffer constructor: available
2021-02-17 16:44:05,399 DEBUG [main] PlatformDependent0(PlatformDependent0.java:313) - java.nio.Bits.unaligned: available, true
2021-02-17 16:44:05,400 DEBUG [main] PlatformDependent0(PlatformDependent0.java:378) - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9
2021-02-17 16:44:05,400 DEBUG [main] PlatformDependent0(PlatformDependent0.java:385) - java.nio.DirectByteBuffer.<init>(long, int): available
2021-02-17 16:44:05,400 DEBUG [main] PlatformDependent(PlatformDependent.java:970) - sun.misc.Unsafe: available
2021-02-17 16:44:05,401 DEBUG [main] PlatformDependent(PlatformDependent.java:1089) - -Dio.netty.tmpdir: C:\Users\E00415~1\AppData\Local\Temp (java.io.tmpdir)
2021-02-17 16:44:05,402 DEBUG [main] PlatformDependent(PlatformDependent.java:1168) - -Dio.netty.bitMode: 64 (sun.arch.data.model)
2021-02-17 16:44:05,405 DEBUG [main] PlatformDependent(PlatformDependent.java:159) - -Dio.netty.maxDirectMemory: 3780640768 bytes
2021-02-17 16:44:05,405 DEBUG [main] PlatformDependent(PlatformDependent.java:166) - -Dio.netty.uninitializedArrayAllocationThreshold: -1
2021-02-17 16:44:05,408 DEBUG [main] CleanerJava6(CleanerJava6.java:92) - java.nio.ByteBuffer.cleaner(): available
2021-02-17 16:44:05,408 DEBUG [main] PlatformDependent(PlatformDependent.java:186) - -Dio.netty.noPreferDirect: false
2021-02-17 16:44:05,711 DEBUG [main] HttpUtil(HttpUtil.java:143) - POST http://127.0.0.1:10105 HTTP/1.1
2021-02-17 16:44:05,740 DEBUG [main] RequestAddCookies(RequestAddCookies.java:123) - CookieSpec selected: default
2021-02-17 16:44:05,769 DEBUG [main] RequestAuthCache(RequestAuthCache.java:77) - Auth cache not set in the context
2021-02-17 16:44:05,773 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:266) - Connection request: [route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]
2021-02-17 16:44:05,817 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:310) - Connection leased: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-17 16:44:05,823 DEBUG [main] MainClientExec(MainClientExec.java:234) - Opening connection {}->http://127.0.0.1:10105
2021-02-17 16:44:05,837 DEBUG [main] DefaultHttpClientConnectionOperator(DefaultHttpClientConnectionOperator.java:139) - Connecting to /127.0.0.1:10105
2021-02-17 16:44:05,845 DEBUG [main] DefaultHttpClientConnectionOperator(DefaultHttpClientConnectionOperator.java:146) - Connection established 127.0.0.1:64479<->127.0.0.1:10105
2021-02-17 16:44:05,846 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 9000
2021-02-17 16:44:05,846 DEBUG [main] MainClientExec(MainClientExec.java:255) - Executing request POST / HTTP/1.1
2021-02-17 16:44:05,847 DEBUG [main] MainClientExec(MainClientExec.java:260) - Target auth state: UNCHALLENGED
2021-02-17 16:44:05,849 DEBUG [main] MainClientExec(MainClientExec.java:266) - Proxy auth state: UNCHALLENGED
2021-02-17 16:44:05,857 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:133) - http-outgoing-0 >> POST / HTTP/1.1
2021-02-17 16:44:05,857 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Language: JAVA
2021-02-17 16:44:05,858 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Username: userName
2021-02-17 16:44:05,858 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Version: 1.0
2021-02-17 16:44:05,858 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Ip: 192.168.2.104
2021-02-17 16:44:05,858 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Region: 
2021-02-17 16:44:05,859 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Idc: FT
2021-02-17 16:44:05,859 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Pid: 0
2021-02-17 16:44:05,859 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Env: P
2021-02-17 16:44:05,859 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Sys: 1234
2021-02-17 16:44:05,860 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Code: 203
2021-02-17 16:44:05,860 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Dcn: FT0
2021-02-17 16:44:05,860 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Passwd: password
2021-02-17 16:44:05,861 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Length: 147
2021-02-17 16:44:05,861 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Type: application/x-www-form-urlencoded; charset=UTF-8
2021-02-17 16:44:05,861 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Host: 127.0.0.1:10105
2021-02-17 16:44:05,862 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Connection: Keep-Alive
2021-02-17 16:44:05,862 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)
2021-02-17 16:44:05,862 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Accept-Encoding: gzip,deflate
2021-02-17 16:44:05,863 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "POST / HTTP/1.1[\r][\n]"
2021-02-17 16:44:05,864 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Language: JAVA[\r][\n]"
2021-02-17 16:44:05,864 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Username: userName[\r][\n]"
2021-02-17 16:44:05,864 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Version: 1.0[\r][\n]"
2021-02-17 16:44:05,864 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Ip: 192.168.2.104[\r][\n]"
2021-02-17 16:44:05,865 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Region: [\r][\n]"
2021-02-17 16:44:05,865 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Idc: FT[\r][\n]"
2021-02-17 16:44:05,865 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Pid: 0[\r][\n]"
2021-02-17 16:44:05,866 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Env: P[\r][\n]"
2021-02-17 16:44:05,866 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Sys: 1234[\r][\n]"
2021-02-17 16:44:05,866 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Code: 203[\r][\n]"
2021-02-17 16:44:05,867 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Dcn: FT0[\r][\n]"
2021-02-17 16:44:05,867 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Passwd: password[\r][\n]"
2021-02-17 16:44:05,867 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Length: 147[\r][\n]"
2021-02-17 16:44:05,867 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Type: application/x-www-form-urlencoded; charset=UTF-8[\r][\n]"
2021-02-17 16:44:05,868 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Host: 127.0.0.1:10105[\r][\n]"
2021-02-17 16:44:05,868 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Connection: Keep-Alive[\r][\n]"
2021-02-17 16:44:05,868 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)[\r][\n]"
2021-02-17 16:44:05,868 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Accept-Encoding: gzip,deflate[\r][\n]"
2021-02-17 16:44:05,869 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "[\r][\n]"
2021-02-17 16:44:05,869 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 >> "clientType=SUB&heartbeatEntities=%5B%7B%22topic%22%3A%22FT0-e-80010000-01-1%22%2C%22url%22%3A%22http%3A%2F%2F127.0.0.1%3A8088%2Fsub%2Ftest%22%7D%5D"
2021-02-17 16:44:07,204 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "HTTP/1.1 200 OK[\r][\n]"
2021-02-17 16:44:07,205 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "content-type: text/plain; charset=UTF-8[\r][\n]"
2021-02-17 16:44:07,205 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "content-length: 56[\r][\n]"
2021-02-17 16:44:07,205 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "connection: keep-alive[\r][\n]"
2021-02-17 16:44:07,205 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "Code: 203[\r][\n]"
2021-02-17 16:44:07,205 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "[\r][\n]"
2021-02-17 16:44:07,206 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 << "{"resTime":1613598247153,"retCode":0,"retMsg":"success"}"
2021-02-17 16:44:07,213 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:122) - http-outgoing-0 << HTTP/1.1 200 OK
2021-02-17 16:44:07,213 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << content-type: text/plain; charset=UTF-8
2021-02-17 16:44:07,213 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << content-length: 56
2021-02-17 16:44:07,213 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << connection: keep-alive
2021-02-17 16:44:07,214 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << Code: 203
2021-02-17 16:44:07,224 DEBUG [main] MainClientExec(MainClientExec.java:285) - Connection can be kept alive indefinitely
2021-02-17 16:44:07,235 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:342) - Connection [id: 0][route: {}->http://127.0.0.1:10105] can be kept alive indefinitely
2021-02-17 16:44:07,235 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 0
2021-02-17 16:44:07,235 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:349) - Connection released: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 1; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-17 16:44:07,235 DEBUG [main] HttpUtil(HttpUtil.java:61) - ResponseHolder={"resTime":1613598247153,"retCode":0,"retMsg":"success"}
2021-02-17 16:44:07,236 DEBUG [main] HttpUtil(HttpUtil.java:143) - POST http://127.0.0.1:10105 HTTP/1.1
2021-02-17 16:44:07,237 DEBUG [main] RequestAddCookies(RequestAddCookies.java:123) - CookieSpec selected: default
2021-02-17 16:44:07,237 DEBUG [main] RequestAuthCache(RequestAuthCache.java:77) - Auth cache not set in the context
2021-02-17 16:44:07,238 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:266) - Connection request: [route: {}->http://127.0.0.1:10105][total kept alive: 1; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-17 16:44:07,238 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:310) - Connection leased: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-17 16:44:07,238 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 0
2021-02-17 16:44:07,238 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 9000
2021-02-17 16:44:07,239 DEBUG [main] MainClientExec(MainClientExec.java:255) - Executing request POST / HTTP/1.1
2021-02-17 16:44:07,239 DEBUG [main] MainClientExec(MainClientExec.java:260) - Target auth state: UNCHALLENGED
2021-02-17 16:44:07,239 DEBUG [main] MainClientExec(MainClientExec.java:266) - Proxy auth state: UNCHALLENGED
2021-02-17 16:44:07,240 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:133) - http-outgoing-0 >> POST / HTTP/1.1
2021-02-17 16:44:07,240 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Language: JAVA
2021-02-17 16:44:07,240 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Username: userName
2021-02-17 16:44:07,240 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Version: 1.0
2021-02-17 16:44:07,240 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Ip: 192.168.2.104
2021-02-17 16:44:07,241 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Region: 
2021-02-17 16:44:07,241 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Idc: FT
2021-02-17 16:44:07,241 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Pid: 0
2021-02-17 16:44:07,241 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Env: P
2021-02-17 16:44:07,241 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Sys: 1234
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Code: 206
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Dcn: FT0
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Passwd: password
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Length: 84
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Type: application/x-www-form-urlencoded; charset=UTF-8
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Host: 127.0.0.1:10105
2021-02-17 16:44:07,242 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Connection: Keep-Alive
2021-02-17 16:44:07,243 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)
2021-02-17 16:44:07,243 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Accept-Encoding: gzip,deflate
2021-02-17 16:44:07,243 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "POST / HTTP/1.1[\r][\n]"
2021-02-17 16:44:07,243 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Language: JAVA[\r][\n]"
2021-02-17 16:44:07,243 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Username: userName[\r][\n]"
2021-02-17 16:44:07,243 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Version: 1.0[\r][\n]"
2021-02-17 16:44:07,244 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Ip: 192.168.2.104[\r][\n]"
2021-02-17 16:44:07,244 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Region: [\r][\n]"
2021-02-17 16:44:07,244 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Idc: FT[\r][\n]"
2021-02-17 16:44:07,244 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Pid: 0[\r][\n]"
2021-02-17 16:44:07,244 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Env: P[\r][\n]"
2021-02-17 16:44:07,244 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Sys: 1234[\r][\n]"
2021-02-17 16:44:07,245 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Code: 206[\r][\n]"
2021-02-17 16:44:07,245 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Dcn: FT0[\r][\n]"
2021-02-17 16:44:07,245 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Passwd: password[\r][\n]"
2021-02-17 16:44:07,245 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Length: 84[\r][\n]"
2021-02-17 16:44:07,246 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Type: application/x-www-form-urlencoded; charset=UTF-8[\r][\n]"
2021-02-17 16:44:07,246 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Host: 127.0.0.1:10105[\r][\n]"
2021-02-17 16:44:07,246 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Connection: Keep-Alive[\r][\n]"
2021-02-17 16:44:07,246 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)[\r][\n]"
2021-02-17 16:44:07,247 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Accept-Encoding: gzip,deflate[\r][\n]"
2021-02-17 16:44:07,247 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "[\r][\n]"
2021-02-17 16:44:07,247 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 >> "topic=%5B%22FT0-e-80010000-01-1%22%5D&url=http%3A%2F%2F127.0.0.1%3A8088%2Fsub%2Ftest"
2021-02-17 16:44:07,248 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "HTTP/1.1 200 OK[\r][\n]"
2021-02-17 16:44:07,248 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "content-type: text/plain; charset=UTF-8[\r][\n]"
2021-02-17 16:44:07,248 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "content-length: 56[\r][\n]"
2021-02-17 16:44:07,249 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "connection: keep-alive[\r][\n]"
2021-02-17 16:44:07,249 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "Code: 203[\r][\n]"
2021-02-17 16:44:07,249 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 << "[\r][\n]"
2021-02-17 16:44:07,249 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 << "{"resTime":1613598247153,"retCode":0,"retMsg":"success"}"
2021-02-17 16:44:07,250 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:122) - http-outgoing-0 << HTTP/1.1 200 OK
2021-02-17 16:44:07,250 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << content-type: text/plain; charset=UTF-8
2021-02-17 16:44:07,250 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << content-length: 56
2021-02-17 16:44:07,250 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << connection: keep-alive
2021-02-17 16:44:07,251 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:125) - http-outgoing-0 << Code: 203
2021-02-17 16:44:07,251 DEBUG [main] MainClientExec(MainClientExec.java:285) - Connection can be kept alive indefinitely
2021-02-17 16:44:07,252 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:342) - Connection [id: 0][route: {}->http://127.0.0.1:10105] can be kept alive indefinitely
2021-02-17 16:44:07,252 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 0
2021-02-17 16:44:07,252 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:349) - Connection released: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 1; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-17 16:44:07,253 DEBUG [main] HttpUtil(HttpUtil.java:61) - ResponseHolder={"resTime":1613598247153,"retCode":0,"retMsg":"success"}
2021-02-17 16:44:07,273 DEBUG [main] LiteConsumer(LiteConsumer.java:143) - subscribe message by await, targetProxy:http://127.0.0.1:10105, cost:1608ms, subscribeParam:{"body":{"topic":"[\"FT0-e-80010000-01-1\"]","url":"http://127.0.0.1:8088/sub/test"},"headers":{"Language":"JAVA","Username":"userName","Version":"1.0","Ip":"192.168.2.104","Idc":"FT","Pid":"0","Env":"P","Sys":"1234","Code":"206","Dcn":"FT0","Passwd":"password"},"httpMethod":{},"logger":{"debugEnabled":true,"errorEnabled":true,"infoEnabled":true,"name":"com.webank.eventmesh.client.http.http.RequestParam","traceEnabled":false,"warnEnabled":true},"queryParams":"","timeout":9000}, rtn:{"resTime":1613598247153,"retCode":0,"retMsg":"success"}

However, when I tried to start the publisher java\com\webank\eventmesh\client\http\demo\AsyncPublishInstance.java in IntelliJ I am getting READ TIME OUT error as shown below.

console output 
4:47:18 PM: Executing task 'AsyncPublishInstance.main()'...

Starting Gradle Daemon...
Gradle Daemon started in 4 s 164 ms
> Task :eventmesh-common:compileJava UP-TO-DATE
> Task :eventmesh-common:processResources NO-SOURCE
> Task :eventmesh-common:classes UP-TO-DATE
> Task :eventmesh-common:jar UP-TO-DATE
> Task :eventmesh-sdk-java:compileJava UP-TO-DATE
> Task :eventmesh-sdk-java:processResources UP-TO-DATE
> Task :eventmesh-sdk-java:classes UP-TO-DATE
> Task :eventmesh-sdk-java:compileTestJava UP-TO-DATE
> Task :eventmesh-sdk-java:processTestResources UP-TO-DATE
> Task :eventmesh-sdk-java:testClasses UP-TO-DATE

> Task :eventmesh-sdk-java:AsyncPublishInstance.main()
2021-02-17 16:47:44,288 main DEBUG Apache Log4j Core 2.13.3 initializing configuration XmlConfiguration[location=C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml]
2021-02-17 16:47:44,314 main DEBUG Installed 1 script engine
2021-02-17 16:47:44,840 main DEBUG Oracle Nashorn version: 1.8.0_261, language: ECMAScript, threading: Not Thread Safe, compile: true, names: [nashorn, Nashorn, js, JS, JavaScript, javascript, ECMAScript, ecmascript], factory class: jdk.nashorn.api.scripting.NashornScriptEngineFactory
2021-02-17 16:47:44,841 main DEBUG PluginManager 'Core' found 123 plugins
2021-02-17 16:47:44,842 main DEBUG PluginManager 'Level' found 0 plugins
2021-02-17 16:47:44,853 main DEBUG PluginManager 'Lookup' found 17 plugins
2021-02-17 16:47:44,860 main DEBUG Building Plugin[name=layout, class=org.apache.logging.log4j.core.layout.PatternLayout].
2021-02-17 16:47:44,897 main DEBUG PluginManager 'TypeConverter' found 26 plugins
2021-02-17 16:47:44,943 main DEBUG PatternLayout$Builder(pattern="%d{yyyy-MM-dd HH:mm:ss,SSS} %-5p [%t] %c{1}(%F:%L) - %m%n", PatternSelector=null, Configuration(C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml), Replace=null, charset="null", alwaysWriteExceptions="null", disableAnsi="null", noConsoleNoAnsi="null", header="null", footer="null")
2021-02-17 16:47:44,944 main DEBUG PluginManager 'Converter' found 47 plugins
2021-02-17 16:47:44,996 main DEBUG Building Plugin[name=appender, class=org.apache.logging.log4j.core.appender.ConsoleAppender].
2021-02-17 16:47:45,021 main DEBUG ConsoleAppender$Builder(target="SYSTEM_OUT", follow="null", direct="null", bufferedIo="null", bufferSize="null", immediateFlush="null", ignoreExceptions="null", PatternLayout(%d{yyyy-MM-dd HH:mm:ss,SSS} %-5p [%t] %c{1}(%F:%L) - %m%n), name="console", Configuration(C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml), Filter=null, ={})
2021-02-17 16:47:45,030 main DEBUG Starting OutputStreamManager SYSTEM_OUT.false.false
2021-02-17 16:47:45,031 main DEBUG Building Plugin[name=appenders, class=org.apache.logging.log4j.core.config.AppendersPlugin].
2021-02-17 16:47:45,037 main DEBUG createAppenders(={console})
2021-02-17 16:47:45,039 main DEBUG Building Plugin[name=AppenderRef, class=org.apache.logging.log4j.core.config.AppenderRef].
2021-02-17 16:47:45,049 main DEBUG createAppenderRef(ref="console", level="null", Filter=null)
2021-02-17 16:47:45,049 main DEBUG Building Plugin[name=asyncRoot, class=org.apache.logging.log4j.core.async.AsyncLoggerConfig$RootLogger].
2021-02-17 16:47:45,054 main DEBUG createLogger(additivity="null", level="DEBUG", includeLocation="true", ={console}, ={}, Configuration(C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml), Filter=null)
2021-02-17 16:47:45,080 main DEBUG Building Plugin[name=AppenderRef, class=org.apache.logging.log4j.core.config.AppenderRef].
2021-02-17 16:47:45,082 main DEBUG createAppenderRef(ref="console", level="null", Filter=null)
2021-02-17 16:47:45,082 main DEBUG Building Plugin[name=asyncLogger, class=org.apache.logging.log4j.core.async.AsyncLoggerConfig].
2021-02-17 16:47:45,089 main DEBUG createLogger(additivity="false", level="DEBUG", name="com.webank.eventmesh.client", includeLocation="true", ={console}, ={}, Configuration(C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml), Filter=null)
2021-02-17 16:47:45,090 main DEBUG Building Plugin[name=loggers, class=org.apache.logging.log4j.core.config.LoggersPlugin].
2021-02-17 16:47:45,094 main DEBUG createLoggers(={root, com.webank.eventmesh.client})
2021-02-17 16:47:45,097 main DEBUG Configuration XmlConfiguration[location=C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml] initialized
2021-02-17 16:47:45,098 main DEBUG Starting configuration XmlConfiguration[location=C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml]
2021-02-17 16:47:45,101 main DEBUG Log4j2 ConfigurationScheduler starting 1 threads
2021-02-17 16:47:45,234 main DEBUG Starting AsyncLoggerConfig disruptor for this configuration with ringbufferSize=262144, waitStrategy=TimeoutBlockingWaitStrategy, exceptionHandler=org.apache.logging.log4j.core.async.AsyncLoggerConfigDefaultExceptionHandler@236e3f4e...
2021-02-17 16:47:45,235 main DEBUG Started configuration XmlConfiguration[location=C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml] OK.
2021-02-17 16:47:45,237 main DEBUG Shutting down OutputStreamManager SYSTEM_OUT.false.false-1
2021-02-17 16:47:45,238 main DEBUG OutputStream closed
2021-02-17 16:47:45,239 main DEBUG Shut down OutputStreamManager SYSTEM_OUT.false.false-1, all resources released: true
2021-02-17 16:47:45,239 main DEBUG Appender DefaultConsole-1 stopped with status true
2021-02-17 16:47:45,240 main DEBUG Stopped org.apache.logging.log4j.core.config.DefaultConfiguration@4ec6a292 OK
2021-02-17 16:47:45,336 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93
2021-02-17 16:47:45,345 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=StatusLogger
2021-02-17 16:47:45,350 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=ContextSelector
2021-02-17 16:47:45,355 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=Loggers,name=
2021-02-17 16:47:45,357 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=Loggers,name=,subtype=RingBuffer
2021-02-17 16:47:45,359 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=Loggers,name=com.webank.eventmesh.client
2021-02-17 16:47:45,360 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=Loggers,name=com.webank.eventmesh.client,subtype=RingBuffer
2021-02-17 16:47:45,365 main DEBUG Registering MBean org.apache.logging.log4j2:type=73d16e93,component=Appenders,name=console
2021-02-17 16:47:45,376 main DEBUG org.apache.logging.log4j.core.util.SystemClock does not support precise timestamps.
2021-02-17 16:47:45,379 main DEBUG Reconfiguration complete for context[name=73d16e93] at URI C:\dev\EventMesh-develop\eventmesh-sdk-java\build\resources\test\log4j2.xml (org.apache.logging.log4j.core.LoggerContext@27ff5d15) with optional ClassLoader: null
2021-02-17 16:47:45,380 main DEBUG Shutdown hook enabled. Registering a new one.
2021-02-17 16:47:45,382 main DEBUG LoggerContext[name=73d16e93, org.apache.logging.log4j.core.LoggerContext@27ff5d15] started OK.
2021-02-17 16:47:47,944 main DEBUG AsyncLogger.ThreadNameStrategy=UNCACHED (user specified null, default is UNCACHED)
2021-02-17 16:47:47,945 main DEBUG org.apache.logging.log4j.core.util.SystemClock does not support precise timestamps.
2021-02-17 16:47:47,916 INFO  [main] LiteProducer(LiteProducer.java:82) - LiteProducer starting
2021-02-17 16:47:47,963 INFO  [main] LiteProducer(LiteProducer.java:85) - LiteProducer started
2021-02-17 16:47:48,098 DEBUG [main] InternalLoggerFactory(InternalLoggerFactory.java:43) - Using SLF4J as the default logging framework
2021-02-17 16:47:48,101 DEBUG [main] PlatformDependent(PlatformDependent.java:927) - Platform: Windows
2021-02-17 16:47:48,115 DEBUG [main] PlatformDependent0(PlatformDependent0.java:395) - -Dio.netty.noUnsafe: false
2021-02-17 16:47:48,116 DEBUG [main] PlatformDependent0(PlatformDependent0.java:851) - Java version: 8
2021-02-17 16:47:48,122 DEBUG [main] PlatformDependent0(PlatformDependent0.java:120) - sun.misc.Unsafe.theUnsafe: available
2021-02-17 16:47:48,125 DEBUG [main] PlatformDependent0(PlatformDependent0.java:144) - sun.misc.Unsafe.copyMemory: available
2021-02-17 16:47:48,128 DEBUG [main] PlatformDependent0(PlatformDependent0.java:182) - java.nio.Buffer.address: available
2021-02-17 16:47:48,131 DEBUG [main] PlatformDependent0(PlatformDependent0.java:243) - direct buffer constructor: available
2021-02-17 16:47:48,135 DEBUG [main] PlatformDependent0(PlatformDependent0.java:313) - java.nio.Bits.unaligned: available, true
2021-02-17 16:47:48,136 DEBUG [main] PlatformDependent0(PlatformDependent0.java:378) - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9
2021-02-17 16:47:48,136 DEBUG [main] PlatformDependent0(PlatformDependent0.java:385) - java.nio.DirectByteBuffer.<init>(long, int): available
2021-02-17 16:47:48,136 DEBUG [main] PlatformDependent(PlatformDependent.java:970) - sun.misc.Unsafe: available
2021-02-17 16:47:48,139 DEBUG [main] PlatformDependent(PlatformDependent.java:1089) - -Dio.netty.tmpdir: C:\Users\E00415~1\AppData\Local\Temp (java.io.tmpdir)
2021-02-17 16:47:48,139 DEBUG [main] PlatformDependent(PlatformDependent.java:1168) - -Dio.netty.bitMode: 64 (sun.arch.data.model)
2021-02-17 16:47:48,145 DEBUG [main] PlatformDependent(PlatformDependent.java:159) - -Dio.netty.maxDirectMemory: 3780640768 bytes
2021-02-17 16:47:48,146 DEBUG [main] PlatformDependent(PlatformDependent.java:166) - -Dio.netty.uninitializedArrayAllocationThreshold: -1
2021-02-17 16:47:48,151 DEBUG [main] CleanerJava6(CleanerJava6.java:92) - java.nio.ByteBuffer.cleaner(): available
2021-02-17 16:47:48,151 DEBUG [main] PlatformDependent(PlatformDependent.java:186) - -Dio.netty.noPreferDirect: false
2021-02-17 16:47:48,279 DEBUG [main] HttpUtil(HttpUtil.java:143) - POST http://127.0.0.1:10105 HTTP/1.1
2021-02-17 16:47:48,326 DEBUG [main] RequestAddCookies(RequestAddCookies.java:123) - CookieSpec selected: default
2021-02-17 16:47:48,371 DEBUG [main] RequestAuthCache(RequestAuthCache.java:77) - Auth cache not set in the context
2021-02-17 16:47:48,378 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:266) - Connection request: [route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]
2021-02-17 16:47:48,728 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:310) - Connection leased: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-17 16:47:48,734 DEBUG [main] MainClientExec(MainClientExec.java:234) - Opening connection {}->http://127.0.0.1:10105
2021-02-17 16:47:48,747 DEBUG [main] DefaultHttpClientConnectionOperator(DefaultHttpClientConnectionOperator.java:139) - Connecting to /127.0.0.1:10105
2021-02-17 16:47:48,754 DEBUG [main] DefaultHttpClientConnectionOperator(DefaultHttpClientConnectionOperator.java:146) - Connection established 127.0.0.1:64524<->127.0.0.1:10105
2021-02-17 16:47:48,754 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 9000
2021-02-17 16:47:48,755 DEBUG [main] MainClientExec(MainClientExec.java:255) - Executing request POST / HTTP/1.1
2021-02-17 16:47:48,755 DEBUG [main] MainClientExec(MainClientExec.java:260) - Target auth state: UNCHALLENGED
2021-02-17 16:47:48,758 DEBUG [main] MainClientExec(MainClientExec.java:266) - Proxy auth state: UNCHALLENGED
2021-02-17 16:47:48,764 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:133) - http-outgoing-0 >> POST / HTTP/1.1
2021-02-17 16:47:48,764 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Language: JAVA
2021-02-17 16:47:48,764 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Username: userName
2021-02-17 16:47:48,765 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Version: 1.0
2021-02-17 16:47:48,765 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Ip: 192.168.2.104
2021-02-17 16:47:48,765 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Region: 
2021-02-17 16:47:48,765 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Idc: idc
2021-02-17 16:47:48,765 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Pid: 0
2021-02-17 16:47:48,765 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Env: env
2021-02-17 16:47:48,766 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Sys: 1234
2021-02-17 16:47:48,766 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Code: 104
2021-02-17 16:47:48,766 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Dcn: dcn
2021-02-17 16:47:48,766 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Passwd: password
2021-02-17 16:47:48,767 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Length: 145
2021-02-17 16:47:48,767 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Type: application/x-www-form-urlencoded; charset=UTF-8
2021-02-17 16:47:48,767 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Host: 127.0.0.1:10105
2021-02-17 16:47:48,767 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Connection: Keep-Alive
2021-02-17 16:47:48,768 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)
2021-02-17 16:47:48,768 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Accept-Encoding: gzip,deflate
2021-02-17 16:47:48,769 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "POST / HTTP/1.1[\r][\n]"
2021-02-17 16:47:48,769 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Language: JAVA[\r][\n]"
2021-02-17 16:47:48,769 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Username: userName[\r][\n]"
2021-02-17 16:47:48,769 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Version: 1.0[\r][\n]"
2021-02-17 16:47:48,769 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Ip: 192.168.2.104[\r][\n]"
2021-02-17 16:47:48,770 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Region: [\r][\n]"
2021-02-17 16:47:48,770 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Idc: idc[\r][\n]"
2021-02-17 16:47:48,770 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Pid: 0[\r][\n]"
2021-02-17 16:47:48,771 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Env: env[\r][\n]"
2021-02-17 16:47:48,771 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Sys: 1234[\r][\n]"
2021-02-17 16:47:48,771 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Code: 104[\r][\n]"
2021-02-17 16:47:48,771 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Dcn: dcn[\r][\n]"
2021-02-17 16:47:48,772 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Passwd: password[\r][\n]"
2021-02-17 16:47:48,772 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Length: 145[\r][\n]"
2021-02-17 16:47:48,772 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Type: application/x-www-form-urlencoded; charset=UTF-8[\r][\n]"
2021-02-17 16:47:48,773 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Host: 127.0.0.1:10105[\r][\n]"
2021-02-17 16:47:48,773 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Connection: Keep-Alive[\r][\n]"
2021-02-17 16:47:48,773 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)[\r][\n]"
2021-02-17 16:47:48,774 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Accept-Encoding: gzip,deflate[\r][\n]"
2021-02-17 16:47:48,774 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "[\r][\n]"
2021-02-17 16:47:48,775 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 >> "topic=FT0-e-80010000-01-1&bizSeqNo=529369684165576580443920631474&ttl=14400000&content=testPublishMessage&uniqueId=328319318170693267055168747132"
2021-02-17 16:47:57,780 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 << "[read] I/O error: Read timed out"
2021-02-17 16:47:57,780 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:79) - http-outgoing-0: Close connection
2021-02-17 16:47:57,781 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:96) - http-outgoing-0: Shutdown connection
2021-02-17 16:47:57,781 DEBUG [main] MainClientExec(ConnectionHolder.java:129) - Connection discarded
2021-02-17 16:47:57,782 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:349) - Connection released: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]
2021-02-17 16:47:57,782 WARN  [main] AsyncPublishInstance(AsyncPublishInstance.java:54) - publish msg failed
com.webank.eventmesh.common.ProxyException: java.net.SocketTimeoutException: Read timed out
	at com.webank.eventmesh.client.http.producer.LiteProducer.publish(LiteProducer.java:138) ~[main/:?]
	at com.webank.eventmesh.client.http.demo.AsyncPublishInstance.main(AsyncPublishInstance.java:50) ~[test/:?]
Caused by: java.net.SocketTimeoutException: Read timed out
	at java.net.SocketInputStream.socketRead0(Native Method) ~[?:1.8.0_261]
	at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) ~[?:1.8.0_261]
	at java.net.SocketInputStream.read(SocketInputStream.java:171) ~[?:1.8.0_261]
	at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[?:1.8.0_261]
	at org.apache.http.impl.conn.LoggingInputStream.read(LoggingInputStream.java:84) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:72) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:221) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:165) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:140) ~[httpclient-4.5.9.jar:4.5.9]
	at com.webank.eventmesh.client.http.http.HttpUtil.post(HttpUtil.java:146) ~[main/:?]
	at com.webank.eventmesh.client.http.http.HttpUtil.post(HttpUtil.java:55) ~[main/:?]
	at com.webank.eventmesh.client.http.producer.LiteProducer.publish(LiteProducer.java:136) ~[main/:?]
	... 1 more
2021-02-17 16:48:27,782 INFO  [main] LiteProducer(LiteProducer.java:93) - LiteProducer shutting down
2021-02-17 16:48:27,782 INFO  [main] AbstractLiteClient(AbstractLiteClient.java:81) - AbstractLiteClient shutdown
2021-02-17 16:48:27,783 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:409) - Connection manager is shutting down
2021-02-17 16:48:27,783 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:415) - Connection manager shut down
2021-02-17 16:48:27,783 INFO  [main] LiteProducer(LiteProducer.java:97) - LiteProducer shutdown

Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.6/userguide/command_line_interface.html#sec:command_line_warnings

BUILD SUCCESSFUL in 1m 9s
7 actionable tasks: 1 executed, 6 up-to-date
4:48:28 PM: Task execution finished 'AsyncPublishInstance.main()'.

What is missing and what is the expected behaviour?

Additional Info

EventMesh-develop>java -version
java version "1.8.0_261"
Java(TM) SE Runtime Environment (build 1.8.0_261-b12)
Java HotSpot(TM) 64-Bit Server VM (build 25.261-b12, mixed mode)
@ewcchan ewcchan changed the title Clent pub/sub client fails to start Feb 17, 2021
@xwm1992
Copy link
Contributor

xwm1992 commented Feb 18, 2021

When you run AsyncPublishInstance Class main method with read time out exception, what was happened in eventmesh runtime module, you can take a look of this module's log . Perhaps you didn't build this topic FT0-e-80010000-01-1 yet.

@ewcchan
Copy link
Author

ewcchan commented Feb 18, 2021

I updated the dist\conf\broker.properties in DeFiBus with a clustername and restart the nameserver and broker with a successful topic creation; however EventMesh still failed with same error

broker.properties

namesrvAddr=
brokerClusterName=DefaultCluster
brokerName=
brokerId=0
brokerRole=ASYNC_MASTER
autoCreateTopicEnable=false
useReentrantLockWhenPutMessage=true
storePathRootDir=/dev/shm/store
storePathCommitLog=/dev/shm/store/commitlog

Create topic

\DeFiBus-master\dist\bin>runadmin.cmd updateTopic -c DefaultCluster -t FT0-e-80010000-01-1 -n localhost:9876
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
create topic to 172.17.59.225:10911 success.
TopicConfig [topicName=FT0-e-80010000-01-1, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

Errors

2021-02-18 17:43:27,537 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Accept-Encoding: gzip,deflate
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "POST / HTTP/1.1[\r][\n]"
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Language: JAVA[\r][\n]"
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Username: userName[\r][\n]"
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Version: 1.0[\r][\n]"
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Ip: 10.48.245.89[\r][\n]"
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Region: [\r][\n]"
2021-02-18 17:43:27,537 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Idc: idc[\r][\n]"
2021-02-18 17:43:27,538 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Pid: 0[\r][\n]"
2021-02-18 17:43:27,538 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Env: env[\r][\n]"
2021-02-18 17:43:27,538 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Sys: 1234[\r][\n]"
2021-02-18 17:43:27,538 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Code: 104[\r][\n]"
2021-02-18 17:43:27,538 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Dcn: dcn[\r][\n]"
2021-02-18 17:43:27,539 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Passwd: password[\r][\n]"
2021-02-18 17:43:27,539 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Length: 145[\r][\n]"
2021-02-18 17:43:27,539 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Type: application/x-www-form-urlencoded; charset=UTF-8[\r][\n]"
2021-02-18 17:43:27,539 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Host: 127.0.0.1:10105[\r][\n]"
2021-02-18 17:43:27,541 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Connection: Keep-Alive[\r][\n]"
2021-02-18 17:43:27,541 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)[\r][\n]"
2021-02-18 17:43:27,541 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Accept-Encoding: gzip,deflate[\r][\n]"
2021-02-18 17:43:27,541 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "[\r][\n]"
2021-02-18 17:43:27,541 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 >> "topic=FT0-e-80010000-01-1&bizSeqNo=683398651360434916072421377032&ttl=14400000&content=testPublishMessage&uniqueId=257543694747619263701720984103"
2021-02-18 17:43:36,547 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 << "[read] I/O error: Read timed out"
2021-02-18 17:43:36,547 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:79) - http-outgoing-0: Close connection
2021-02-18 17:43:36,548 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:96) - http-outgoing-0: Shutdown connection
2021-02-18 17:43:36,548 DEBUG [main] MainClientExec(ConnectionHolder.java:129) - Connection discarded
2021-02-18 17:43:36,548 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:349) - Connection released: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]
2021-02-18 17:43:36,548 WARN  [main] AsyncPublishInstance(AsyncPublishInstance.java:54) - publish msg failed
com.webank.eventmesh.common.ProxyException: java.net.SocketTimeoutException: Read timed out
	at com.webank.eventmesh.client.http.producer.LiteProducer.publish(LiteProducer.java:138) ~[main/:?]
	at com.webank.eventmesh.client.http.demo.AsyncPublishInstance.main(AsyncPublishInstance.java:50) ~[test/:?]
Caused by: java.net.SocketTimeoutException: Read timed out
	at java.net.SocketInputStream.socketRead0(Native Method) ~[?:1.8.0_261]
	at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) ~[?:1.8.0_261]
	at java.net.SocketInputStream.read(SocketInputStream.java:171) ~[?:1.8.0_261]
	at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[?:1.8.0_261]
	at org.apache.http.impl.conn.LoggingInputStream.read(LoggingInputStream.java:84) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:72) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:221) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:165) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:140) ~[httpclient-4.5.9.jar:4.5.9]
	at com.webank.eventmesh.client.http.http.HttpUtil.post(HttpUtil.java:146) ~[main/:?]
	at com.webank.eventmesh.client.http.http.HttpUtil.post(HttpUtil.java:55) ~[main/:?]
	at com.webank.eventmesh.client.http.producer.LiteProducer.publish(LiteProducer.java:136) ~[main/:?]
	... 1 more
2021-02-18 17:44:06,548 INFO  [main] LiteProducer(LiteProducer.java:93) - LiteProducer shutting down
2021-02-18 17:44:06,548 INFO  [main] AbstractLiteClient(AbstractLiteClient.java:81) - AbstractLiteClient shutdown
2021-02-18 17:44:06,548 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:409) - Connection manager is shutting down
2021-02-18 17:44:06,548 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:415) - Connection manager shut down
2021-02-18 17:44:06,548 INFO  [main] LiteProducer(LiteProducer.java:97) - LiteProducer shutdown

Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.6/userguide/command_line_interface.html#sec:command_line_warnings

BUILD SUCCESSFUL in 1m 7s
7 actionable tasks: 1 executed, 6 up-to-date
5:44:06 PM: Task execution finished 'AsyncPublishInstance.main()'.

@xwm1992
Copy link
Contributor

xwm1992 commented Feb 19, 2021

broker.properties

The namesrvAddr= here in this file can't be null, must be your namesrv ip:port e.g. 127.0.0.1:9876

@ewcchan
Copy link
Author

ewcchan commented Feb 19, 2021 •
edited
Loading

I tried both localhost and 127.0.0.1:9876 as suggested in https://github.com/WeBankFinTech/DeFiBus/blob/master/defibus-broker/src/main/java/com/webank/defibus/broker/DeFiBusBrokerStartup.java#L146-L149, neither of them works and the async publisher startup still failed with connection time out.

namesrvAddr=127.0.0.1:9876
brokerClusterName=DefaultCluster
brokerName=
brokerId=0
brokerRole=ASYNC_MASTER
autoCreateTopicEnable=false
useReentrantLockWhenPutMessage=true
storePathRootDir=/dev/shm/store
storePathCommitLog=/dev/shm/store/commitlog

and runadmin command confirmed topic creation

DeFiBus-master\dist\bin>runadmin.cmd updateTopic -c DefaultCluster -t FT0-e-80010000-01-1 -n localhost:9876
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
create topic to 172.17.1.33:10911 success.
TopicConfig [topicName=FT0-e-80010000-01-1, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

Failing when topic publish with a connect read timeout

2021-02-19 16:14:19,167 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:266) - Connection request: [route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]
2021-02-19 16:14:19,399 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:310) - Connection leased: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 1 of 2; total allocated: 1 of 20]
2021-02-19 16:14:19,404 DEBUG [main] MainClientExec(MainClientExec.java:234) - Opening connection {}->http://127.0.0.1:10105
2021-02-19 16:14:19,414 DEBUG [main] DefaultHttpClientConnectionOperator(DefaultHttpClientConnectionOperator.java:139) - Connecting to /127.0.0.1:10105
2021-02-19 16:14:19,419 DEBUG [main] DefaultHttpClientConnectionOperator(DefaultHttpClientConnectionOperator.java:146) - Connection established 127.0.0.1:52290<->127.0.0.1:10105
2021-02-19 16:14:19,420 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:88) - http-outgoing-0: set socket timeout to 9000
2021-02-19 16:14:19,420 DEBUG [main] MainClientExec(MainClientExec.java:255) - Executing request POST / HTTP/1.1
2021-02-19 16:14:19,420 DEBUG [main] MainClientExec(MainClientExec.java:260) - Target auth state: UNCHALLENGED
2021-02-19 16:14:19,422 DEBUG [main] MainClientExec(MainClientExec.java:266) - Proxy auth state: UNCHALLENGED
2021-02-19 16:14:19,427 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:133) - http-outgoing-0 >> POST / HTTP/1.1
2021-02-19 16:14:19,427 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Language: JAVA
2021-02-19 16:14:19,427 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Username: userName
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Version: 1.0
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Ip: 10.48.240.116
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Region: 
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Idc: idc
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Pid: 0
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Env: env
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Sys: 1234
2021-02-19 16:14:19,428 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Code: 104
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Dcn: dcn
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Passwd: password
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Length: 145
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Content-Type: application/x-www-form-urlencoded; charset=UTF-8
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Host: 127.0.0.1:10105
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Connection: Keep-Alive
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)
2021-02-19 16:14:19,429 DEBUG [main] headers(LoggingManagedHttpClientConnection.java:136) - http-outgoing-0 >> Accept-Encoding: gzip,deflate
2021-02-19 16:14:19,430 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "POST / HTTP/1.1[\r][\n]"
2021-02-19 16:14:19,430 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Language: JAVA[\r][\n]"
2021-02-19 16:14:19,430 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Username: userName[\r][\n]"
2021-02-19 16:14:19,430 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Version: 1.0[\r][\n]"
2021-02-19 16:14:19,431 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Ip: 10.48.240.116[\r][\n]"
2021-02-19 16:14:19,431 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Region: [\r][\n]"
2021-02-19 16:14:19,431 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Idc: idc[\r][\n]"
2021-02-19 16:14:19,431 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Pid: 0[\r][\n]"
2021-02-19 16:14:19,431 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Env: env[\r][\n]"
2021-02-19 16:14:19,432 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Sys: 1234[\r][\n]"
2021-02-19 16:14:19,432 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Code: 104[\r][\n]"
2021-02-19 16:14:19,432 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Dcn: dcn[\r][\n]"
2021-02-19 16:14:19,432 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Passwd: password[\r][\n]"
2021-02-19 16:14:19,433 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Length: 145[\r][\n]"
2021-02-19 16:14:19,433 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Content-Type: application/x-www-form-urlencoded; charset=UTF-8[\r][\n]"
2021-02-19 16:14:19,433 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Host: 127.0.0.1:10105[\r][\n]"
2021-02-19 16:14:19,433 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Connection: Keep-Alive[\r][\n]"
2021-02-19 16:14:19,433 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "User-Agent: Apache-HttpClient/4.5.9 (Java/1.8.0_261)[\r][\n]"
2021-02-19 16:14:19,434 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "Accept-Encoding: gzip,deflate[\r][\n]"
2021-02-19 16:14:19,434 DEBUG [main] wire(Wire.java:73) - http-outgoing-0 >> "[\r][\n]"
2021-02-19 16:14:19,434 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 >> "topic=FT0-e-80010000-01-1&bizSeqNo=419191857764524268924573635906&ttl=14400000&content=testPublishMessage&uniqueId=077687108035298457813383765022"
2021-02-19 16:14:28,439 DEBUG [main] wire(Wire.java:87) - http-outgoing-0 << "[read] I/O error: Read timed out"
2021-02-19 16:14:28,439 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:79) - http-outgoing-0: Close connection
2021-02-19 16:14:28,440 DEBUG [main] DefaultManagedHttpClientConnection(LoggingManagedHttpClientConnection.java:96) - http-outgoing-0: Shutdown connection
2021-02-19 16:14:28,440 DEBUG [main] MainClientExec(ConnectionHolder.java:129) - Connection discarded
2021-02-19 16:14:28,440 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:349) - Connection released: [id: 0][route: {}->http://127.0.0.1:10105][total kept alive: 0; route allocated: 0 of 2; total allocated: 0 of 20]
2021-02-19 16:14:28,440 WARN  [main] AsyncPublishInstance(AsyncPublishInstance.java:54) - publish msg failed
com.webank.eventmesh.common.ProxyException: java.net.SocketTimeoutException: Read timed out
	at com.webank.eventmesh.client.http.producer.LiteProducer.publish(LiteProducer.java:138) ~[main/:?]
	at com.webank.eventmesh.client.http.demo.AsyncPublishInstance.main(AsyncPublishInstance.java:50) ~[test/:?]
Caused by: java.net.SocketTimeoutException: Read timed out
	at java.net.SocketInputStream.socketRead0(Native Method) ~[?:1.8.0_261]
	at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) ~[?:1.8.0_261]
	at java.net.SocketInputStream.read(SocketInputStream.java:171) ~[?:1.8.0_261]
	at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[?:1.8.0_261]
	at org.apache.http.impl.conn.LoggingInputStream.read(LoggingInputStream.java:84) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:137) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:153) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.io.SessionInputBufferImpl.readLine(SessionInputBufferImpl.java:280) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:138) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:56) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:259) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:163) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:157) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:273) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125) ~[httpcore-4.4.11.jar:4.4.11]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:72) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:221) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:165) ~[httpclient-4.5.9.jar:4.5.9]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:140) ~[httpclient-4.5.9.jar:4.5.9]
	at com.webank.eventmesh.client.http.http.HttpUtil.post(HttpUtil.java:146) ~[main/:?]
	at com.webank.eventmesh.client.http.http.HttpUtil.post(HttpUtil.java:55) ~[main/:?]
	at com.webank.eventmesh.client.http.producer.LiteProducer.publish(LiteProducer.java:136) ~[main/:?]
	... 1 more
Caused by: java.net.SocketTimeoutException: Read timed out

2021-02-19 16:14:58,441 INFO  [main] LiteProducer(LiteProducer.java:93) - LiteProducer shutting down
2021-02-19 16:14:58,441 INFO  [main] AbstractLiteClient(AbstractLiteClient.java:81) - AbstractLiteClient shutdown
2021-02-19 16:14:58,441 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:409) - Connection manager is shutting down
2021-02-19 16:14:58,441 DEBUG [main] PoolingHttpClientConnectionManager(PoolingHttpClientConnectionManager.java:415) - Connection manager shut down
2021-02-19 16:14:58,441 INFO  [main] LiteProducer(LiteProducer.java:97) - LiteProducer shutdown

I see heartbeat in SpringBootDemoApplication display fine but when I tested with a postman against POST http://127.0.0.1:10105 that does not response in a timely fashion.

Its kinda like its failing to reach out to port 10105 request instead. please advice.

@qqeasonchen qqeasonchen added bug Something isn't working kind labels Feb 20, 2021
@xwm1992
Copy link
Contributor

xwm1992 commented Feb 20, 2021

Ok, I got it. I tried it in the way as you mentioned. The phenomenon is that there is a ReadTime Out Exception when the first message is sent.When I try to run AsyncPublishInstance again, it will be ok. You can have a try like this.
I suppose this problem due to Eventmesh trying to start the defibus-client to connect with Defibus and this will cost a time, we can analyze this problem further together

@xwm1992
Copy link
Contributor

xwm1992 commented Feb 20, 2021

Consider implementing a warm-up function for the first message under HTTP requests.

@qqeasonchen
Copy link
Contributor

@ewcchan Is there any problem that we can help?

@ewcchan
Copy link
Author

ewcchan commented Feb 23, 2021 •
edited
Loading

@qqeasonchen I tried the suggestion provided by @xwm1992 with multiple AsyncPublishInstance invocations and I am still hitting the same failure.

I observed from ProxyStartup output that there were failures in meshMQPushConsumer and Producer plugins loading process, as observed in following console errors.

and I have in \eventmesh-starter\build.gradle the dependencies of defibus configured.

dependencies {
    compile project(":eventmesh-runtime"), project(":eventmesh-connector-defibus")
    testCompile group: 'junit', name: 'junit', version: '4.12'
}

Errors

2021-02-23 14:29:24,766 ERROR [proxy-clientmanage-2] ConsumerManager(ConsumerManager.java:288) - onChange event:consumerGroupStateEvent={consumerGroup=1234-FT0,action=NEW} err
java.lang.RuntimeException: doesn't load the meshMQPushConsumer plugin, please check.
	at com.webank.eventmesh.runtime.core.plugin.MQConsumerWrapper.init(MQConsumerWrapper.java:56) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.consumer.ProxyConsumer.init(ProxyConsumer.java:90) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.consumer.ConsumerGroupManager.init(ConsumerGroupManager.java:44) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.consumer.ConsumerManager.addConsumer(ConsumerManager.java:203) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.consumer.ConsumerManager.onChange(ConsumerManager.java:274) ~[main/:?]
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_261]
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_261]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_261]
	at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_261]
	at com.google.common.eventbus.Subscriber.invokeSubscriberMethod(Subscriber.java:87) ~[guava-29.0-jre.jar:?]
	at com.google.common.eventbus.Subscriber$SynchronizedSubscriber.invokeSubscriberMethod(Subscriber.java:144) ~[guava-29.0-jre.jar:?]
	at com.google.common.eventbus.Subscriber$1.run(Subscriber.java:72) ~[guava-29.0-jre.jar:?]
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:30) ~[guava-29.0-jre.jar:?]
	at com.google.common.eventbus.Subscriber.dispatchEvent(Subscriber.java:67) ~[guava-29.0-jre.jar:?]
	at com.google.common.eventbus.Dispatcher$PerThreadQueuedDispatcher.dispatch(Dispatcher.java:108) ~[guava-29.0-jre.jar:?]
	at com.google.common.eventbus.EventBus.post(EventBus.java:212) ~[guava-29.0-jre.jar:?]
	at com.webank.eventmesh.runtime.core.protocol.http.consumer.ConsumerManager.notifyConsumerManager(ConsumerManager.java:156) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.processor.SubscribeProcessor.processRequest(SubscribeProcessor.java:169) ~[main/:?]
	at com.webank.eventmesh.runtime.boot.AbrstractHTTPServer$HTTPHandler.lambda$processProxyRequest$1(AbrstractHTTPServer.java:296) ~[main/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_261]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261]
...
....
2021-02-23 14:30:06,069 ERROR [proxy-sendmsg-1] ProxyHTTPServer(AbrstractHTTPServer.java:309) - process error
java.lang.RuntimeException: doesn't load the meshMQProducer plugin, please check.
	at com.webank.eventmesh.runtime.core.plugin.MQProducerWrapper.init(MQProducerWrapper.java:43) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProxyProducer.init(ProxyProducer.java:90) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.createProxyProducer(ProducerManager.java:73) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.getProxyProducer(ProducerManager.java:53) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.processor.SendAsyncMessageProcessor.processRequest(SendAsyncMessageProcessor.java:110) ~[main/:?]
	at com.webank.eventmesh.runtime.boot.AbrstractHTTPServer$HTTPHandler.lambda$processProxyRequest$1(AbrstractHTTPServer.java:296) ~[main/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_261]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261]
	
.....
2021-02-23 14:30:36,481 ERROR [proxy-sendmsg-2] MQProducerWrapper(MQProducerWrapper.java:42) - can't load the meshMQProducer plugin, please check.
2021-02-23 14:30:36,482 ERROR [proxy-sendmsg-2] ProxyHTTPServer(AbrstractHTTPServer.java:309) - process error
java.lang.RuntimeException: doesn't load the meshMQProducer plugin, please check.
	at com.webank.eventmesh.runtime.core.plugin.MQProducerWrapper.init(MQProducerWrapper.java:43) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProxyProducer.init(ProxyProducer.java:90) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.createProxyProducer(ProducerManager.java:73) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.getProxyProducer(ProducerManager.java:53) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.processor.SendAsyncMessageProcessor.processRequest(SendAsyncMessageProcessor.java:110) ~[main/:?]
	at com.webank.eventmesh.runtime.boot.AbrstractHTTPServer$HTTPHandler.lambda$processProxyRequest$1(AbrstractHTTPServer.java:296) ~[main/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_261]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261]
....
2021-02-23 14:30:38,526 ERROR [proxy-sendmsg-3] MQProducerWrapper(MQProducerWrapper.java:42) - can't load the meshMQProducer plugin, please check.
2021-02-23 14:30:38,526 ERROR [proxy-sendmsg-3] ProxyHTTPServer(AbrstractHTTPServer.java:309) - process error
java.lang.RuntimeException: doesn't load the meshMQProducer plugin, please check.
	at com.webank.eventmesh.runtime.core.plugin.MQProducerWrapper.init(MQProducerWrapper.java:43) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProxyProducer.init(ProxyProducer.java:90) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.createProxyProducer(ProducerManager.java:73) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.getProxyProducer(ProducerManager.java:53) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.processor.SendAsyncMessageProcessor.processRequest(SendAsyncMessageProcessor.java:110) ~[main/:?]
	at com.webank.eventmesh.runtime.boot.AbrstractHTTPServer$HTTPHandler.lambda$processProxyRequest$1(AbrstractHTTPServer.java:296) ~[main/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_261]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261]
....
2021-02-23 14:30:57,198 ERROR [proxy-sendmsg-4] MQProducerWrapper(MQProducerWrapper.java:42) - can't load the meshMQProducer plugin, please check.
2021-02-23 14:30:57,198 ERROR [proxy-sendmsg-4] ProxyHTTPServer(AbrstractHTTPServer.java:309) - process error
java.lang.RuntimeException: doesn't load the meshMQProducer plugin, please check.
	at com.webank.eventmesh.runtime.core.plugin.MQProducerWrapper.init(MQProducerWrapper.java:43) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProxyProducer.init(ProxyProducer.java:90) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.createProxyProducer(ProducerManager.java:73) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager.getProxyProducer(ProducerManager.java:53) ~[main/:?]
	at com.webank.eventmesh.runtime.core.protocol.http.processor.SendAsyncMessageProcessor.processRequest(SendAsyncMessageProcessor.java:110) ~[main/:?]
	at com.webank.eventmesh.runtime.boot.AbrstractHTTPServer$HTTPHandler.lambda$processProxyRequest$1(AbrstractHTTPServer.java:296) ~[main/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_261]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261]

Please advice. In the meantime I am trying to understand the com.webank.eventmesh.client.http.producer model.

@ewcchan
Copy link
Author

ewcchan commented Feb 23, 2021

I found out that I had been running the com/webank/eventmesh/runtime/boot/ProxyStartup.java instead of com/webank/eventmesh/starter/StartUp.java, After I switched to run in eventmesh-starter project with the gradle.build file that has the connector dependency, I no longer see the Read Time Out error in execution of AsyncPublishInstance.java.

however, On first execution of AsyncPublishInstance, I did see the following error show up in StartUp console.
@xwm1992 may be able to confirm this is the same DeFiBus client initialization delay issue.

2021-02-23 16:48:17,875 ERROR [http-retry-2] message(AsyncHTTPPushRequest.java:206) - push2client err
org.apache.http.conn.HttpHostConnectException: Connect to 127.0.0.1:8088 [/127.0.0.1] failed: Connection refused: connect
	at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:158) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:353) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:380) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:184) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:88) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:184) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:71) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:220) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:164) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:139) ~[httpclient-4.5.2.jar:4.5.2]
	at com.webank.eventmesh.runtime.core.protocol.http.push.AsyncHTTPPushRequest.tryHTTPRequest(AsyncHTTPPushRequest.java:146) ~[eventmesh-runtime-1.2.0-SNAPSHOT.jar:1.2.0-SNAPSHOT]
	at com.webank.eventmesh.runtime.core.protocol.http.push.AsyncHTTPPushRequest.retry(AsyncHTTPPushRequest.java:273) ~[eventmesh-runtime-1.2.0-SNAPSHOT.jar:1.2.0-SNAPSHOT]
	at com.webank.eventmesh.runtime.core.protocol.http.retry.HttpRetryer$2.lambda$run$0(HttpRetryer.java:83) ~[eventmesh-runtime-1.2.0-SNAPSHOT.jar:1.2.0-SNAPSHOT]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_261]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_261]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_261]
Caused by: java.net.ConnectException: Connection refused: connect
	at java.net.DualStackPlainSocketImpl.connect0(Native Method) ~[?:1.8.0_261]
	at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:75) ~[?:1.8.0_261]
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476) ~[?:1.8.0_261]
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218) ~[?:1.8.0_261]
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200) ~[?:1.8.0_261]
	at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:162) ~[?:1.8.0_261]
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394) ~[?:1.8.0_261]
	at java.net.Socket.connect(Socket.java:606) ~[?:1.8.0_261]
	at org.apache.http.conn.socket.PlainConnectionSocketFactory.connectSocket(PlainConnectionSocketFactory.java:74) ~[httpclient-4.5.2.jar:4.5.2]
	at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:141) ~[httpclient-4.5.2.jar:4.5.2]
	... 17 more

@xwm1992
Copy link
Contributor

xwm1992 commented Feb 24, 2021

127.0.0.1:8088 this port is configuried in the SpringBootDemoApplication class, after run com/webank/eventmesh/starter/StartUp.java you can run the SpringBootDemoApplication to see eventmesh logs and springbootdemoapplication logs whether http sub is ok, then you can run AsyncPublishInstance.

@ewcchan
Copy link
Author

ewcchan commented Feb 25, 2021 •
edited
Loading

Thanks @xwm1992 I don't have any outstanding problem for now. I will close this issue and will reopen if there is further concern.

BY THE WAY, is there any java doc or developer documentation for the jdk client usage?

@ewcchan ewcchan closed this as completed Feb 25, 2021
@qqeasonchen
Copy link
Contributor

Thanks @xwm1992 I don't have any outstanding problem for now. I will close this issue and will reopen if there is further concern.

BY THE WAY, is there any java doc or developer documentation for the jdk client usage?

Documents supplements is going on.

@xwm1992 xwm1992 added this to the 1.2.0-release milestone Apr 25, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug Something isn't working kind
Projects
None yet
Milestone
1.2.0-release
Development

No branches or pull requests
3 participants
@ewcchan @xwm1992 @qqeasonchen