阿里云rocketmq消息队列对接demo

上传者: alan_liuyue | 上传时间: 2024-02-29 19:26:40 | 文件大小: 42KB | 文件类型: ZIP
该资源为在购买了阿里云中间件产品rocketmq消息队列之后,使用的连接rocketmq的demo工程,该程序以 Java 为例,包括普通消息、事务消息、定时消息的测试代码,以及相关 Spring 的配置示例,同时提供tcp连接的程序。

文件下载

资源详情

[{"title":"( 38 个子文件 42KB ) 阿里云rocketmq消息队列对接demo","children":[{"title":"mq-demo-master","children":[{"title":"tcp","children":[{"title":"java-tcp-demo","children":[{"title":"src","children":[{"title":"test","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 229B </span>","children":null,"spread":false},{"title":"logback.xml <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"aliyun","children":[{"title":"openservices","children":[{"title":"tcp","children":[{"title":"example","children":[{"title":"consumer","children":[{"title":"SimpleOrderConsumer.java <span style='color:#111;'> 2.34KB </span>","children":null,"spread":false},{"title":"MessageListenerImpl.java <span style='color:#111;'> 1.36KB </span>","children":null,"spread":false},{"title":"SimpleMQConsumer.java <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false}],"spread":true},{"title":"MqConfig.java <span style='color:#111;'> 1.79KB </span>","children":null,"spread":false},{"title":"producer","children":[{"title":"MQTimerProducer.java <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false},{"title":"SimpleOrderProducer.java <span style='color:#111;'> 2.90KB </span>","children":null,"spread":false},{"title":"SimpleMQProducer.java <span style='color:#111;'> 2.43KB </span>","children":null,"spread":false},{"title":"SimpleTransactionProducer.java <span style='color:#111;'> 2.08KB </span>","children":null,"spread":false},{"title":"LocalTransactionCheckerImpl.java <span style='color:#111;'> 722B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"README.txt <span style='color:#111;'> 8B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 3.26KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 1.88KB </span>","children":null,"spread":false},{"title":".gitignore <span style='color:#111;'> 87B </span>","children":null,"spread":false},{"title":"spring","children":[{"title":"java-spring-demo","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"order_consumer.xml <span style='color:#111;'> 1.79KB </span>","children":null,"spread":false},{"title":"batch_consumer.xml <span style='color:#111;'> 1.93KB </span>","children":null,"spread":false},{"title":"producer.xml <span style='color:#111;'> 834B </span>","children":null,"spread":false},{"title":"consumer.xml <span style='color:#111;'> 1.77KB </span>","children":null,"spread":false},{"title":"order_producer.xml <span style='color:#111;'> 844B </span>","children":null,"spread":false},{"title":"common.xml <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false},{"title":"transaction_producer.xml <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false},{"title":"sql_consumer.xml <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"aliyun","children":[{"title":"openservices","children":[{"title":"spring","children":[{"title":"example","children":[{"title":"batch","children":[{"title":"BatchConsumerClient.java <span style='color:#111;'> 597B </span>","children":null,"spread":false},{"title":"BatchDemoMessageListener.java <span style='color:#111;'> 839B </span>","children":null,"spread":false}],"spread":false},{"title":"order","children":[{"title":"OrderConsumerClient.java <span style='color:#111;'> 596B </span>","children":null,"spread":false},{"title":"OrderProducerClient.java <span style='color:#111;'> 2.40KB </span>","children":null,"spread":false},{"title":"OrderDemoMessageListener.java <span style='color:#111;'> 744B </span>","children":null,"spread":false}],"spread":false},{"title":"normal","children":[{"title":"ProducerClient.java <span style='color:#111;'> 2.34KB </span>","children":null,"spread":false},{"title":"AsyncProducerClient.java <span style='color:#111;'> 3.30KB </span>","children":null,"spread":false},{"title":"SqlConsumerClient.java <span style='color:#111;'> 584B </span>","children":null,"spread":false},{"title":"SqlProducerClient.java <span style='color:#111;'> 2.72KB </span>","children":null,"spread":false},{"title":"DemoMessageListener.java <span style='color:#111;'> 650B </span>","children":null,"spread":false},{"title":"ConsumerClient.java <span style='color:#111;'> 576B </span>","children":null,"spread":false}],"spread":false},{"title":"transaction","children":[{"title":"DemoLocalTransactionChecker.java <span style='color:#111;'> 577B </span>","children":null,"spread":false},{"title":"TransactionProducerClient.java <span style='color:#111;'> 1.71KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 676B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 1.68KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}]

评论信息

免责申明

【只为小站】的资源来自网友分享,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论 【只为小站】 经营者是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二条之规定,若资源存在侵权或相关问题请联系本站客服人员,zhiweidada#qq.com,请把#换成@,本站将给予最大的支持与配合,做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明