Open LeeMoonCh opened 1 month ago
Welcome to the Apache EventMesh community!! We are glad that you are contributing by opening this issue. :D
Please make sure to include all the relevant context. We will be here shortly.
If you are interested in contributing to our project, please let us know! You can check out our contributing guide on contributing to EventMesh.
Want to get closer to the community?
WeChat Assistant | WeChat Public Account | Slack |
---|---|---|
![]() |
![]() |
Join Slack Chat |
Mailing Lists: | Name | Description | Subscribe | Unsubscribe | Archive |
---|---|---|---|---|---|
Users | User support and questions mailing list | Subscribe | Unsubscribe | Mail Archives | |
Development | Development related discussions | Subscribe | Unsubscribe | Mail Archives | |
Commits | All commits to repositories | Subscribe | Unsubscribe | Mail Archives | |
Issues | Issues or PRs comments and reviews | Subscribe | Unsubscribe | Mail Archives |
2024-07-12 22:31:33,260 WARN [eventMesh-tcpNettyEpoll-Boss-1] ServerBootstrap(AbstractBootstrap.java:464) - Unknown channel option 'SO_TIMEOUT' for channel '[id: 0xb8d69f6f, L:/172.16.15.136:51111 - R:/10.2.1.116:51565]'
2024-07-12 22:31:33,263 INFO [eventMesh-tcp-worker-6] EventMeshTcpConnectionHandler(EventMeshTcpConnectionHandler.java:48) - client|tcp|channelRegistered|remoteAddress=10.2.1.116:51565|msg=
2024-07-12 22:31:33,263 INFO [eventMesh-tcp-worker-6] EventMeshTcpConnectionHandler(EventMeshTcpConnectionHandler.java:62) - client|tcp|channelActive|remoteAddress=10.2.1.116:51565|msg=
2024-07-12 22:31:33,692 INFO [eventMesh-tcp-worker-6] message(EventMeshTcpMessageDispatcher.java:100) - pkg|c2eventMesh|cmd=HELLO_REQUEST|pkg=org.apache.eventmesh.common.protocol.tcp.Package@63c8d488
2024-07-12 22:31:33,693 ERROR [eventMesh-tcp-task-handle-6] message(HelloTask.java:95) - HelloTask failed|address=/10.2.1.116:51565,errMsg=java.lang.Exception: client purpose config is error
2024-07-12 22:31:33,695 INFO [eventMesh-tcp-worker-6] message(Utils.java:128) - pkg|eventMesh2c|cmd=HELLO_RESPONSE|pkg=org.apache.eventmesh.common.protocol.tcp.Package@5e6d5da9|user=UserAgent{env='env', subsystem='5556', group='EventmeshTestGroup', path='C:/em', pid=32893, host='10.2.1.116', port=8362, version='2.0.11', idc='1234', purpose='null', unack='0'}|wait=0ms|cost=2ms
In addition, when I want to try to send a message using tpc, there is an error prompt
My code :
UserAgent userAgent = UserAgent.builder()
.env(ENV)
.host("10.2.1.116")
.password(generateRandomString(UtilsConstants.PASSWORD_LENGTH))
.username("admin")
.group(UtilsConstants.GROUP)
.path("C:/em")
.port(8362)
.subsystem("5556")
.pid(32_893)
.version(UtilsConstants.VERSION)
.idc(SYSID)
.build();
EventMeshTCPClientConfig eventMeshTcpClientConfig = EventMeshTCPClientConfig.builder()
.host("172.16.15.136")
.port(51111)
.userAgent(userAgent)
.build();
final EventMeshTCPClient<CloudEvent> producer =
EventMeshTCPClientFactory.createEventMeshTCPClient(eventMeshTcpClientConfig, CloudEvent.class);
producer.init();
So, now I am confused. Neither official documents nor cases provide detailed descriptions of UserAgents. It's weird.
client purpose config is error
this error means your UserAgents missing the purpose property, you can take a look at EventMeshTestUtils.generateClient1()
method, this may help you.
Search before asking
Question
Sending cloudevents format messages with grpc is slow (I'm not sure if the producers are all slow), and sending 101 pieces of data takes over 60 seconds.
code like this
The results as shown:![image](https://github.com/user-attachments/assets/a54e94a5-395d-4ea7-9cea-89826b1f6b66)
The server is configured as follows:
eventmesh.properties
server.env
Where I do wrong? I don't think producers should so slowly!