阿里云-消息队列TCP接入手册-D

《阿里云-消息队列TCP接入手册-D》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、消息队列TCP接入(专业)消息队列/TCP接入(专业)TCP接入(专业)JavaSDK环境准备运行本节描述的Java代码之前，请按以下说明准备好环境。通过下面两种方式可以引入依赖(任选一种)：-Maven方式引入依赖：com.aliyun.openservicesons-client1.2.4下载依赖Jar包：下载链接代码里涉及到的Topic，ProducerID

2、，ConsumerID，需要到MQ控制台上创建。MessageTag可以完全由应用自定义，具体创建过程可参考申请MQ资源。使用MQ服务的应用程序需要部署在ECS上。发送普通消息（三种方式）简介MQ发送普通消息有三种实现方式：可靠同步发送、可靠异步发送、单向(Oneway)发送。本文介绍了每种实现的原理、使用场景以及三种实现的异同，同时提供了代码示例以供参考。31消息队列/TCP接入(专业)可靠同步发送原理：同步发送是指消息发送方发出数据后，会在收到接收方发回响应之后才发下一个数据包的通讯方式。应用场景：此种方式应用场景非常广泛，例如重要

3、通知邮件、报名短信通知、营销短信系统等。可靠异步发送原理：异步发送是指发送方发出数据后，不等接收方发回响应，接着发送下个数据包的通讯方式。MQ的异步发送，需要用户实现异步发送回调接口（SendCallback），在执行消息的异步发送时，应用不需要等待服务器响应即可直接返回，通过回调接口接收务器响应，并对服务器的响应结果进行处理。应用场景：异步发送一般用于链路耗时较长，对RT响应时间较为敏感的业务场景，例如用户视频上传后通知启动转码服务，转码完成后通知推送转码结果等。单向（Oneway）发送原理：单向（Oneway）发送特点为只负责发送消

4、息，不等待服务器回应且没有回调函数触发，即只发送请求不等待应答。此方式发送消息的过程耗时非常短，一般在微秒级别。31消息队列/TCP接入(专业)发送TPS发送结果反馈可靠性同步发送快有不丢失异步发送快有不丢失单向发送最快无可能丢失应用场景：适用于某些耗时非常短，但对可靠性要求并不高的场景，例如日志收集。下表概括了三者的特点和主要区别。示例代码同步发送publicclassProducerTest{publicstaticvoidmain(String[]args){Propertiesproperties=newProperties()

5、;properties.put(PropertyKeyConst.ProducerId,"XXX");//您在控制台创建的ProducerIDproperties.put(PropertyKeyConst.AccessKey,"XXX");//AccessKey阿里云身份验证，在阿里云服务器管理控制台创建properties.put(PropertyKeyConst.SecretKey,"XXX");//SecretKey阿里云身份验证，在阿里云服务器管理控制台创建properties.setProperty(PropertyKeyCo

6、nst.SendMsgTimeoutMillis,"3000");//设置发送超时时间，单位毫秒Producerproducer=ONSFactory.createProducer(properties);//在发送消息前，必须调用start方法来启动Producer，只需调用一次即可。producer.start();//循环发送消息for(inti=0;i<100;i++){Messagemsg=newMessage(////MessageTopic"TopicTestMQ",//MessageTag可理解为Gmail中的标签，对消

7、息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤"TagA",//MessageBody可以是任何二进制形式的数据，MQ不做任何干预，//需要Producer与Consumer协商好一致的序列化和反序列化方式"HelloMQ".getBytes());//设置代表消息的业务关键属性，请尽可能全局唯一。//以方便您在无法正常收到消息情况下，可通过阿里云服务器管理控制台查询消息并补发。//注意：不设置也不会影响消息正常收发31消息队列/TCP接入(专业)msg.setKey("ORDERID_"+i);//同步发送消息，只要不

8、抛异常就是成功SendResultsendResult=producer.send(msg);System.out.println(sendResult);}//在应用退出前，销毁Producer对象//注