生產者
更新時間 2024-12-04 18:00:11
最近更新時間: 2024-12-04 18:00:11
分享文章
應用進程、生產組、生產實例的關系
同一進程內，同一生產組不能有相同的實例
實例的創建和銷毀
1.使用CTGFactory進行創建Producer實例【強制規范】。
2.Prouder是重量級的實例，每次創建、銷毀都會消耗系統資源，建議系統啟動的時候創建，系統退出的時候關閉，禁止每次發送消息創建新的實例【強制規范】。
客戶端參數建議
- 生產者參數：
| 常量字段 | 說明 |
|---|---|
| namesrv | 地址必要，例如：192.168.10.10:9876;192.168.10.11:9876 |
| namesrv | 用戶名必填 |
| namesrv | 密碼必填 |
| ClusterName | 客戶端訂閱broker的集群名，根據實際情況設置 |
| TenantID | 租戶ID，根據實際情況設置 |
| 生產組名稱 | 生產者必填 |
| VipChannelEnabled | true或者false，默認是true，生產和消費端口分開，如果是false，那就共用一個端口 |
| EnalbeCipher | true或者false，默認是false，客戶端字段填明文密碼，如果設置為true，字段填md5密文 |
- 消費者參數：
| 常量字段 | 說明 |
|---|---|
| 從哪個位置開始消費 | 建議設置為：ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET.name() |
| 消費組名稱 | 消費者必要 |
| 最大消費線程數 | 針對push模式，默認64 |
| 最小消費線程數 | 針對push模式，默認20 |
| 消費超時時間 | 1.默認不設或設置<=0：表示不做超時處理，應用自己處理簽收2.設置>0：表示一旦超過此消費超時時間（應用未做簽收），客戶端將自動簽收失敗，消息進入重試隊列。 |
| namesrv | 地址必要，例如：192.168.10.10:9876;192.168.10.11:9876 |
| namesrv | 用戶名必填 |
| namesrv | 密碼必填 |
| ClusterName | 客戶端訂閱broker的集群名，默認defaultMQBrokerCluster |
| TenantID | 租戶ID，默認defaultMQTenantID |
