packagenet;importcom.baidu.yun.channel.auth.ChannelKeyPair;importcom.baidu.yun.channel.client.BaiduChannelClient;importcom.baidu.yun.channel.exception.ChannelClientException;importcom.baidu.yun.channel.exception.ChannelServerException;importcom.baidu.yun.channel.model.PushBroadcastMessageRequest;importcom.baidu.yun.channel.model.PushBroadcastMessageResponse;importcom.baidu.yun.channel.model.PushUnicastMessageRequest;importcom.baidu.yun.channel.model.PushUnicastMessageResponse;importcom.baidu.yun.core.log.YunLogEvent;importcom.baidu.yun.core.log.YunLogHandler;publicclassTestPushMessage{/***测试推送*/publicstaticvoidmain(String[]args){Stringstring="{\"title\":\"你有新消息\",\"description\":\"今天下午全体员工发奖金\","+"\"notification_builder_id\":0,\"notification_basic_style\":2,\"custom_content\":{\"id\":\"485446\"},\"open_type\":\"2\"}";//Stringstring="hello";//intstatus=pushBroadcastMessage(string,3,1);intstatus=pushOnlyPleploMessage(string,3,1);System.out.println(status);}/***初始化百度推送*/privatestaticBaiduChannelClientinitPushClient(){//这两个key自己申请StringapiKey="自己申请的apikey";StringsecretKey="自己申请的secretKey";//1.设置developer平台的ApiKey/SecretKeyChannelKeyPairpair=newChannelKeyPair(apiKey,secretKey);//2.创建BaiduChannelClient对象实例BaiduChannelClientchannelClient=newBaiduChannelClient(pair);//3.若要了解交互细节，请注册YunLogHandler类channelClient.setChannelLogHandler(newYunLogHandler(){@OverridepublicvoidonHandle(YunLogEventevent){System.out.println(event.getMessage());}});returnchannelClient;}/***用百度推送向所有人发送消息或者通知*/publicstaticintpushBroadcastMessage(StringContent,intdevType,intpushType){BaiduChannelClientchannelClient=initPushClient();try{//4.创建请求类对象PushBroadcastMessageRequestrequest=newPushBroadcastMessageRequest();//devType=>1:web2:pc3:android4:ios5:wprequest.setDeviceType(devType);//pushType为0设置发送消息，为1设置发送通知request.setMessageType(pushType);request.setMessage(Content);//5.调用pushMessage接口PushBroadcastMessageResponseresponse=channelClient.pushBroadcastMessage(request);//6.认证推送成功System.out.println("认证推送成功pushamount:"+response.getSuccessAmount());returnresponse.getSuccessAmount();}catch(ChannelClientExceptione){//处理客户端错误异常e.printStackTrace();return2;}catch(ChannelServerExceptione){//处理服务端错误异常System.out.println(String.format("request_id:%d,error_code:%d,error_message:%s",e.getRequestId(),e.getErrorCode(),e.getErrorMsg()));return3;}}/***向单个人推送消息或者通知*@return*/publicstaticintpushOnlyPleploMessage(StringContent,intdevType,intpushType){BaiduChannelClientchannelClient=initPushClient();try{//4.创建请求类对象//手机端的ChannelId，手机端的UserId，用户需替换为自己的PushUnicastMessageRequestrequest=newPushUnicastMessageRequest();//devType=>1:web2:pc3:android4:ios5:wprequest.setDeviceType(devType);//ChannelId、UserId这两个为每个手机绑定的，根据需要自己填写，暂用11111111111111代替request.setChannelId(111111111111L);request.setUserId("111111111111111111");//request.setMessageType(pushType);//pushType为0时发送消息//request.setMessage("HelloChannel");request.setMessageType(pushType);//pushType为1时发送通知request.setMessage(Content);//5.调用pushMessage接口PushUnicastMessageResponseresponse=channelClient.pushUnicastMessage(request);//6.认证推送成功System.out.println("认证推送成功pushamount:"+response.getSuccessAmount());returnresponse.getSuccessAmount();}catch(ChannelClientExceptione){//处理客户端错误异常e.printStackTrace();return2;}catch(ChannelServerExceptione){//处理服务端错误异常System.out.println(String.format("request_id:%d,error_code:%d,error_message:%s",e.getRequestId(),e.getErrorCode(),e.getErrorMsg()));return3;}}}
