Short Message Service:Lightweight Message Queue (旧 MNS) の消費デモ

Java デモ

package com.alicom.mns.sample;

import java.text.SimpleDateFormat;
import java.util.Date;

import com.alicom.mns.tools.inter.DefaultAlicomMessagePuller;
import com.alicom.mns.tools.inter.MessageListener;
import com.aliyun.mns.model.Message;

/**
 * これは、SMS MNS キューメッセージ消費のデモです
 * MessageType: SmsReport
 */
public class ReceiveDemo {


    static class MyMessageListener implements MessageListener {
        @Override
        public boolean dealMessage(Message message) {

            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            System.out.println("message receiver time from mns:" + format.format(new Date()));
            System.out.println("message handle: " + message.getReceiptHandle());
            System.out.println("message body: " + message.getMessageBodyAsString());
            System.out.println("message id: " + message.getMessageId());
            System.out.println("message dequeue count:" + message.getDequeueCount());
            System.out.println("Thread:" + Thread.currentThread().getName());
            try {
                // ここから独自のコードを開始してください

            } catch (Throwable e) {
                // 独自のコードによって引き起こされた例外。メッセージは削除されず、再度取得できます
                return false;
            }
            // フォーマットエラーの場合、メッセージは削除されます
            return true;
        }

    }

    public static void main(String[] args) {

        DefaultAlicomMessagePuller puller = new DefaultAlicomMessagePuller();

        // 非同期スレッドのサイズを設定します
        puller.setConsumeMinThreadSize(6);
        puller.setConsumeMaxThreadSize(16);
        puller.setThreadQueueSize(200);
        puller.setPullMsgThreadSize(1);
        // デバッグ時にのみ有効にし、稼働状態では無効にする必要があります
        puller.openDebugLog(false);

        String regionIdForPop = "ap-southeast-1";
        String endpointNameForPop = "ap-southeast-1";

        // シンガポールリージョンの OpenAPI (ドメイン: dysmsapi.ap-southeast-1.aliyuncs.com) に SMS リクエストを送信する場合
        // 以下を使用してください
        String domainForPop = "dybaseapi.ap-southeast-1.aliyuncs.com";
        String mnsAccountEndpoint = "http://1493622401794734.mns.ap-southeast-1.aliyuncs.com";

        // インドネシア (ジャカルタ) リージョンの OpenAPI (ドメイン: dysmsapi.ap-southeast-5.aliyuncs.com) に SMS リクエストを送信する場合
        // 以下を使用してください
        //String domainForPop = "dybaseapi.ap-southeast-5.aliyuncs.com";
        //String mnsAccountEndpoint = "http://1493622401794734.mns.ap-southeast-5.aliyuncs.com";

        // ドイツ (フランクフルト) リージョンの OpenAPI (ドメイン: dysmsapi.eu-central-1.aliyuncs.com) に SMS リクエストを送信する場合
        //String domainForPop = "dybaseapi.eu-central-1.aliyuncs.com";
        //String mnsAccountEndpoint = "http://1493622401794734.mns.eu-central-1.aliyuncs.com";

        // 米国東部 (バージニア) リージョンの OpenAPI (ドメイン: dysmsapi.us-east-1.aliyuncs.com) に SMS リクエストを送信する場合
        //String domainForPop = "dybaseapi.us-east-1.aliyuncs.com";
        //String mnsAccountEndpoint = "http://1493622401794734.mns.us-east-1.aliyuncs.com";

        // AccessKey と SecretKey は Alibaba Cloud コンソールから取得できます
        String accessKeyId = "";
        String accessKeySecret = "";

        //SmsReport
        String messageType = "SmsReport";

        // QueueName は Alibaba Cloud SMS コンソールから取得できます
        // パターン: Alicom-Queue-{UID}-{messageType}
        String queueName = "";

        puller.startReceiveMsgForVPC(accessKeyId, accessKeySecret, messageType, queueName, regionIdForPop,
            endpointNameForPop, domainForPop, mnsAccountEndpoint, new MyMessageListener());

        // または、IAcsClient を初期化します (accessKeySecret 不要)
        //puller.startReceiveMsg(acsClient, messageType, queueName, new MyMessageListener(), mnsAccountEndpoint);
    }

}