发送消息三种方式有哪些？

MQ 发送消息有三种实现方式：可靠同步发送、可靠异步发送、单向(Oneway)发送。本文介绍了每种实现的原理、使用场景以及三种实现的异同，同时提供了代码示例以供参考。
注意：顺序消息只支持可靠同步发送。

• 
  可靠同步发送
  原理：同步发送是指消息发送方发出数据后，会在收到接收方发回响应之后才发下一个数据包的通讯方式。
  应用场景：适用于某些耗时非常短，但对可靠性要求并不高的场景，例如日志收集。

1. import com.aliyun.openservices.ons.api.Message;
2. import com.aliyun.openservices.ons.api.Producer;
3. import com.aliyun.openservices.ons.api.SendResult;
4. import com.aliyun.openservices.ons.api.ONSFactory;
5. import com.aliyun.openservices.ons.api.PropertyKeyConst;
7. import java.util.Properties;
9. public class ProducerTest {
10.     public static void main(String[] args) {
11.         Properties properties = new Properties();
12.         //您在控制台创建的Producer ID
13.         properties.put(PropertyKeyConst.ProducerId, "XXX");
14.         // AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建
15.         properties.put(PropertyKeyConst.AccessKey,"XXX");
16.         // SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建
17.         properties.put(PropertyKeyConst.SecretKey, "XXX");
18.         //设置发送超时时间，单位毫秒
19.         properties.setProperty(PropertyKeyConst.SendMsgTimeoutMillis, "3000");
20.         // 设置 TCP 接入域名（此处以公共云生产环境为例）
21.         properties.put(PropertyKeyConst.ONSAddr,
22.           "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");
24.         Producer producer = ONSFactory.createProducer(properties);
25.         // 在发送消息前，必须调用start方法来启动Producer，只需调用一次即可
26.         producer.start();
28.         //循环发送消息
29.         for (int i = 0; i < 100; i++){
30.             Message msg = new Message( //
31.                 // Message所属的Topic
32.                 "TopicTestMQ",
33.                 // Message Tag 可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤
34.                 "TagA",
35.                 // Message Body 可以是任何二进制形式的数据， MQ不做任何干预，
36.                 // 需要Producer与Consumer协商好一致的序列化和反序列化方式
37.                 "Hello MQ".getBytes());
38.             // 设置代表消息的业务关键属性，请尽可能全局唯一。
39.             // 以方便您在无法正常收到消息情况下，可通过阿里云服务器管理控制台查询消息并补发
40.             // 注意：不设置也不会影响消息正常收发
41.             msg.setKey("ORDERID_" + i);
43.             // 同步发送消息，只要不抛异常就是成功
44.             SendResult sendResult = producer.send(msg);
45.             System.out.println(sendResult);
46.         }
48.         // 在应用退出前，销毁Producer对象
49.         // 注意：如果不销毁也没有问题
50.         producer.shutdown();
51.     }
52. }

