多线程推送 push JavaPNS 2.1

以前用的 javapns-jdk15-165.jar 不支持多线程。后来在网上找到新的一个jar，可以支持多线程发送，与大家分享一下，不知道写的对不对，不对的话请指出，多谢。

将消息以多线程方式推送到iPhone服务器，不知道写的对不对，我在本地上测试是没有问题的，如有疑问请留言。

以下项目所用的jar包：

JavaPNS_2.1.jar

bcprov-jdk16-145-1.jar

log4j-1.2.15.jar

只记得这几个jar，如果不对，请留言我在看一下，多谢指正

JavaPNS_2.1.jar 地址

http://code.google.com/p/javapns/ 

 

public static void main(String[] args){
    String keystore = "D:/XXXXXXXX/XXX.p12";//证书路径和证书名
    String password = "XXXXXXXX"; // 证书密码
    String token = "XXXXXX XXXXXX XXXXXX XXXXXX XXXXXX XXXXXX XXXXXX XXXXXX";// 手机唯一标识
    boolean production = true; // 设置true为正式服务地址，false为开发者地址
    int threadThreads = 10; // 线程数
try {
        // 建立与Apple服务器连接
        AppleNotificationServer server = new AppleNotificationServerBasicImpl(keystore, password, production  );
	List<PayloadPerDevice> list = new ArrayList<PayloadPerDevice>();
	PushNotificationPayload payload = new PushNotificationPayload();
	payload.addAlert("推送内容");
	payload.addSound("default");// 声音
        payload.addBadge(1);//图标小红圈的数值
	payload.addCustomDictionary("url","www.baidu.com");// 添加字典 
	PayloadPerDevice pay = new PayloadPerDevice(payload,token);// 将要推送的消息和手机唯一标识绑定
	list.add(pay);

        NotificationThreads work = new NotificationThreads(server,list,threadThreads);// 
	work.setListener(DEBUGGING_PROGRESS_LISTENER);// 对线程的监听，一定要加上这个监听
	work.start(); // 启动线程
	work.waitForAllThreads();// 等待所有线程启动完成

 } catch (Exception e) {
	e.printStackTrace();
		}
}

 

 

// 线程监听
public static final NotificationProgressListener DEBUGGING_PROGRESS_LISTENER = new NotificationProgressListener() {
		public void eventThreadStarted(NotificationThread notificationThread) {
			System.out.println("   [EVENT]: thread #" + notificationThread.getThreadNumber() + " started with " + " devices beginning at message id #" + notificationThread.getFirstMessageIdentifier());
		}
		public void eventThreadFinished(NotificationThread thread) {
			System.out.println("   [EVENT]: thread #" + thread.getThreadNumber() + " finished: pushed messages #" + thread.getFirstMessageIdentifier() + " to " + thread.getLastMessageIdentifier() + " toward "+ " devices");
		}
		public void eventConnectionRestarted(NotificationThread thread) {
			System.out.println("   [EVENT]: connection restarted in thread #" + thread.getThreadNumber() + " because it reached " + thread.getMaxNotificationsPerConnection() + " notifications per connection");
		}
		public void eventAllThreadsStarted(NotificationThreads notificationThreads) {
			System.out.println("   [EVENT]: all threads started: " + notificationThreads.getThreads().size());
		}
		public void eventAllThreadsFinished(NotificationThreads notificationThreads) {
			System.out.println("   [EVENT]: all threads finished: " + notificationThreads.getThreads().size());
		}
		public void eventCriticalException(NotificationThread notificationThread, Exception exception) {
			System.out.println("   [EVENT]: critical exception occurred: " + exception);
		}
	 };

 

 

 

评论

12 楼 鐜嬫旦 2013-04-02  

这玩意不行啊，2.2版本支持群发，还有我们针对推送不成功的设备怎么处理？

11 楼 estn_h 2012-12-18  

LZ这个在2.2里面已经全部实现了直接调用这个方法就OK！Push.payloads(p12, "com.scpii.app33166", true, 10, payloadPerDevicesList); 
谢谢你的文章！

10 楼 java-cn 2012-10-25  

请问楼主这个bcprov-jdk16-145-1.jar包，在哪里用到了？？

9 楼 moon198654 2012-09-12  

楼主，有两个问题不知道你思考过没：
第一个，一般这种推送消息什么时候产生我们是不可预知的，为了保证消息的实时性，苹果API里提供的多线程只能在我们有大量消息产生，并且有阻塞的时候才会用它的API，所以我们自己肯定要实现一套线程模型去处理实时消息。并且消息要按“队列”推送，保证客户端收到的数是正确的，比如我给同一台iphone并发推送1、2、3、4，并发推送时要保证到达顺序也是这个，javapns里实现了这个机制，但我不太清楚它是怎么实现的。
第二个，如果我们实现实时推送，是否每次都要去读那个证书，然后推送，这样读证书操作会浪费很多性能。能不能读出来一直放在内存里，没此要推从内存拿。

8 楼 kevinsong331331 2012-06-06  

我执行的时候，老是报以下错误的！

[[16777217] not transmitted to token 78368..2e0f4  javapns.communication.exceptions.InvalidCertificateChainException: Invalid certificate chain (Received fatal alert: certificate_unknown)!  Verify that the keystore you provided was produced according to specs...]

7 楼 xytdman 2012-04-19  

请教一个问题，你这种方案适合一次向N多用户发送通知，我这边的应用场景是当这个用户有新的留言的时候向该用户推送通知，也就是说我每次推送只给一个用户，如果5000个用户在留言的话，我的并发将非常高，每次与apns建立连接就推一条然后连接就断开，这样效率是否太低了，能否有什么方案可以解决

6 楼 w54653520 2012-04-09  

你可以先试一下效率，不过两千到一万应该是没有问题，如果有问题的话，最好自己写与苹果服务器的通信了，先了解一下苹果服务器的特性

5 楼 jiafu0773 2012-03-26  

jiafu0773 写道

正是需要的，非常感谢，现在JavaPNS更新到2.2了

但我还有一个问题，假若我的线程达到两千甚至上万的话，会怎么样？

4 楼 jiafu0773 2012-03-26  

正是需要的，非常感谢，现在JavaPNS更新到2.2了

3 楼 kanhai001 2012-03-19  

kanhai001 写道

非常感谢.正是所需要的.

2 楼 kanhai001 2012-03-19  

非常感谢.正是所需要的.

1 楼 javajiangyijin 2012-03-05  

非常感谢!