import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
private boolean initializeConnection() throws KeystoreException,
		CommunicationException {
	if (keystore != null) {
		AppleNotificationServer server = new AppleNotificationServerBasicImpl(
				keystore, PASSWORD, PRODUCTION);

		pushManager.initializeConnection(server);
		isConnected = true;
	} else {
		isConnected = false;
	}

	return isConnected;
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
private void initializeConnection() throws KeystoreException, CommunicationException {
  AppleNotificationServer server = new AppleNotificationServerBasicImpl(
      keystore, password, production);

  pushManager.initializeConnection(server);
  isConnected = true;
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
public PushNotificationTemplate(AppleNotificationServer appleNotificationServer) {
    this.pool = new ConcurrentHolderLinkedPool<PushNotificationManager>(
            new PushNotificationManagerCreator(appleNotificationServer),
            Runtime.getRuntime().availableProcessors(),
            Runtime.getRuntime().availableProcessors() * 4, false);

}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
public APNSClient(AppleNotificationServer appleNotificationServer) {
    GenericObjectPool.Config config = new GenericObjectPool.Config();
    config.testOnBorrow = true;
    config.testOnReturn = true;
    config.testWhileIdle = true;
    config.minIdle = 1;
    config.maxIdle = Runtime.getRuntime().availableProcessors();
    config.maxActive = Runtime.getRuntime().availableProcessors() * 4;

    this.pool = new PushNotificationManagerPool(config, appleNotificationServer);
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
private void initializeConnection() throws KeystoreException, CommunicationException {
  AppleNotificationServer server =
          new AppleNotificationServerBasicImpl(keystore, password, production);

  pushManager.initializeConnection(server);
  isConnected = true;
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
@Override
	public void pushAll4Apple(MsgEntity msgEntity) {
		//群推线程数
		String	pushThreads = ResourceUtil.getConfigByName("applePushAllThread");
		//p12文件地址
		String	appleP12Path = ResourceUtil.getConfigByName("appleP12Path");
		//p12文件密码
		String	appleP12Pwd = ResourceUtil.getConfigByName("appleP12Pwd");
		//苹果推送服务器选择，true为正式服务器，false为开发者服务器
		String	applePushServer = ResourceUtil.getConfigByName("applePushServer");
		try {
			// 建立与Apple服务器连接
			AppleNotificationServer server = new AppleNotificationServerBasicImpl(
					appleP12Path, appleP12Pwd, Boolean.parseBoolean(applePushServer));
			List<PayloadPerDevice> list = new ArrayList<PayloadPerDevice>();
			// 获取要推送的tokenlist
			List<AppleTokenEntity> tokenList = commonDao.loadAll(AppleTokenEntity.class);
			for (AppleTokenEntity tokenEntity : tokenList) {
				Gson gson = new Gson();
				String msg = gson.toJson(msgEntity);
				StringBuilder sb=new StringBuilder();
				PushNotificationPayload payload = new PushNotificationPayload();
				sb.append("{'title':").append(msgEntity.getTitle()).append(",'body':").append(msgEntity.getContent()).append("}");
				payload.addBadge(0);// 图标小红圈的数值
				payload.addCustomAlertBody(msgEntity.getContent());
				payload.addCustomDictionary("data", msg);
//				payload.addCustomDictionary("content-available", 1);
				PayloadPerDevice pay = new PayloadPerDevice(payload,
						tokenEntity.getToken());// 将要推送的消息和手机唯一标识绑定
				list.add(pay);
			}
			NotificationThreads work = new NotificationThreads(server, list,
					Integer.parseInt(pushThreads));//
			work.setListener(DEBUGGING_PROGRESS_LISTENER);// 对线程的监听，一定要加上这个监听
			work.start(); // 启动线程
			work.waitForAllThreads();// 等待所有线程启动完成

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

	}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
public PushNotificationManagerPool(
        Config config, AppleNotificationServer appleNotificationServer) {
    super(new PushNotificationManagerFactory(appleNotificationServer), config);
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
private PushNotificationManagerFactory(AppleNotificationServer appleNotificationServer) {
    this.appleNotificationServer = appleNotificationServer;
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
public PushNotificationManagerCreator(AppleNotificationServer appleNotificationServer) {
    this.appleNotificationServer = appleNotificationServer;
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
@Override
public AppleNotificationServer getObject() throws Exception {
    return new AppleNotificationServerBasicImpl(keystore.getFile(), password, type, host, port);
}
 

import javapns.notification.AppleNotificationServer; //导入依赖的package包/类
@Override
public Class<?> getObjectType() {
    return AppleNotificationServer.class;
}