1.     import com.aliyun.openservices.ons.api.Message;
2.     import com.aliyun.openservices.ons.api.OnExceptionContext;
3.     import com.aliyun.openservices.ons.api.Producer;
4.     import com.aliyun.openservices.ons.api.SendCallback;
5.     import com.aliyun.openservices.ons.api.SendResult;
6.     import com.aliyun.openservices.ons.api.ONSFactory;
7.     import com.aliyun.openservices.ons.api.PropertyKeyConst;
9.     import java.util.Properties;
11.     public static void main(String[] args) {
12.         Properties properties = new Properties();
13.         // AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建
14.         properties.put(PropertyKeyConst.AccessKey, "DEMO_AK");
15.         // SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建
16.         properties.put(PropertyKeyConst.SecretKey, "DEMO_SK");
17.         //您在控制台创建的Producer ID
18.         properties.put(PropertyKeyConst.ProducerId, "DEMO_PID");
19.         //设置发送超时时间，单位毫秒
20.         properties.setProperty(PropertyKeyConst.SendMsgTimeoutMillis, "3000");
21.         // 设置 TCP 接入域名（此处以公共云生产环境为例）
22.         properties.put(PropertyKeyConst.ONSAddr,
23.           "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");
25.         Producer producer = ONSFactory.createProducer(properties);
26.         // 在发送消息前，必须调用start方法来启动Producer，只需调用一次即可。
27.         producer.start();
29.         Message msg = new Message(
30.                 // Message所属的Topic
31.                 "TopicTestMQ",
32.                 // Message Tag,可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤
33.                 "TagA",
34.                 // Message Body，任何二进制形式的数据，MQ不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式
35.                 "Hello MQ".getBytes());
37.         // 设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过MQ控制台查询消息并补发。
38.         // 注意：不设置也不会影响消息正常收发
39.         msg.setKey("ORDERID_100");
41.         // 异步发送消息, 发送结果通过callback返回给客户端。
42.         producer.sendAsync(msg, new SendCallback() {
43.             @Override
44.             public void onSuccess(final SendResult sendResult) {
45.                 // 消费发送成功
46.                 System.out.println("send message success. topic=" + sendResult.getTopic() + ", msgId=" + sendResult.getMessageId());
47.             }
49.             @Override
50.             public void onException(OnExceptionContext context) {
51.                 // 消息发送失败
52.                 System.out.println("send message failed. topic=" + context.getTopic() + ", msgId=" + context.getMessageId());
53.             }
54.         });
56.         // 在callback返回之前即可取得msgId。
57.         System.out.println("send message async. topic=" + msg.getTopic() + ", msgId=" + msg.getMsgID());
59.         // 在应用退出前，销毁Producer对象。注意：如果不销毁也没有问题
60.         producer.shutdown();
61.     }

1.     import com.aliyun.openservices.ons.api.Message;
2.     import com.aliyun.openservices.ons.api.Producer;
3.     import com.aliyun.openservices.ons.api.ONSFactory;
4.     import com.aliyun.openservices.ons.api.PropertyKeyConst;
6.     import java.util.Properties;
8.     public static void main(String[] args) {
9.         Properties properties = new Properties();
10.         // AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建
11.         properties.put(PropertyKeyConst.AccessKey, "DEMO_AK");
12.         // SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建
13.         properties.put(PropertyKeyConst.SecretKey, "DEMO_SK");
14.         //您在控制台创建的Producer ID
15.         properties.put(PropertyKeyConst.ProducerId, "DEMO_PID");
16.         //设置发送超时时间，单位毫秒
17.         properties.setProperty(PropertyKeyConst.SendMsgTimeoutMillis, "3000");
18.         // 设置 TCP 接入域名（此处以公共云生产环境为例）
19.         properties.put(PropertyKeyConst.ONSAddr,
20.           "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");
22.         Producer producer = ONSFactory.createProducer(properties);
23.         // 在发送消息前，必须调用start方法来启动Producer，只需调用一次即可。
24.         producer.start();
25.         //循环发送消息
26.         for (int i = 0; i < 100; i++){
27.             Message msg = new Message(
28.                     // Message所属的Topic
29.                     "TopicTestMQ",
30.                     // Message Tag,
31.                     // 可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤
32.                     "TagA",
33.                     // Message Body
34.                     // 任何二进制形式的数据，MQ不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式
35.                     "Hello MQ".getBytes());
37.             // 设置代表消息的业务关键属性，请尽可能全局唯一。
38.             // 以方便您在无法正常收到消息情况下，可通过阿里云服务器管理控制台查询消息并补发。
39.             // 注意：不设置也不会影响消息正常收发
40.             msg.setKey("ORDERID_" + i);
42.             // oneway发送消息，只要不抛异常就是成功
43.             producer.sendOneway(msg);
44.         }
46.         // 在应用退出前，销毁Producer对象
47.         // 注意：如果不销毁也没有问题
48.         producer.shutdown();
49.     }