MNS支持JMS协议的方案

        <dependency>
            <groupId>com.aliyun.mns</groupId>
            <artifactId>java-messaging-lib</artifactId>
            <version>0.1.1</version>
        </dependency>

          String accessKeyId = “从第4步拿到的AK信息”;
          String accessKeySecret = “从第4步拿到的AK信息”;
          String accessKeySecret = “从第4步拿到的AK信息”;
          String endpoint = “从第3步拿到的Endpoint信息”;
          MNSConnectionFactory factory = MNSConnectionFactory.builder()
                                                                .withAccessKeyId(accessKeyId)
                                                                .withAccessKeySecret(accessKeySecret)
                                                                .withEndpoint(endpoint)
                                                                .build();
          MNSQueueConnection connection = factory.createQueueConnection();

          MNSClientWrapper mnsClientWrapper = connection.getMNSClientWrapper();
          mnsClientWrapper.createQueue(queueName);

          QueueSession session = connection.createQueueSession(false, 
              Session.AUTO_ACKNOWLEDGE);
          Queue queue = session.createQueue(queueName);

         MessageProducer producer = session.createProducer(queue);
         TextMessage textMessage = session.createTextMessage("Hello JMS!");                   
         textMessage.setDoubleProperty("TestFloat", 0.127);
         producer.send(textMessage);

        MessageListener listener = new MessageListener() {
            @Override
            public void onMessage(Message message) {
                    receivedNum.incrementAndGet();
                    try {
                        if (message instanceof TextMessage) {
                            MNSTextMessage textMessage = (MNSTextMessage) message;
                            System.out.println("Receive in lisener: " + textMessage.getText());
                        }
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }                    
                }
            };

      MessageConsumer consumer = session.createConsumer(queue);
      consumer.setMessageListener(listener);     
      connection.start();

      producer.close();
      consumer.close();
      session.close();
      connection.close();

• ConnectionFactory
• Connection
• Destination
• Session
• MessageProducer
• MessageConsumer

• TextMessage
• ByteMessage
• ObjectMessage

• AUTO_ACKNOWLEDGE