Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
Kwan的解忧杂货铺@新空间代码工作室
Rocketmq
提交
6898bf25
R
Rocketmq
项目概览
Kwan的解忧杂货铺@新空间代码工作室
/
Rocketmq
与 Fork 源项目一致
Fork自
Apache RocketMQ / Rocketmq
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
R
Rocketmq
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
提交
6898bf25
编写于
11月 24, 2021
作者:
Z
zhangxu16
浏览文件
操作
浏览文件
下载
差异文件
Merge branch 'master' of github.com:apache/rocketmq
上级
33aee586
a75c7423
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
13 addition
and
13 deletion
+13
-13
docs/cn/client/java/API_Reference_DefaultMQProducer.md
docs/cn/client/java/API_Reference_DefaultMQProducer.md
+13
-13
未找到文件。
docs/cn/client/java/API_Reference_DefaultMQProducer.md
浏览文件 @
6898bf25
...
...
@@ -54,7 +54,7 @@ public class Producer {
|int|retryTimesWhenSendAsyncFailed|异步模式下内部尝试发送消息的最大次数|
|boolean|retryAnotherBrokerWhenNotStoreOK|是否在内部发送失败时重试另一个broker|
|int|maxMessageSize|消息的最大长度|
|TraceDispatcher|traceDispatcher|
消息追踪器。使用rcpHook来追踪消息
|
|TraceDispatcher|traceDispatcher|
基于RPCHooK实现的消息轨迹插件
|
### 构造方法摘要
...
...
@@ -62,11 +62,11 @@ public class Producer {
|-------|------------|
|DefaultMQProducer()|由默认参数值创建一个生产者 |
|DefaultMQProducer(final String producerGroup)|使用指定的分组名创建一个生产者|
|DefaultMQProducer(final String producerGroup, boolean enableMsgTrace)|使用指定的分组名创建一个生产者,并设置是否开启消息
追踪
|
|DefaultMQProducer(final String producerGroup, boolean enableMsgTrace, final String customizedTraceTopic)|使用指定的分组名创建一个生产者,并设置是否开启消息
追踪
及追踪topic的名称|
|DefaultMQProducer(final String producerGroup, boolean enableMsgTrace)|使用指定的分组名创建一个生产者,并设置是否开启消息
轨迹
|
|DefaultMQProducer(final String producerGroup, boolean enableMsgTrace, final String customizedTraceTopic)|使用指定的分组名创建一个生产者,并设置是否开启消息
轨迹
及追踪topic的名称|
|DefaultMQProducer(RPCHook rpcHook)|使用指定的hook创建一个生产者|
|DefaultMQProducer(final String producerGroup, RPCHook rpcHook)|使用指定的分组名及自定义hook创建一个生产者|
|DefaultMQProducer(final String producerGroup, RPCHook rpcHook, boolean enableMsgTrace,final String customizedTraceTopic)|使用指定的分组名及自定义hook创建一个生产者,并设置是否开启消息
追踪
及追踪topic的名称|
|DefaultMQProducer(final String producerGroup, RPCHook rpcHook, boolean enableMsgTrace,final String customizedTraceTopic)|使用指定的分组名及自定义hook创建一个生产者,并设置是否开启消息
轨迹
及追踪topic的名称|
### 使用方法摘要
...
...
@@ -204,7 +204,7 @@ public class Producer {
`private TraceDispatcher traceDispatcher = null`
在开启消息
追踪
后,该类通过hook的方式把消息生产者,消息存储的broker和消费者消费消息的信息像链路一样记录下来。在构造生产者时根据构造入参enableMsgTrace来决定是否创建该对象。
在开启消息
轨迹
后,该类通过hook的方式把消息生产者,消息存储的broker和消费者消费消息的信息像链路一样记录下来。在构造生产者时根据构造入参enableMsgTrace来决定是否创建该对象。
### 构造方法详细信息
...
...
@@ -230,20 +230,20 @@ public class Producer {
`DefaultMQProducer(final String producerGroup, boolean enableMsgTrace)`
使用指定的分组名创建一个生产者,并设置是否开启消息
追踪
。
使用指定的分组名创建一个生产者,并设置是否开启消息
轨迹
。
- 入参描述:
参数名 | 类型 | 是否必须 | 缺省值 |描述
---|---|---|---|---
producerGroup | String | 是 | DEFAULT_PRODUCER | 生产者的分组名称
enableMsgTrace | boolean | 是 | false |是否开启消息
追踪
enableMsgTrace | boolean | 是 | false |是否开启消息
轨迹
4.
DefaultMQProducer
`DefaultMQProducer(final String producerGroup, boolean enableMsgTrace, final String customizedTraceTopic)`
使用指定的分组名创建一个生产者,并设置是否开启消息
追踪
及追踪topic的名称。
使用指定的分组名创建一个生产者,并设置是否开启消息
轨迹
及追踪topic的名称。
- 入参描述:
...
...
@@ -251,8 +251,8 @@ public class Producer {
---|---|---|---|---
producerGroup | String | 是 | DEFAULT_PRODUCER | 生产者的分组名称
rpcHook | RPCHook | 否 | null |每个远程命令执行后会回调rpcHook
enableMsgTrace | boolean | 是 | false |是否开启消息
追踪
customizedTraceTopic | String | 否 | RMQ_SYS_TRACE_TOPIC | 消息
跟踪
topic的名称
enableMsgTrace | boolean | 是 | false |是否开启消息
轨迹
customizedTraceTopic | String | 否 | RMQ_SYS_TRACE_TOPIC | 消息
轨迹
topic的名称
5.
DefaultMQProducer
...
...
@@ -283,7 +283,7 @@ public class Producer {
`DefaultMQProducer(final String producerGroup, RPCHook rpcHook, boolean enableMsgTrace,final String customizedTraceTopic)`
使用指定的分组名及自定义hook创建一个生产者,并设置是否开启消息
追踪
及追踪topic的名称。
使用指定的分组名及自定义hook创建一个生产者,并设置是否开启消息
轨迹
及追踪topic的名称。
- 入参描述:
...
...
@@ -291,8 +291,8 @@ public class Producer {
---|---|---|---|---
producerGroup | String | 是 | DEFAULT_PRODUCER | 生产者的分组名称
rpcHook | RPCHook | 否 | null |每个远程命令执行后会回调rpcHook
enableMsgTrace | boolean | 是 | false |是否开启消息
追踪
customizedTraceTopic | String | 否 | RMQ_SYS_TRACE_TOPIC | 消息
跟踪
topic的名称
enableMsgTrace | boolean | 是 | false |是否开启消息
轨迹
customizedTraceTopic | String | 否 | RMQ_SYS_TRACE_TOPIC | 消息
轨迹
topic的名称
### 使用方法详细信息
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录