zhyyu commented on PR #361:
URL: https://github.com/apache/skywalking-java/pull/361#issuecomment-1286596516
> This scenario is unfinished. I meet a weird problem and can not figure it
out for a longtime. The provider segment successfully report to mock collector,
but the consumer segment missed.
>
> I run the run.sh debug mode,
>
> the secnario.out shows that rocketmq conumser success.
>
> ```
> Provider Started.
> Fri Oct 21 07:21:53 UTC 2022 send msg: SendResult [sendStatus=SEND_OK,
msgId=7F0000010030351E414E6893BBFA0000,
offsetMsgId=AC17000300002A9F0000000000000000, messageQueue=MessageQueue
[topic=TopicTest, brokerName=broker, queueId=2], queueOffset=0]
> Consumer Started.
> ConsumeMessageThread_please_rename_unique_group_name_1 Receive New
Messages: Hello RocketMQ sendMsg Fri Oct 21 07:21:51 UTC 2022
> ```
>
> bug actualData.yaml do not exit consumer segment
>
> ```
> segmentItems:
> - serviceName: rocketmq-scenario
> segmentSize: 2
> segments:
> - segmentId: e20e9a5ec93e49858ca254713a3d370e.37.16663369109610000
> spans:
> - operationName: HEAD:/rocketmq-scenario/case/healthCheck
> parentSpanId: -1
> spanId: 0
> spanLayer: Http
> startTime: 1666336910980
> endTime: 1666336911321
> componentId: 1
> isError: false
> spanType: Entry
> peer: ''
> skipAnalysis: false
> tags:
> - {key: url, value:
'http://localhost:8080/rocketmq-scenario/case/healthCheck'}
> - {key: http.method, value: HEAD}
> - {key: http.status_code, value: '200'}
> - segmentId: e20e9a5ec93e49858ca254713a3d370e.38.16663369113630000
> spans:
> - operationName: RocketMQ/TopicTest/Producer
> parentSpanId: 0
> spanId: 1
> spanLayer: MQ
> startTime: 1666336912425
> endTime: 1666336913135
> componentId: 38
> isError: false
> spanType: Exit
> peer: namesrv:9876
> skipAnalysis: false
> tags:
> - {key: mq.broker, value: '172.23.0.3:10911'}
> - {key: mq.topic, value: TopicTest}
> - operationName: GET:/rocketmq-scenario/case/rocketmq-scenario
> parentSpanId: -1
> spanId: 0
> spanLayer: Http
> startTime: 1666336911363
> endTime: 1666336913185
> componentId: 1
> isError: false
> spanType: Entry
> peer: ''
> skipAnalysis: false
> tags:
> - {key: url, value:
'http://localhost:8080/rocketmq-scenario/case/rocketmq-scenario'}
> - {key: http.method, value: GET}
> - {key: http.status_code, value: '200'}
> meterItems:
> - serviceName: rocketmq-scenario
> meterSize: 5
> meters:
> - meterId:
> name: thread_pool
> tags:
> - {name: metric_type, value: active_size}
> - {name: pool_name, value: tomcat_execute_pool}
> singleValue: 0.0
> - meterId:
> name: thread_pool
> tags:
> - {name: metric_type, value: queue_size}
> - {name: pool_name, value: tomcat_execute_pool}
> singleValue: 0.0
> - meterId:
> name: thread_pool
> tags:
> - {name: metric_type, value: pool_size}
> - {name: pool_name, value: tomcat_execute_pool}
> singleValue: 10.0
> - meterId:
> name: thread_pool
> tags:
> - {name: metric_type, value: core_pool_size}
> - {name: pool_name, value: tomcat_execute_pool}
> singleValue: 10.0
> - meterId:
> name: thread_pool
> tags:
> - {name: metric_type, value: max_pool_size}
> - {name: pool_name, value: tomcat_execute_pool}
> singleValue: 200.0
> logItems: []
> ```
It seems like rocketmq plugin error when provider and consumer in the same
java process. The consumer class is not enhanced. But when provider and
consumer in two different java process, the consumer class is enhanced, and can
report consume segment. I checked the rocketmq plugin code but not found out
why....
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
