Short Message Service：Demo konsumsi Lightweight Message Queue (sebelumnya MNS)

Demo 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;

/**
 * Ini adalah DEMO untuk konsumsi pesan Antrian MNS SMS
 * 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("waktu penerimaan pesan dari mns:" + format.format(new Date()));
            System.out.println("handle pesan: " + message.getReceiptHandle());
            System.out.println("isi pesan: " + message.getMessageBodyAsString());
            System.out.println("ID pesan: " + message.getMessageId());
            System.out.println("jumlah dequeue pesan:" + message.getDequeueCount());
            System.out.println("Thread:" + Thread.currentThread().getName());
            try {
                //Silakan tambahkan kode Anda di sini

            } catch (Throwable e) {
                // Exception yang disebabkan oleh kode Anda sendiri. Pesan tidak akan dihapus dan dapat diambil kembali
                return false;
            }
            // Pesan akan dihapus karena kesalahan format
            return true;
        }

    }

    public static void main(String[] args) {

        DefaultAlicomMessagePuller puller = new DefaultAlicomMessagePuller();

        //Atur ukuran thread asinkron
        puller.setConsumeMinThreadSize(6);
        puller.setConsumeMaxThreadSize(16);
        puller.setThreadQueueSize(200);
        puller.setPullMsgThreadSize(1);
        //Hanya diaktifkan saat debugging, harus dinonaktifkan dalam status produksi
        puller.openDebugLog(false);

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

        //Jika Anda mengirim permintaan SMS ke OpenAPI Wilayah Singapura (domain: dysmsapi.ap-southeast-1.aliyuncs.com)
        //Silakan gunakan
        String domainForPop = "dybaseapi.ap-southeast-1.aliyuncs.com";
        String mnsAccountEndpoint = "http://1493622401794734.mns.ap-southeast-1.aliyuncs.com";

        //Jika Anda mengirim permintaan SMS ke OpenAPI Wilayah Indonesia (Jakarta) (domain: dysmsapi.ap-southeast-5.aliyuncs.com)
        //Silakan gunakan
        //String domainForPop = "dybaseapi.ap-southeast-5.aliyuncs.com";
        //String mnsAccountEndpoint = "http://1493622401794734.mns.ap-southeast-5.aliyuncs.com";

        //Jika Anda mengirim permintaan SMS ke OpenAPI Wilayah Jerman (Frankfurt) (domain: dysmsapi.eu-central-1.aliyuncs.com)
        //String domainForPop = "dybaseapi.eu-central-1.aliyuncs.com";
        //String mnsAccountEndpoint = "http://1493622401794734.mns.eu-central-1.aliyuncs.com";

        //Jika Anda mengirim permintaan SMS ke OpenAPI Wilayah AS Timur (Virginia) (domain: dysmsapi.us-east-1.aliyuncs.com)
        //String domainForPop = "dybaseapi.us-east-1.aliyuncs.com";
        //String mnsAccountEndpoint = "http://1493622401794734.mns.us-east-1.aliyuncs.com";

        //AccessKey dan SecretKey dapat Anda peroleh dari Alibaba Cloud Console
        String accessKeyId = "";
        String accessKeySecret = "";

        //SmsReport
        String messageType = "SmsReport";

        //Nama Antrian dapat Anda peroleh dari Alibaba Cloud Sms Console
        //Pola: Alicom-Queue-{UID}-{messageType}
        String queueName = "";

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

        //atau inisialisasi IAcsClient Anda sendiri (tanpa accessKeySecret)
        //puller.startReceiveMsg(acsClient, messageType, queueName, new MyMessageListener(), mnsAccountEndpoint);
    }

}