HTTP 接入Java 收发消息如何实现？

下载官网 Demo


下载地址

导入工程


HTTP 的 Demo 在 http/java-http-demo路径下，使用 Eclipse 或者 Idea 打开http/java-http-demo。具体可参考 Idea 配置教程。

修改配置文件

1. 
   修改 producer.xml，该文件在src/main/resources/producer/producer.xml路径下。如下所示，修改为自己在阿里云商分配的配置：
   域名 Domain 列表 <bean id="producer" class="com.alibaba.ons.message.example.producer.HttpMQProducer">
2. <!-- domain，请替换，从域名列表选择Topic所在region的域名 -->
3. <property name="url" value="http://domain/message" />
5. <!-- 阿里云身份验证码，请替换 -->
6. <property name="accessKey" value="XXXXXX" />
8. <!-- 阿里云身份验证密钥，请替换 -->
9. <property name="secretKey" value="XXXXXX" />
11. <!-- MQ控制台创建的Topic，请替换 -->
12. <property name="topic" value="XXXXXX" />
14. <!-- MQ控制台创建的Producer ID，请替换 -->
15. <property name="producerId" value="XXXXXX" />
16. </bean>

1. <bean id="consumer" class="com.alibaba.ons.message.example.consumer.HttpMQConsumer">
2. <!-- domain，请替换，从域名列表选择Topic所在region的域名 -->
3. <property name="url" value="http://domain/message" />
5. <!-- 阿里云身份验证码,请替换 -->
6. <property name="accessKey" value="XXXXXX" />
8. <!-- 阿里云身份验证密钥，请替换 -->
9. <property name="secretKey" value="XXXXXX" />
11. <!-- MQ控制台创建的Topic，请替换 -->
12. <property name="topic" value="XXXXXX" />
14. <!-- MQ控制台创建的Consumer ID，请替换 -->
15. <property name="consumerId" value="XXXXXX" />
16. </bean>

1. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("producer/producer.xml");
2. HttpMQProducer producer = context.getBean(HttpMQProducer.class);
4. // 发送定时消息: producer.send("msg", "tag", "key", startDeliverTime);
5. if (producer.send("msg", "tag", "key")) {
6.     System.out.println("send message success");
7. } else {
8.     System.out.println("send message failed");
9. }
10. context.close();

1. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer/consumer.xml");
2. HttpMQConsumer consumer = context.getBean(HttpMQConsumer.class);
3. List<SimpleMessage> list = consumer.pull();
4. if (list != null && list.size() > 0) {
5.     for (SimpleMessage simpleMessage : list) {
6.         System.out.println(simpleMessage);
8.         // 当消息处理成功后，需要进行delete，如果不及时delete将会导致重复消费此消息
9.         String msgHandle = simpleMessage.getMsgHandle();
10.         if (consumer.delete(msgHandle)) {
11.             System.out.println("delete success: " + msgHandle);
12.         } else {
13.             System.out.println("delete failed: " + msgHandle);
14.         }
15.     }
16. }
17. context.close();