上传者: 42118161
|
上传时间: 2021-12-02 14:55:27
|
文件大小: 48KB
|
文件类型: -
cmq-client
近期项目中使用到CMQ,鉴于官方提供SDK太过简陋且存在严重BUG,于是自己简单的实现了一个,虽只实现了routingKey相关部分,但也足够一般使用。此外虽然本项目实现了应用启动时自动创建Topic、Queue、Subscription相关功能,但由于实际场景复杂,仍建议通过CMQ控制台进行相关创建。时间仓促,细节之处多有瑕疵,复杂场景测试不全,故仅供参考。
// 配置类
@EnableCMQ
@Configuration
public class CMQConfig {
@Bean
public CMQSpringConfigBean cmqSpringConfigBean() {
CMQSpringConfigBean config = new CMQSpringConfigBean();
config.setSecretId("xxx");
c