不寫發簡訊的方法了,這個搜一下一大把

呼叫接收佇列方法,也是對照官方的demo

 @Autowired
    private MessageUp messageUp;

    @RequestMapping("/message_phone/getMessage.do")
    public String getMessage(){
        try {
            DefaultAlicomMessagePuller puller=new DefaultAlicomMessagePuller();
            String messageType="SmsUp";
            String accessKeyId="xxxxxxxxxxxx";
            String accessKeySecret="xxxxxxxxxxxxxxxxxxx";
            String queueName="Alicom-Queue-xxxxxxxxxxxxxxxx-SmsUp";
            puller.startReceiveMsg
                    (accessKeyId,accessKeySecret ,messageType,queueName , messageUp);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "redirect:HZ/v_list.do";
    }

工具類:

@Component
    public class MessageUp implements MessageListener {
        private Gson gson=new Gson();

        @Autowired
        private RsMessagePhoneMng rsMessagePhoneMng;

        @Override
        public boolean dealMessage(Message message){
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            try{
                Map<String,Object> contentMap=gson.fromJson(message.getMessageBodyAsString(), HashMap.class);
                String phoneNumber=(String)contentMap.get("phone_number");
                String sendTime=(String)contentMap.get("send_time");
                String content = (String) contentMap.get("content");
                //System.out.println("接收到簡訊回執:手機號"+phoneNumber+"傳送時間:"+sendTime+"內容:"+content);
                    List<RsMessagephoneEntity> phone_number = rsMessagePhoneMng.findByPhone(phoneNumber);
                    if (null != phone_number.get(0)){
                        //System.out.println("查詢到手機號");
                        RsMessagephoneEntity bean = phone_number.get(0);
                        Date datel = bean.getRsMessagephonereplyTime();
                        Date parse = format.parse(sendTime);
                        bean.setRsMessagephoneStatus("已回覆");
                        bean.setRsMessagephoneReply(content);
                        bean.setRsMessagephonereplyTime(parse);
                        rsMessagePhoneMng.update(bean);
                        //System.out.println("更新回執內容over");
                    }
            }catch(com.google.gson.JsonSyntaxException e){
                //logger.error("error_json_format:"+message.getMessageBodyAsString(),e);
                //理論上不會出現格式錯誤的情況，所以遇見格式錯誤的訊息，只能先delete,否則重新推送也會一直報錯
                return true;
            } catch (Throwable e) {
                //您自己的程式碼部分導致的異常，應該return false,這樣訊息不會被delete掉，而會根據策略進行重推
                return false;
            }
            //訊息處理成功，返回true, SDK將呼叫MNS的delete方法將訊息從佇列中刪除掉
            return true;
        }
    }
 

注意jar包版本一定要正確

否則報ArrayStoreException,而且搜不到為什麼 坑...