㈠ JPush java API单例模式多线程报错,JPush可以用单例吗
单例也不能保证100%线程安全的。解决方法就是创建实例方法中加入Java关键字synchronized。
Java语言的关键字synchronized,可用来给对象和方法或者代码块加锁,当它锁定一个方法或者一个代码块的时候,同一时刻最多只有一个线程执行这段代码。当两个并发线程访问同一个对象object中的这个加锁同步代码块时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。然而,当一个线程访问object的一个加锁代码块时,另一个线程仍然可以访问该object中的非加锁代码块。
㈡ java做消息推送
JPush 是经过考验的大规模 APP 推送平台,每天推送消息数超过 5 亿条。开发者集成 SDK 后,可以通过调用 API 推送消息。同时,JPush 提供可视化的 Web 端控制台发送通知,统计分析推送效果。JPush 全面支持 android, iOS, Winphone 三大手机平台。㈢ 如何利用Java语言实现消息推送到手机app
首先APP后台就得有这样的轮询程序,比如每次打开app时触发,比如每隔10分钟触发,每次触发就调用下服务器端的服务,服务端去拉取要推送的信息,或者知道对方的手机号或微信号,那就直接调用短信接口或直接发送微信信息了。㈣ java如何推送消息给前端
Java服务器推送消息给前端主要方法:㈤ java消息定时推送怎么实现
定时任务实现的几种方式:㈥ java极光推送怎么调用自定义消息接口
// 对android和ios设备发送
JPushClient jpush = new JPushClient(masterSecret, appKey);
// 对android和ios设备发送,同时指定离线消息保存时间
JPushClient jpush = new JPushClient(masterSecret, appKey, timeToLive);
// 指定某种设备发送
JPushClient jpush = new JPushClient(masterSecret, appKey, DeviceEnum.Android);
// 指定某种设备发送,并且指定离线消息保存时间
JPushClient jpush = new JPushClient(masterSecret, appKey, timeToLive, DeviceEnum.IOS);
㈦ Java web 服务端消息推送用什么比较好
Java web 服务端消息推送用极光推送就不错,效率很高。极光推送搭建起一个高度稳定、可扩展的云端架构,极大地帮助移动应用开发者节约开发和维护的成本,轻松实现毫秒级的精准推送。㈧ java怎样远程调用 jpush 提供的服务
开发的时候需要引用appache的包commons-httpclient.jar 、commons-codec.jar、commons-logging.jar这些包可以到官网上下载,如果有需要的话也我也可以发给你。
引入上述这些包之后,就可以进行开发了。
这里需要特别说明的两点是:
1、通过 HttpClient client = new DefaultHttpClient(); 获得HttpClient对象不支持https,需要自己重写。
2、我们的MD5编码要和服务器那边的一样。(我用我自己写的MD5编码验证的时候,总是验证失败,后来跟他们的技术人员要了他们的md5的实现方式就通过验证了)
好了,废话不多说了,接下来是贴代码的时候了:
类MySSLSocketFactory用来实现对https的支持
[java] view plain
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.security.KeyManagementException;
import java.security.KeyStore;
import java.security.KeyStoreException;
㈨ java 如何实现系统消息推送
消息推送方式分为两种:短连接和长连接。也就是客户端与服务器之间的数据传输交互方式不同。㈩ jpush推送java后台怎么调用
原创作品,可以转载,但是请标注出处地址http://www.cnblogs.com/V1haoge/p/6439313.html
Java后台实现极光推送有两种方式,一种是使用极光推送官方提供的推送请求API:https://api.jpush.cn/v3/push,另一种则是使用官方提供的第三方Java SDK,这里先进行第一种方式推送的实现代码:
importorg.apache.http.HttpResponse;
importorg.apache.http.client.HttpClient;
importorg.apache.http.client.methods.HttpPost;
importorg.apache.http.entity.StringEntity;
importorg.apache.http.impl.client.DefaultHttpClient;
importorg.apache.http.util.EntityUtils;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importcom.alibaba.fastjson.JSONArray;
importnet.sf.json.JSONObject;
importsun.misc.BASE64Encoder;
/**
*java后台极光推送方式一:使用HttpAPI
*此种方式需要自定义http请求发送客户端:HttpClient
*/
@SuppressWarnings({"deprecation","restriction"})
publicclassJiguangPush{
privatestaticfinalLoggerlog=LoggerFactory.getLogger(JiguangPush.class);
privateStringmasterSecret="xxxxxxxxxxxxxxxxxxxx";
privateStringappKey="xxxxxxxxxxxxxxxxxxx";
privateStringpushUrl="https://api.jpush.cn/v3/push";
privatebooleanapns_proction=true;
privateinttime_to_live=86400;
privatestaticfinalStringALERT="推送信息";
/**
*极光推送
*/
publicvoidjiguangPush(){
Stringalias="123456";//声明别名
try{
Stringresult=push(pushUrl,alias,ALERT,appKey,masterSecret,apns_proction,time_to_live);
JSONObjectresData=JSONObject.fromObject(result);
if(resData.containsKey("error")){
log.info("针对别名为"+alias+"的信息推送失败!");
JSONObjecterror=JSONObject.fromObject(resData.get("error"));
log.info("错误信息为:"+error.get("message").toString());
}
log.info("针对别名为"+alias+"的信息推送成功!");
}catch(Exceptione){
log.error("针对别名为"+alias+"的信息推送失败!",e);
}
}
/**
*组装极光推送专用json串
*@paramalias
*@paramalert
*@returnjson
*/
(Stringalias,Stringalert,booleanapns_proction,inttime_to_live){
JSONObjectjson=newJSONObject();
JSONArrayplatform=newJSONArray();//平台
platform.add("android");
platform.add("ios");
JSONObjectaudience=newJSONObject();//推送目标
JSONArrayalias1=newJSONArray();
alias1.add(alias);
audience.put("alias",alias1);
JSONObjectnotification=newJSONObject();//通知内容
JSONObjectandroid=newJSONObject();//android通知内容
android.put("alert",alert);
android.put("builder_id",1);
JSONObjectandroid_extras=newJSONObject();//android额外参数
android_extras.put("type","infomation");
android.put("extras",android_extras);
JSONObjectios=newJSONObject();//ios通知内容
ios.put("alert",alert);
ios.put("sound","default");
ios.put("badge","+1");
JSONObjectios_extras=newJSONObject();//ios额外参数
ios_extras.put("type","infomation");
ios.put("extras",ios_extras);
notification.put("android",android);
notification.put("ios",ios);
JSONObjectoptions=newJSONObject();//设置参数
options.put("time_to_live",Integer.valueOf(time_to_live));
options.put("apns_proction",apns_proction);
json.put("platform",platform);
json.put("audience",audience);
json.put("notification",notification);
json.put("options",options);
returnjson;
}
/**
*推送方法-调用极光API
*@paramreqUrl
*@paramalias
*@paramalert
*@returnresult
*/
publicstaticStringpush(StringreqUrl,Stringalias,Stringalert,StringappKey,StringmasterSecret,booleanapns_proction,inttime_to_live){
Stringbase64_auth_string=encryptBASE64(appKey+":"+masterSecret);
Stringauthorization="Basic"+base64_auth_string;
returnsendPostRequest(reqUrl,generateJson(alias,alert,apns_proction,time_to_live).toString(),"UTF-8",authorization);
}
/**
*发送Post请求(json格式)
*@paramreqURL
*@paramdata
*@paramencodeCharset
*@paramauthorization
*@returnresult
*/
@SuppressWarnings({"resource"})
(StringreqURL,Stringdata,StringencodeCharset,Stringauthorization){
HttpPosthttpPost=newHttpPost(reqURL);
HttpClientclient=newDefaultHttpClient();
HttpResponseresponse=null;
Stringresult="";
try{
StringEntityentity=newStringEntity(data,encodeCharset);
entity.setContentType("application/json");
httpPost.setEntity(entity);
httpPost.setHeader("Authorization",authorization.trim());
response=client.execute(httpPost);
result=EntityUtils.toString(response.getEntity(),encodeCharset);
}catch(Exceptione){
log.error("请求通信["+reqURL+"]时偶遇异常,堆栈轨迹如下",e);
}finally{
client.getConnectionManager().shutdown();
}
returnresult;
}
/**
*BASE64加密工具
*/
(Stringstr){
byte[]key=str.getBytes();
BASE64Encoderbase64Encoder=newBASE64Encoder();
Stringstrs=base64Encoder.encodeBuffer(key);
returnstrs;
}
}
以上代码中使用的是第一种方式实现推送,下面介绍第二种方式:使用java SDK
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importcn.jiguang.common.ClientConfig;
importcn.jiguang.common.resp.APIConnectionException;
importcn.jiguang.common.resp.APIRequestException;
importcn.jpush.api.JPushClient;
importcn.jpush.api.push.PushResult;
importcn.jpush.api.push.model.Options;
importcn.jpush.api.push.model.Platform;
importcn.jpush.api.push.model.PushPayload;
importcn.jpush.api.push.model.audience.Audience;
importcn.jpush.api.push.model.notification.AndroidNotification;
importcn.jpush.api.push.model.notification.IosNotification;
importcn.jpush.api.push.model.notification.Notification;
/**
*java后台极光推送方式二:使用JavaSDK
*/
@SuppressWarnings({"deprecation","restriction"})
publicclassJiguangPush{
privatestaticfinalLoggerlog=LoggerFactory.getLogger(JiguangPush.class);
="xxxxxxxxxxxxxxxxx";
privatestaticStringappKey="xxxxxxxxxxxxxxxx";
privatestaticfinalStringALERT="推送信息";
/**
*极光推送
*/
publicvoidjiguangPush(){
Stringalias="123456";//声明别名
log.info("对别名"+alias+"的用户推送信息");
PushResultresult=push(String.valueOf(alias),ALERT);
if(result!=null&&result.isResultOK()){
log.info("针对别名"+alias+"的信息推送成功!");
}else{
log.info("针对别名"+alias+"的信息推送失败!");
}
}
/**
*生成极光推送对象PushPayload(采用javaSDK)
*@paramalias
*@paramalert
*@returnPushPayload
*/
_android_ios_alias_alert(Stringalias,Stringalert){
returnPushPayload.newBuilder()
.setPlatform(Platform.android_ios())
.setAudience(Audience.alias(alias))
.setNotification(Notification.newBuilder()
.addPlatformNotification(AndroidNotification.newBuilder()
.addExtra("type","infomation")
.setAlert(alert)
.build())
.addPlatformNotification(IosNotification.newBuilder()
.addExtra("type","infomation")
.setAlert(alert)
.build())
.build())
.setOptions(Options.newBuilder()
.setApnsProction(false)//true-推送生产环境false-推送开发环境(测试使用参数)
.setTimeToLive(90)//消息在JPush服务器的失效时间(测试使用参数)
.build())
.build();
}
/**
*极光推送方法(采用javaSDK)
*@paramalias
*@paramalert
*@returnPushResult
*/
publicstaticPushResultpush(Stringalias,Stringalert){
ClientConfigclientConfig=ClientConfig.getInstance();
JPushClientjpushClient=newJPushClient(masterSecret,appKey,null,clientConfig);
PushPayloadpayload=buildPushObject_android_ios_alias_alert(alias,alert);
try{
returnjpushClient.sendPush(payload);
}catch(APIConnectionExceptione){
log.error("Connectionerror.Shouldretrylater.",e);
returnnull;
}catch(APIRequestExceptione){
log.error("ErrorresponsefromJPushserver.Shouldreviewandfixit.",e);
log.info("HTTPStatus:"+e.getStatus());
log.info("ErrorCode:"+e.getErrorCode());
log.info("ErrorMessage:"+e.getErrorMessage());
log.info("MsgID:"+e.getMsgId());
returnnull;
}
}
}
可以看出使用Java SDK实现推送的方式很简单,代码量也少,理解起来也不难,官方提供的SDK中讲很多内容都实现了,我们只是需要配置一下信息,然后发起推送即可。需要注意的是使用第二种方式,需要导入极光官网提供的jar包。
直接在maven中的pom文件中加入:
<dependency>
<groupId>cn.jpush.api</groupId>
<artifactId>jpush-client</artifactId>
<version>3.2.15</version>
</dependency>
原本我们项目中也是采用第二种方式实现的,但是最后在提交代码时发现一个问题,那就是虽然我们只是带入了官网提供的那三个jar包,但是最后一统计,竟然无缘无故增多了80+个jar包,如此多的jar包提交过于臃肿,而且不现实,所以才临时改变方案,采用第一种方式进行编码。
代码中采用的是别名方式进行推送,需要在在手机APP端进行别名设置,最好就是在用户登录之后就设置好,这样只要用户登录一次,它的绑定别名就可以保存到极光服务器,而我们推送时,指定这个别名,就能将信息推送到对应用户的手机上。
其实我们发起推送请求,只是将信息发送到了极光服务器之上,这个信息有一个保存时限,默认一天,只要用户登录手机APP,极光服务器就会将信息自动推送到对应别名的手机上,由此可见,信息并非由我们后天直接推送到手机,而是通过极光服务器这个中转站,而这正式极光的工作。