Java微信公众平台之群发接口(高级群发)
再次吐槽下,微信素材管理和群发这块文档对Java很不友好,此文需要结合我前文和官方文档。
测试号调试群发只需看是否群发消息是否能组装成功,不需要看结果如何(反正不会发送成功的),因为微信还没开放这个功能(估计也不会开放的)。
一、群发说明
在公众平台网站上,为订阅号提供了每天一条的群发权限,为服务号提供每月(自然月)4条的群发权限。
1、对于认证订阅号,群发接口每天可成功调用1次,此次群发可选择发送给全部用户或某个标签;
2、对于认证服务号虽然开发者使用高级群发接口的每日调用限制为100次,但是用户每月只能接收4条,无论在公众平台网站上,还是使用接口群发,用户每月只能接收4条群发消息,多于4条的群发将对该用户发送失败;
3、开发者可以主动设置clientmsgid来避免重复推送。
4、群发接口每分钟限制请求60次,超过限制的请求会被拒绝。
5、图文消息正文中插入自己帐号和其他公众号已群发文章链接的能力。
二、群发图文消息过程
1、首先,预先将图文消息中需要用到的图片,使用上传图文消息内图片接口,上传成功并获得图片URL;参考前文的上传图文消息内的图片获取URL方法
2、上传图文消息素材,需要用到图片时,请使用上一步获取的图片URL;
3、使用对用户标签的群发,或对OpenID列表的群发,将图文消息群发出去,群发时微信会进行原创校验,并返回群发操作结果;
4、在上述过程中,如果需要,还可以预览图文消息、查询群发状态,或删除已群发的消息等。
三、群发图片、文本等其他消息类型的过程
1、如果是群发文本消息,则直接根据下面的接口说明进行群发即可;
2、如果是群发图片、视频等消息,则需要预先通过素材管理接口准备好mediaID。
四、is_to_all说明
用于设定是否向全部用户发送,值为true或false,选择true该消息群发给所有用户,选择false可根据tag_id发送给指定群组的用户。
五、两种群发方式
根据标签进行群发,订阅号与服务号必须通过认证
接口:https://api.weixin.qq.com/cgi-bin/message/mass/sendall?access_token=ACCESS_TOKEN
根据OpenID列表群发,只适用于认证后的服务号
接口:https://api.weixin.qq.com/cgi-bin/message/mass/send?access_token=ACCESS_TOKEN
post数据可以是图文消息、文本、语音/音频、图片、视频、卡券消息(所有使用到media_id的地方,现在都可以使用素材管理中的永久素材media_id了)
1、图文消息post数据中的media_id需要通过上传图文消息素材接口获取(https://api.weixin.qq.com/cgi-bin/media/uploadnews?access_token=ACCESS_TOKEN)
这个跟素材管理里的新增永久图文素材接口post数据一样,只是接口不一样、返回的json多了一个type和created_at,参考我前文的新增永久图文素材方法
2、语音/音频、图片post数据中的media_id需要通过上传下载多媒体文件接口获得,参考我前文的新增临时/永久素材方法
3、视频post数据中的media_id最麻烦,先得通过上传下载多媒体文件接口获取到media_id(经测试,永久的下一步报错提示无效media_id),然后再通过特别接口再获取到一个media_id,这才是群发所需要的media_id
六、群发示例Controller
@RequestMapping("/sendByOpenid") publicMassMsgResultsendByOpenid()throwsException{ //根据OpenID列表群发图文消息 StringmediaPath1="C:/Users/phil/Pictures/image/8538572f61d7a94cf0b9fe0f290cdb28.jpg"; UploadMediasResultresult1=HttpReqUtil.uploadTempMedia("phil_token","image",mediaPath1); StringmediaPath2="C:/Users/phil/Pictures/image/685977abgw1f8xqp46dgyj20qo0zktfi.jpg"; UploadMediasResultresult2=HttpReqUtil.uploadTempMedia("phil_token","image",mediaPath2); Listarray=newArrayList<>(); UploadNewsMediaentity1=newUploadNewsMedia(); entity1.setAuthor("phil"); entity1.setContent("人生只有经历才会懂得,只有懂得才知道珍惜,一生中,总会有一个人让你笑得最甜,也总会有一个人让你痛得最深,忘记,是善待自己"); entity1.setContent_source_url("http://blog.csdn.net/phil_jing"); //entity1.setDigest("digest"); entity1.setShow_conver_pic(1); entity1.setThumb_media_id(result1.getMedia_id()); entity1.setTitle("心灵鸡汤"); array.add(entity1); UploadNewsMediaentity2=newUploadNewsMedia(); entity2.setAuthor("phil"); entity2.setContent("什么是幸福,幸福就是自己的一种愉快的心理状态和感受。时时、事事都能使自己快乐的人才是最幸福的人。最快乐的人,就是最幸福的人。笑口常开的人,是最幸福的。"); entity2.setContent_source_url("http://www.qq.com"); //entity2.setDigest("digest"); entity2.setShow_conver_pic(0); entity2.setThumb_media_id(result2.getMedia_id()); entity2.setTitle("经典语录"); array.add(entity2); UploadMediasResultur=HttpReqUtil.uploadNewsMedia("phil_token",array); List openids=newArrayList<>(); openids.add("ovHQ5v9-ZsHUcax_nTCQwiP-sBcg"); openids.add("ovHQ5v6CW3INkWUsCl3olODif0cc"); MassMsgResultresult_news=wechatMsgService.sendMpnewsToOpenid("phil_token",openids, ur.getMedia_id()); logger.debug("sendbyopenidmsg{}",result_news.getErrmsg()); //根据OpenID列表群发文字消息 MassMsgResultresult_text=wechatMsgService.sendTextToOpenid("phil_token",openids, "什么是幸福,幸福就是自己的一种愉快的心理状态和感受。时时、事事都能使自己快乐的人才是最幸福的人。最快乐的人,就是最幸福的人。笑口常开的人,是最幸福的"); logger.debug("sendbyopenidmsg{}",result_text.getErrmsg()); returnnull; }
七、部分用到的类和方法
群发方法
/** *根据标签进行群发文本消息 *@paramaccessToken授权token *@paramentity图文消息对象 *@return */ publicMassMsgResultsendTextToTag(StringaccessToken,inttagId,Stringcontent){ MassMsgResultresult=null; TreeMapparams=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map filterParams=newHashMap<>(); filterParams.put("is_to_all",false); filterParams.put("tag_id",tagId); Map textParams=newHashMap<>(); textParams.put("content",content); TreeMap dataParams=newTreeMap<>(); dataParams.put("filter",filterParams); dataParams.put("text",textParams); dataParams.put("msgtype","text"); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_ALL_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据标签进行群发图文消息 *@paramaccessToken授权token *@paramtagId标签 *@parammediaIduploadMedia方法获得 *@return */ publicMassMsgResultsendMpnewsToTag(StringaccessToken,inttagId,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map filterParams=newHashMap<>(); filterParams.put("is_to_all",false); filterParams.put("tag_id",tagId); Map mpnewsParams=newHashMap<>(); mpnewsParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("filter",filterParams); dataParams.put("mpnews",mpnewsParams); dataParams.put("msgtype","mpnews"); dataParams.put("send_ignore_reprint",0);//不能省略 Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_ALL_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据标签进行群发图片 *@paramaccessToken授权token *@paramtagId标签 *@parammediaIduploadMedia方法获得 *@return */ publicMassMsgResultsendImageToTag(StringaccessToken,inttagId,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map filterParams=newHashMap<>(); filterParams.put("is_to_all",false); filterParams.put("tag_id",tagId); Map imageParams=newHashMap<>(); imageParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("filter",filterParams); dataParams.put("image",imageParams); dataParams.put("msgtype","image"); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_ALL_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据标签进行群发语音/音频 *@paramaccessToken授权token *@paramtagId标签 *@parammediaIduploadMedia方法获得 *@return */ publicMassMsgResultsendVoiceToTag(StringaccessToken,inttagId,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map filterParams=newHashMap<>(); filterParams.put("is_to_all",false); filterParams.put("tag_id",tagId); Map voiceParams=newHashMap<>(); voiceParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("filter",filterParams); dataParams.put("voice",voiceParams); dataParams.put("msgtype","voice"); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_ALL_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据标签进行群发视频 *@paramaccessToken授权token *@paramtagId标签 *@parammediaIduploadMedia方法获得 *@return */ publicMassMsgResultsendVideoToTag(StringaccessToken,inttagId,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map filterParams=newHashMap<>(); filterParams.put("is_to_all",false); filterParams.put("tag_id",tagId); Map mpvideoParams=newHashMap<>(); mpvideoParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("filter",filterParams); dataParams.put("mpvideo",mpvideoParams); dataParams.put("msgtype","mpvideo"); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_ALL_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据标签进行群发卡券 *@paramaccessToken授权token *@paramtagId标签 *@paramcard_id *@return */ publicMassMsgResultsendWxCardToTag(StringaccessToken,inttagId,StringcardId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map filterParams=newHashMap<>(); filterParams.put("is_to_all",false); filterParams.put("tag_id",tagId); Map wxcardParams=newHashMap<>(); wxcardParams.put("card_id",cardId); TreeMap dataParams=newTreeMap<>(); dataParams.put("filter",filterParams); dataParams.put("wxcard",wxcardParams); dataParams.put("msgtype","wxcard"); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_ALL_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据OpenId进行群发图文消息 *@paramaccessToken授权token *@paramtagId标签 *@parammediaIduploadMedia方法获得 *@return */ publicMassMsgResultsendMpnewsToOpenid(StringaccessToken,List openids,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map mpnewsParams=newHashMap<>(); mpnewsParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("touser",openids); dataParams.put("mpnews",mpnewsParams); dataParams.put("msgtype","mpnews"); dataParams.put("send_ignore_reprint",0); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据OpenId进行群发文本消息 *@paramaccessToken授权token *@paramopenidsopenid *@paramcontent *@return */ publicMassMsgResultsendTextToOpenid(StringaccessToken,List openids,Stringcontent){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map textParams=newHashMap<>(); textParams.put("content",content); TreeMap dataParams=newTreeMap<>(); dataParams.put("touser",openids); dataParams.put("text",textParams); dataParams.put("msgtype","text"); Stringdata=JsonUtil.toJsonString(dataParams); System.out.println(data); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据OpenId进行群发语音消息 *@paramaccessToken授权token *@paramopenidsopenid *@parammediaId *@return */ publicMassMsgResultsendVocieToOpenid(StringaccessToken,List openids,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map voiceParams=newHashMap<>(); voiceParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("touser",openids); dataParams.put("voice",voiceParams); dataParams.put("msgtype","voice"); Stringdata=JsonUtil.toJsonString(dataParams); System.out.println(data); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据OpenId进行群发图片消息 *@paramaccessToken授权token *@paramopenidsopenid *@parammediaId *@return */ publicMassMsgResultsendImageToOpenid(StringaccessToken,List openids,StringmediaId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map imageParams=newHashMap<>(); imageParams.put("media_id",mediaId); TreeMap dataParams=newTreeMap<>(); dataParams.put("touser",openids); dataParams.put("image",imageParams); dataParams.put("msgtype","image"); Stringdata=JsonUtil.toJsonString(dataParams); System.out.println(data); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据OpenId进行群发视频消息 *@paramaccessToken授权token *@paramopenidsopenid *@parammpVideoMediauploadMediaVideo方法获得media *@return */ publicMassMsgResultsendVideoToOpenid(StringaccessToken,List openids,MpVideoMediampVideoMedia){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 TreeMap dataParams=newTreeMap<>(); dataParams.put("touser",openids); dataParams.put("mpvideo",mpVideoMedia); dataParams.put("msgtype","mpvideo"); Stringdata=JsonUtil.toJsonString(dataParams); System.out.println(data); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; } /** *根据OpenId进行群发卡券消息 *@paramaccessToken授权token *@paramopenidsopenid *@parammediaId *@return */ publicMassMsgResultsendWxcardToOpenid(StringaccessToken,List openids,StringcardId){ MassMsgResultresult=null; TreeMap params=newTreeMap<>(); params.put("access_token",accessToken); //post提交的参数 Map wxcardParams=newHashMap<>(); wxcardParams.put("card_id",cardId); TreeMap dataParams=newTreeMap<>(); dataParams.put("touser",openids); dataParams.put("wxcard",wxcardParams); dataParams.put("msgtype","wxcard"); Stringdata=JsonUtil.toJsonString(dataParams); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.SEND_MASS_MESSAGE_URL,params,data); try{ result=JsonUtil.fromJsonString(json,MassMsgResult.class); }catch(Exceptione){ e.printStackTrace(); } returnresult; }
视频post数据bean
/** *视频post数据bean *@authorphil *@date2017年9月20日 * */ publicclassMpVideoMedia{ privateStringmedia_id; privateStringtitle; privateStringdescription; }
获取群发视频post中的media_id
/** *获取群发视频post中的media_id * *@paramaccessToken *@paramuploadVideo *@return */ publicstaticUploadMediasResultuploadMediaVideo(StringaccessToken,MpVideoMediampVideoMedia){ UploadMediasResultresult=null; TreeMapparams=newTreeMap (); params.put("access_token",accessToken); //post提交的参数 Stringdata=JsonUtil.toJsonString(mpVideoMedia); Stringjson=HttpReqUtil.HttpsDefaultExecute(SystemConfig.POST_METHOD,WechatConfig.UPLOAD_VIDEO_MEDIA_URL, params,data); result=JsonUtil.fromJsonString(json,UploadMediasResult.class); returnresult; }
群发返回的结果
packagecom.phil.wechat.msg.model.resp; importcom.phil.wechat.base.result.ResultState; /** *群发消息返回的结果 *根据OpenID列表群发 *@authorphil *@date2017年7月2日 * */ publicclassMassMsgResultextendsResultState{ privateStringtype;//媒体文件类型,分别有图片(image)、语音(voice)、视频(video)和缩略图(thumb),次数为news,即图文消息 privateStringmsg_id; privateStringmsg_data_id; }
配置类
//按分组进行群发 publicstaticfinalStringSEND_ALL_MASS_MESSAGE_URL="https://api.weixin.qq.com/cgi-bin/message/mass/sendall"; //按照openid进行群发消息(OpenID最少2个,最多10000个10000个) publicstaticfinalStringSEND_MASS_MESSAGE_URL="https://api.weixin.qq.com/cgi-bin/message/mass/send"; //上传图文消息素材 publicstaticfinalStringUPLOAD_NEWS_MEDIA_URL="https://api.weixin.qq.com/cgi-bin/media/uploadnews"; //获取群发视频post中的media_id publicstaticfinalStringUPLOAD_VIDEO_MEDIA_URL="https://api.weixin.qq.com/cgi-bin/media/uploadvideo";
关于源码,希望帮到了你
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。