[Feature] 接入 OpenTelemetry 链路追踪，方便消息跟踪

[sduo]

Programming Language of the Client

C#

Is Your Feature Request Related to a Problem?

C# 客户端无法对消息进行追踪

Describe the Solution You'd Like

通过向 DiagnosticListener 写入相关事件，为消息加入相关的追踪数据。

Describe Alternatives You've Considered

=== SDK 修改开始 ===

1. 定义一个名称为 Org.Apache.Rocketmq 的 DiagnosticListener。
2. 在 ClientManager 发送消息时，向 DiagnosticSource 中写入 SendMessage 事件，载荷为当次发送的所有消息的数组。
3. 在 ClientManager 接收消息时，向 DiagnosticSource 中写入 ReceiveMessage 事件，载荷为当次接收的所有消息的数组。
   === SDK 修改完毕 ===

=== OpenTelemetry 实现开始 ===
4. 此时可在外部对通过 DiagnosticListener 订阅名称为 Org.Apache.Rocketmq 的事件。
5. 在 SendMessage 事件中，依次遍历载荷中的消息，判断消息的 SystemProperties.TraceContext 是否包含相关数据。
5.1 包含跟踪数据，不做任何处理，放行即可。
5.2 不包含跟踪数据，写入跟踪信息，并上报。
6. 在 ReceiveMessage 事件中，依次遍历载荷中的消息，判断消息的 SystemProperties.TraceContext 是否包含相关数据。
6.1 不包含跟踪数据，不做任何处理，放行即可。
6.2 包含跟踪数据，读取跟踪信息，并上报。
=== OpenTelemetry 实现完毕 ===

Additional Context

No response

[aaron-ai]

Nice proposal.

[sduo]

@aaron-ai 经过进一步的思考与论证，打算将SendMessage和ReceiveMessage拆分成4个，对应事件及数据来源打算按照下表：

其中：?处有待商讨！

	Attribute	SendMessageBefore	SendMessageAfter	ReceiveMessageBefore	ReceiveMessageAfter
Span	Id	Activity.Id	-	-	Activity.Id
Span	ParentId	-	Message.UserProperties.TraceContext ?	-	Message.SystemProperties.TraceContext
Tag	messaging.system	-	"rocketmq"	-	"rocketmq"
Tag	messaging.client_id	-	Metadata["x-mq-client-id"]	-	Metadata["x-mq-client-id"]
Tag	messaging.operation	-	"publish"	-	"receive" ? "deliver" ?
Tag	messaging.destination.name	-	Message.Topic	-	Message.Topic
Tag	messaging.destination.anonymous	-	-	-	-
Tag	messaging.destination.template	-	-	-	-
Tag	messaging.destination.temporary	-	-	-	-
Tag	messaging.destination_publish.name	-	-	-	-
Tag	messaging.destination_publish.anonymous	-	-	-	-
Tag	messaging.message.conversation_id	-	Metadata["x-mq-request-id"] ?	-	Metadata["x-mq-request-id"] ?
Tag	messaging.message.id	-	Message.SystemProperties.MessageId	-	Message.SystemProperties.MessageId
Tag	messaging.rocketmq.message.type	-	Message.SystemProperties.MessageType	-	Message.SystemProperties.MessageType
Tag	messaging.rocketmq.message.tag	-	Message.SystemProperties.Tag	-	Message.SystemProperties.Tag
Tag	messaging.rocketmq.namespace	-	ClientConfig.Endpoints ?	-	ClientConfig.Endpoints ?
Tag	messaging.rocketmq.message.keys	-	Message.SystemProperties.Keys	-	Message.SystemProperties.Keys
Tag	messaging.rocketmq.message.group	-	Message.SystemProperties.MessageGroup	-	Message.SystemProperties.MessageGroup
Tag	messaging.message.envelope.size	-	-	-	-
Tag	messaging.message.body.size	-	Message.Body.Length	-	Message.Body.Length
Tag	messaging.rocketmq.client_group	-	-	-	ReceiveMessageRequest.Group.Name
Tag	messaging.batch.message_count	-	-	-	ReceiveMessageRequest.BatchSize
Tag	messaging.rocketmq.consumption_model	-	-	-	-
Tag	messaging.rocketmq.message.delay_time_level	-	-	-	-
Tag	messaging.rocketmq.message.delivery_timestamp	-	Message.SystemProperties.DeliveryTimestamp	-	Message.SystemProperties.DeliveryTimestamp
Tag	messaging.gcp_pubsub.message.ordering_key	-	-	-	-

论证点：

1. 不能直接暴露ClientConfig，其中包含了认证敏感信息。
2. 另外Metadata信息中，我觉得可以有更多的关键数据被记录下来，但无对应的Tag属性。

项目	数值
x-mq-language	"DOTNET"
x-mq-client-version	"5.1.1-rc1"
x-mq-request-id	GUID

• https://opentelemetry.io/docs/specs/semconv/attributes-registry/messaging/
• https://opentelemetry.io/docs/specs/semconv/messaging/rocketmq/

[github-actions]

This issue is stale because it has been open for 30 days with no activity. It will be closed in 3 days if no further activity occurs.

[ZUOXIANGE]

这个Feature不错,现在有计划实现吗