集群推送第二版修改，调整P端增删改路由关系，M端查询等操作

display-server/src/main/webapp/biz/js/more/push/PushDemo.js

@@ -21,22 +21,21 @@ require(["domReady!","wadeMobile","mobile","util"],function(doc,WadeMobile,Mobil
				$("#devicePart").css("display","block"); 
				var map = new Wade.DataMap();
				map.put("account", info);
				// 用户权限校验的数据
				map.put("userName", "chengwb3");
				map.put("passWord", "123456");
				// 请求M，返回ip+port
				var url = "http://192.168.253.1:8080/push-manager-server/wlwdata";//也可以通过配置文件读取，获取数据库读取，待修正 add by chengwb3
				var action = "ServerBean.getBestServer";
				Mobile.dataRequestWithHost(url,action,null,function(data){
				Mobile.dataRequestWithHost(url,action,map.toString(),function(data){
					data = typeof(data) == "string" ? new Wade.DataMap(data) : data;
					map.put("serverId", data.get("server").get("serverId"));//serverId
					map.put("address", data.get("server").get("host"));// 请求M端获取
					map.put("port", data.get("server").get("port"));// 请求M端获取
					map.put("httpPort", data.get("server").get("http_port"));// http服务端端口
					map.put("serverName", data.get("server").get("server_name"));// 项目部署名称
					map.put("servletDataRequestName", data.get("server").get("servlet_data_request_name"));// 项目数据请求的serlet的名称
					map.put("serverId", data.get("server").get("server_id"));//serverId
					// 测试数据替换，因只有一个推送服务端push-server
					map.put("address", "192.168.253.1");
					map.put("port", "7070");
					map.put("httpPort", data.get("server").get("httpPort"));// http服务端端口
					map.put("serverName", data.get("server").get("serverName"));// 项目部署名称
					map.put("servletDataRequestName", data.get("server").get("servletDataRequestName"));// 项目数据请求的serlet的名称
					// 推送注册
					alert("开始注册");
					WadeMobile.registerForPush(map.toString(),function(msg){
						WadeMobile.tip(msg);
					},function(msg){

push-manager-server/src/main/java/com/ai/ipu/biz/bean/PMSMessageAction.java

@@ -1,11 +1,12 @@
package com.ai.ipu.biz.bean;
import java.util.Set;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.string.StringUtil;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.biz.core.bean.IpuAppBean;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
import com.ai.ipu.pushmanager.cache.PushRouteCacheManager;
import com.ai.ipu.pushmanager.util.PushUtil;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
@@ -13,6 +14,8 @@ import com.ailk.common.data.impl.DataMap;
import com.ailk.common.data.impl.DatasetList;
public class PMSMessageAction extends IpuAppBean {
    
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(PMSMessageAction.class);
    /**
     * 根据account列表推送消息，可以是一个或者多个account
@@ -27,7 +30,7 @@ public class PMSMessageAction extends IpuAppBean {
        if (StringUtil.isJSONArray(accountSetStr)) {
            IDataset accountSet = new DatasetList(accountSetStr);
            if (accountSet == null || accountSet.size() == 0) {
                IpuUtility.error("is not expected json format or has no account");
                throw new IpuBaseException("is not expected json format or has no account");
            }
            PushUtil.pushToAccountSet(accountSet, content, false, true);
        } else {
@@ -37,23 +40,23 @@ public class PMSMessageAction extends IpuAppBean {
        return null;
    }
    public IData sendTextMessageToAllAccounts(IData param) throws Exception {
        String content = param.getString("content");
        PushUtil.pushToAllAccount(content, false, true);
        return null;
    }
    // public IData sendTextMessageToAllAccounts(IData param) throws Exception {
    // String content = param.getString("content");
    // PushUtil.pushToAllAccount(content, false, true);
    // return null;
    // }
    public IData getPushServerStatus(IData param) throws Exception {
        IData result = new DataMap();
        IDataset pushServerList = BizDataCacheManager.getPushServerListCache();
        IData pushServer;
        String serverId = null;
        Set<String> pushServerAccountSzet;
        int accountSizze;
        for (int i = 0; i < pushServerList.size(); i++) {
            pushServer = pushServerList.getData(i);
            serverId = pushServer.getString("server_id");
            pushServerAccountSzet = BizDataCacheManager.getPushServerAccountsCache(serverId);
            result.put(BizDataCacheManager.PUSH_SERVER_ACCOUNTS_PREFIX + serverId + "_size", pushServerAccountSet.size());
            serverId = pushServer.getString("serverId");
            accountSizze = BizDataCacheManager.getPushServerAccountsSize(serverId);
            result.put(BizDataCacheManager.PUSH_SERVER_ACCOUNTS_SIZE_PREFIX + serverId, accountSize);
        }
        return result;
    }

push-manager-server/src/main/java/com/ai/ipu/biz/bean/RouteBean.java

@@ -1,9 +1,9 @@
package com.ai.ipu.biz.bean;
import com.ai.ipu.biz.core.bean.IpuAppBean;
import com.ai.ipu.pushmanager.route.DefaultRouteManager;
import com.ai.ipu.pushmanager.route.IRouteManager;
import com.ai.ipu.pushmanager.route.Route;
import com.ai.ipu.pushmanager.route.impl.DefaultRouteManager;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;

push-manager-server/src/main/java/com/ai/ipu/biz/bean/ServerBean.java

@@ -1,16 +1,34 @@
package com.ai.ipu.biz.bean;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.biz.core.bean.IpuAppBean;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
import com.ai.ipu.pushmanager.loadbalancing.ILoadBalancing;
import com.ai.ipu.pushmanager.loadbalancing.impl.WeightRandomLoadBalancing;
import com.ai.ipu.pushmanager.usermanager.DefaultUserManager;
import com.ai.ipu.pushmanager.usermanager.IUserManager;
import com.ai.ipu.server.config.MobileConfig;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DataMap;
public class ServerBean extends IpuAppBean {
    
    public IData getBestServer(IData param) throws Exception{
    /**
     * C向M请求最佳P
     * 
     * @param param
     * @return
     * @throws Exception
     */
    public IData getBestServer(IData param) throws Exception {
        // 用户权限校验
        // 可能使用个，可能不使用。要通过配置文件注入
        String userPermissionsCheck = MobileConfig.getValue("userPermissionsCheck", "false");
        if("true".equals(userPermissionsCheck)){
            IUserManager userManager = new DefaultUserManager();
            userManager.verify(param.getString("account"), param);//用户连接权限验证
        }
        IData result = new DataMap();
        // 用户是否可以获取ip+port的验证
        IDataset list = BizDataCacheManager.getPushServerListCache();
@@ -20,4 +38,37 @@ public class ServerBean extends IpuAppBean {
        result.put("flag", "success");
        return result;
    }
    /**
     * P启动时候，向M注册信息
     */
    public IData addServer(IData param) throws Exception {
        String serverId = param.getString("serverId");
        boolean containsPushServer = BizDataCacheManager.containsPushServer(serverId);
        if (containsPushServer) {
            String msg = "serverId[" + serverId + "]的push-server已经存在，请检查。";
            throw new IpuBaseException(msg);
        }
        IDataset pushList = BizDataCacheManager.getPushServerListCache();
        IData pushServerObj = new DataMap();
        pushServerObj.put("serverId", param.getString("serverId"));
        pushServerObj.put("host", param.getString("host"));
        pushServerObj.put("name", param.getString("name"));
        pushServerObj.put("port", param.getString("port"));
        pushServerObj.put("weight", param.getString("weight"));
        pushServerObj.put("httpPort", param.getString("httpPort"));
        pushServerObj.put("serverName", param.getString("serverName"));
        pushServerObj.put("servletDataRequestName", param.getString("servletDataRequestName"));
        pushList.add(pushServerObj);
        BizDataCacheManager.putPushServerListCache(pushList);
        IData result = new DataMap();
        result.put("flag", "success");
        return result;
    }
    public IData deleteServer(IData param) {
        //
        return null;
    }
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/cache/BizDataCacheManager.java

@@ -3,25 +3,22 @@ package com.ai.ipu.pushmanager.cache;
import java.util.HashSet;
import java.util.Set;
import org.apache.log4j.Logger;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.biz.dao.ServerDao;
import com.ai.ipu.biz.util.Constant;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.util.PushConstant;
import com.ai.ipu.server.cache.CacheFactory;
import com.ai.ipu.server.cache.intf.ICache;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DataMap;
import com.ailk.common.data.impl.DatasetList;
/**
 * 业务数据缓存管理类
 */
public class BizDataCacheManager {
    private static transient Logger log = Logger.getLogger(BizDataCacheManager.class);
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(BizDataCacheManager.class);
    private static final String BIZ_DATA_CACHE = PushConstant.BIZ_DATA_CACHE;
@@ -29,6 +26,10 @@ public class BizDataCacheManager {
    public static final String PUSH_SERVER_ACCOUNTS_PREFIX = PushConstant.PUSH_SERVER_ACCOUNTS_PREFIX; // value:Set<String>
    public static final String AVAILABLE_ACCOUNTS = PushConstant.AVAILABLE_ACCOUNTS; // 用于P端用户有效性二次验证的集合，value:Set<String>
    public static final String PUSH_SERVER_ACCOUNTS_SIZE_PREFIX = PushConstant.PUSH_SERVER_ACCOUNTS_SIZE_PREFIX; // push-server链接account的数量,value:int
    public static ICache getBizDataCache() throws Exception {
        return CacheFactory.getCache(BIZ_DATA_CACHE);
    }
@@ -44,36 +45,64 @@ public class BizDataCacheManager {
                if (null != getBizDataCache().get(PUSH_SERVER_LIST)) {// 避免时间差
                    return (IDataset) getBizDataCache().get(PUSH_SERVER_LIST);
                }
                putPushServerListCache();
                initPushServerListCache();
            }
        }
        return (IDataset) getBizDataCache().get(PUSH_SERVER_LIST);
    }
    public static boolean containsPushServer(String serverId) throws Exception {
        if (null == serverId) {
            throw new IpuBaseException("serverId is null.");
        }
        IDataset list = getPushServerListCache();
        if (list.isEmpty()) {
            return false;
        }
        IData pushServer;
        for (int i = 0; i < list.size(); i++) {
            pushServer = list.getData(i);
            if (serverId.equals(pushServer.getString("serverId"))) {
                return true;
            }
        }
        return false;
    }
    /**
     * 读取数据库，初始化数据
     */
    private static void putPushServerListCache() throws Exception {
        ServerDao dao = new ServerDao(Constant.connName);
        IData param = new DataMap();
        param.put("STATE", Constant.Server.STATE_AVAILABLE);
        IDataset list = dao.getServerList(param);
        if (list == null || list.isEmpty()) {
            IpuLogger.error(log, "tab_server表未找到数据.");
            IpuUtility.error("tab_server表未找到数据.");
        }
        getBizDataCache().put(PUSH_SERVER_LIST, list);
    // private static void initPushServerListCache() throws Exception {
    // ServerDao dao = new ServerDao(Constant.connName);
    // IData param = new DataMap();
    // param.put("STATE", Constant.Server.STATE_AVAILABLE);
    // IDataset list = dao.getServerList(param);
    // if (list == null || list.isEmpty()) {
    // IpuLogger.error(log, "tab_server表未找到数据.");
    // IpuUtility.error("tab_server表未找到数据.");
    // }
    // getBizDataCache().put(PUSH_SERVER_LIST, list);
    //
    // IpuLogger.debug(log, "初始化" + PUSH_SERVER_LIST + "成功.");
    // }
        IpuLogger.debug(log, "初始化" + PUSH_SERVER_LIST + "成功.");
    /**
     * 初始化P的列表，应该是主动扫描P的列表
     */
    private static void initPushServerListCache() throws Exception {
        // 待处理。。。
        log.debug("待处理，初始化扫描可用的P的列表");
        IDataset list = new DatasetList();
        getBizDataCache().put(PUSH_SERVER_LIST, list);
    }
    /**
     * 主动更改缓存，用于数据库tab_server表变动
     */
    protected static void putPushServerListCache(IDataset list) throws Exception {
    public static void putPushServerListCache(IDataset list) throws Exception {
        getBizDataCache().put(PUSH_SERVER_LIST, list);
        IpuLogger.debug(log, "主动更改" + PUSH_SERVER_LIST + "成功.");
        log.debug("更改" + PUSH_SERVER_LIST + "成功.");
    }
    /**
@@ -99,10 +128,10 @@ public class BizDataCacheManager {
     */
    public static void addAccountToPushServerAccountsId(String account, String serverId) throws Exception {
        Set<String> accountSet = getPushServerAccountsCache(serverId);
        IpuLogger.debug(log, "M add route, put before:key=" + (PUSH_SERVER_ACCOUNTS_PREFIX + serverId) + ",value=" + accountSet.toString());
        log.debug("M add route, put before:key=" + (PUSH_SERVER_ACCOUNTS_PREFIX + serverId) + ",value=" + accountSet.toString());
        accountSet.add(account);
        putPushServerAccountsCache(accountSet, serverId);
        IpuLogger.debug(log, "M add route, put after:key=" + (PUSH_SERVER_ACCOUNTS_PREFIX + serverId) + ",value=" + accountSet.toString());
        log.debug("M add route, put after:key=" + (PUSH_SERVER_ACCOUNTS_PREFIX + serverId) + ",value=" + accountSet.toString());
    }
@@ -112,10 +141,63 @@ public class BizDataCacheManager {
    public static void removeAccountToPushServerAccountsId(String account, String serverId) throws Exception {
        Set<String> accountSet = getPushServerAccountsCache(serverId);
        if (null == accountSet || !accountSet.contains(account)) {
            IpuLogger.debug(log, "has not this account [" + account + "] on this " + serverId + "server");
            log.debug("has not this account [" + account + "] on this " + serverId + "server");
            return;
        }
        accountSet.remove(account);
        putPushServerAccountsCache(accountSet, serverId);
    }
    public static void addAvailableAccount(String account) throws Exception {
        if (getAvailableAccountSet().contains(account)) {
            // account已经存在了
            log.debug("account[" + account + "] already exists.");
        }
        Set<String> accountSet = getAvailableAccountSet();
        accountSet.add(account);
        putAvailableAccountSet(accountSet);
    }
    @SuppressWarnings("unchecked")
    public static Set<String> getAvailableAccountSet() throws Exception {
        if (null == getBizDataCache().get(AVAILABLE_ACCOUNTS)) {
            return new HashSet<String>();
        }
        return (Set<String>) getBizDataCache().get(AVAILABLE_ACCOUNTS);
    }
    public static void putAvailableAccountSet(Set<String> accountSet) throws Exception {
        getBizDataCache().put(AVAILABLE_ACCOUNTS, accountSet);
    }
    public static boolean containsAvailableAccount(String account) throws Exception {
        return getAvailableAccountSet().contains(account);
    }
    public static void increasePushServerAccountsSize(String serverId) throws Exception {
        int size = getPushServerAccountsSize(serverId);
        putPushServerAccountsSize(serverId, size + 1);
        log.debug("Number of server connections plus one");
    }
    public static void decreasePushServerAccountsSize(String serverId) throws Exception {
        int size = getPushServerAccountsSize(serverId);
        if (size < 1) {
            throw new IpuBaseException("The number of current connected account is less than one.");
        }
        putPushServerAccountsSize(serverId, size - 1);
        log.debug("Number of server connections minus one");
    }
    private static void putPushServerAccountsSize(String serverId, int accountsSize) throws Exception {
        getBizDataCache().put(PUSH_SERVER_ACCOUNTS_PREFIX + serverId, accountsSize);
    }
    public static int getPushServerAccountsSize(String serverId) throws Exception {
        if (null == getBizDataCache().get(PUSH_SERVER_ACCOUNTS_SIZE_PREFIX + serverId)) {
            return 0;
        }
        return (Integer) getBizDataCache().get(PUSH_SERVER_ACCOUNTS_SIZE_PREFIX + serverId);
    }
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/cache/PushRouteCacheManager.java

@@ -1,9 +1,8 @@
package com.ai.ipu.pushmanager.cache;
import org.apache.log4j.Logger;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.route.Route;
import com.ai.ipu.pushmanager.util.PushConstant;
import com.ai.ipu.server.cache.CacheFactory;
@@ -14,7 +13,7 @@ import com.ai.ipu.server.cache.intf.ICache;
 */
public class PushRouteCacheManager {
    private static transient Logger log = Logger.getLogger(PushRouteCacheManager.class);
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(PushRouteCacheManager.class);
    private static final String PUSH_ROUTE_CACHE = PushConstant.PUSH_ROUTE_CACHE;
@@ -26,23 +25,24 @@ public class PushRouteCacheManager {
        if (null == getPushRouteCache().get(account)) {
            return null;
        }
        return (Route) getPushRouteCache().get(account);
        return new Route(getPushRouteCache().get(account).toString());
    }
    public static void putRoute(String account, Route route) throws Exception {
        if (null == route) {
            IpuLogger.error(log, "route is null.");
            IpuUtility.error("route is null.");
        if (null == account || "".equals(account) || null == route) {
            throw new IpuBaseException("account or route is null.");
        }
        getPushRouteCache().put(account, route);
        getPushRouteCache().put(account, route.toString());
        log.debug("set key=[" + account + "] route success.");
    }
    public static void removeRoute(String account) throws Exception {
        if (null == getRoute(account)) {
            IpuLogger.debug(log, "this route account [" + account + "] is null.");
            log.debug("this route account [" + account + "] is null.");
            return;
        }
        getPushRouteCache().remove(account);
        log.debug("remove key=[" + account + "] route success.");
    }
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/loadbalancing/impl/HashLoadBalancing.java

@@ -17,7 +17,7 @@ public class HashLoadBalancing implements ILoadBalancing {
            return null;
        }
        Object obj = null;
        synchronized (pos) {
        synchronized (new Object()) {
            pos = pos > list.size() ? 0 : pos;
            obj = list.get(pos);
            pos++;

push-manager-server/src/main/java/com/ai/ipu/pushmanager/loadbalancing/impl/RoundLoadBalancing.java

@@ -2,7 +2,7 @@ package com.ai.ipu.pushmanager.loadbalancing.impl;
import java.util.List;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.loadbalancing.ILoadBalancing;
/**
@@ -18,7 +18,7 @@ public class RoundLoadBalancing implements ILoadBalancing {
            return null;
        }
        if (null == IP) {
            IpuUtility.error("IP为null");
            throw new IpuBaseException("IP为null");
        }
        int hashCode = IP.hashCode();
        int hashPosition = hashCode % list.size();

push-manager-server/src/main/java/com/ai/ipu/pushmanager/route/Route.java

@@ -2,7 +2,9 @@ package com.ai.ipu.pushmanager.route;
import java.io.Serializable;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ailk.common.data.impl.DataMap;
/**
@@ -210,7 +212,7 @@ public class Route extends DataMap implements Serializable {
                }
            }
        } else {
            IpuLogger.debug("无法解析，不是自定义解析格式。");
            throw new IpuBaseException("无法解析，不是自定义解析格式。");
        }
    }

push-manager-server/src/main/java/com/ai/ipu/pushmanager/route/DefaultRouteManager.java

@@ -1,15 +1,16 @@
package com.ai.ipu.pushmanager.route;
package com.ai.ipu.pushmanager.route.impl;
import org.apache.log4j.Logger;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
import com.ai.ipu.pushmanager.cache.PushRouteCacheManager;
import com.ai.ipu.pushmanager.route.IRouteManager;
import com.ai.ipu.pushmanager.route.Route;
import com.ai.ipu.server.cache.intf.ICache;
public class DefaultRouteManager implements IRouteManager {
    private static transient Logger log = Logger.getLogger(DefaultRouteManager.class);
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(DefaultRouteManager.class);
    @Override
    public void addRoute(String account, Route route) throws Exception {
@@ -36,10 +37,10 @@ public class DefaultRouteManager implements IRouteManager {
    public void removeRoute(String account) throws Exception {
        Route route = PushRouteCacheManager.getRoute(account);
        if (null == route) {
            IpuLogger.debug(log, "Not found this designated account of the Route.");
            log.debug("Not found this designated account of the Route.");
            return;
        }
        BizDataCacheManager.removeAccountToPushServerAccountsId(account, route.getServerId());
        BizDataCacheManager.decreasePushServerAccountsSize(route.getServerId());
        PushRouteCacheManager.removeRoute(account);
    }

push-manager-server/src/main/java/com/ai/ipu/pushmanager/route/impl/RouteManagerImpl.java

@@ -0,0 +1,58 @@
package com.ai.ipu.pushmanager.route.impl;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
import com.ai.ipu.pushmanager.cache.PushRouteCacheManager;
import com.ai.ipu.pushmanager.route.IRouteManager;
import com.ai.ipu.pushmanager.route.Route;
import com.ai.ipu.server.cache.intf.ICache;
/**
 * 路由关系管理实现类。 注：不保存push-server对象的account列表，只保存account的数量。
 */
public class RouteManagerImpl implements IRouteManager {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(RouteManagerImpl.class);
    @Override
    public void addRoute(String account, Route route) throws Exception {
        PushRouteCacheManager.putRoute(account, route);
        BizDataCacheManager.increasePushServerAccountsSize(route.getServerId());
    }
    @Override
    public Route getRoute(String account) throws Exception {
        return PushRouteCacheManager.getRoute(account);
    }
    @Override
    public ICache getRoutes() throws Exception {
        return PushRouteCacheManager.getPushRouteCache();
    }
    @Override
    public void removeRoute(Route route) throws Exception {
        removeRoute(route.getAccount());
    }
    @Override
    public void removeRoute(String account) throws Exception {
        Route route = PushRouteCacheManager.getRoute(account);
        if (null == route) {
            log.debug("Not found this designated account of the Route.");
            return;
        }
        BizDataCacheManager.decreasePushServerAccountsSize(route.getServerId());
        PushRouteCacheManager.removeRoute(account);
    }
    @Override
    public boolean containsRoute(Route route) throws Exception {
        if (null != PushRouteCacheManager.getPushRouteCache().get(route.getAccount())) {
            return true;
        }
        return false;
    }
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/usermanager/AbstractUserManager.java

@@ -0,0 +1,21 @@
package com.ai.ipu.pushmanager.usermanager;
import java.util.Map;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
public abstract class AbstractUserManager implements IUserManager {
    @Override
    public boolean verify(String account, Map<String, Object> map) throws Exception {
        if (account == null || "".equals(account)) {
            throw new IpuBaseException("account为空。");
        }
        if(customVerify(account, map)){
            // 把tokenId即account保存到memcache里面，用于P端的二次验证
            BizDataCacheManager.addAvailableAccount(account);
        }
        return false;
    }
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/usermanager/DefaultUserManager.java

@@ -0,0 +1,25 @@
package com.ai.ipu.pushmanager.usermanager;
import java.util.Map;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuBaseException;
public class DefaultUserManager extends AbstractUserManager{
    
    transient protected final static ILogger log = IpuLoggerFactory.createLogger(DefaultUserManager.class);
    
    @Override
    public boolean customVerify(String account, Map<String, Object> map) throws Exception{
        // 用户名和密码的校验
        String user = (String) map.get("userName");
        String passwd = (String) map.get("passWord");
        if(user!=null&&passwd!=null){
            log.debug("用户连接权限校验通过.");
            return true;
        }
        throw new IpuBaseException("用户连接权限校验失败.");
    }
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/usermanager/IUserManager.java

@@ -0,0 +1,16 @@
package com.ai.ipu.pushmanager.usermanager;
import java.util.Map;
public interface IUserManager {
    /**
     * 验证account有效性
     */
    public boolean verify(String account, Map<String, Object> map) throws Exception;
    /**
     * 自定义校验map
     */
    public boolean customVerify(String account, Map<String, Object> map) throws Exception;
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/util/AccountsGroup.java

@@ -1,6 +1,6 @@
package com.ai.ipu.pushmanager.util;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.route.Route;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DatasetList;
@@ -13,7 +13,11 @@ public class AccountsGroup {
    private String serverId;
    private IDataset accountSet = new DatasetList();
    
    public AccountsGroup(String serverId) {
        this.serverId = serverId;
    }
    public String getServerId() {
        return serverId;
    }
@@ -29,7 +33,7 @@ public class AccountsGroup {
    public void setAccountSet(IDataset accountSet) {
        this.accountSet = accountSet;
    }
    
    /**
     * 添加account
     */
@@ -38,12 +42,11 @@ public class AccountsGroup {
            return;
        }
        if (serverId == null) {
            IpuUtility.error("serverId is null");
            throw new IpuBaseException("serverId is null");
        }
        if (serverId.equals(route.getServerId())) {
            accountSet.add(route.getAccount());
        }
    }
    
}

push-manager-server/src/main/java/com/ai/ipu/pushmanager/util/PushConstant.java

@@ -16,6 +16,16 @@ public class PushConstant {
     * 业务数据缓存之一的前缀，+serverId即key，单个push-server的链接accounts列表
     */
    public static final String PUSH_SERVER_ACCOUNTS_PREFIX = "PUSH_SERVER_ACCOUNTS_"; // value:Set<String>
    
    /**
     * 业务数据缓存之一的前缀，+serverId即key，单个push-server链接account的数量
     */
    public static final String PUSH_SERVER_ACCOUNTS_SIZE_PREFIX = "PUSH_SERVER_ACCOUNTS_SIZE_"; // value:int
    
    /**
     * 业务数据缓存之一，是account的Set集合
     */
    public static final String AVAILABLE_ACCOUNTS = "AVAILABLE_ACCOUNTS"; // value:Set<String>
    /**
     * 路由缓存key，memcache.xml的cluster name

push-manager-server/src/main/java/com/ai/ipu/pushmanager/util/PushUtil.java

@@ -6,19 +6,17 @@ import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import org.apache.log4j.Logger;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
import com.ai.ipu.pushmanager.route.DefaultRouteManager;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.route.IRouteManager;
import com.ai.ipu.pushmanager.route.Route;
import com.ai.ipu.pushmanager.route.impl.DefaultRouteManager;
import com.ai.ipu.pushmanager.route.impl.RouteManagerImpl;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DataMap;
import com.ailk.common.data.impl.DatasetList;
/**
 * 推送工具类
@@ -28,7 +26,7 @@ import com.ailk.common.data.impl.DatasetList;
 */
public class PushUtil {
    private static transient Logger log = Logger.getLogger(PushUtil.class);
    transient protected final static ILogger log = IpuLoggerFactory.createLogger(PushUtil.class);
    /**
     * 推送给单个account
@@ -42,7 +40,7 @@ public class PushUtil {
     * @throws Exception
     */
    public static void pushToAccount(String account, String content, boolean isEncrypt) throws Exception {
        IRouteManager routeManager = new DefaultRouteManager();
        IRouteManager routeManager = new RouteManagerImpl();
        Route route = routeManager.getRoute(account);
        String ip = route.getHost();
        String httpPort = route.getHttpPort();
@@ -51,11 +49,10 @@ public class PushUtil {
        String url = "http://" + ip + ":" + httpPort + "/" + serverName + "/" + servletDataRequestName;
        IData dataParam = new DataMap();
        dataParam.put("CONTENT", content);
        dataParam.put("content", content);
        dataParam.put("accountSet", account);
        dataParam.put("SENDER", "system");
        Map<String, String> postData = new HashMap<String, String>();
        isEncrypt = false;
        if (isEncrypt) {
            /* 参数加密处理 */
            postData.put("action", "MessageAction.sendTextMessageToAccountSet");
@@ -78,9 +75,9 @@ public class PushUtil {
        }
        IData resultData = new DataMap(resultStr);
        if ("success".equals(resultData.getString("flag"))) {
            IpuLogger.debug("发送成功！");
            log.debug("单个account推送成功！");
        } else {
            IpuLogger.debug("发送失败！");
            log.debug("单个account推送失败！");
        }
    }
@@ -116,8 +113,7 @@ public class PushUtil {
            AccountsGroup ag;
            Iterator<String> it = serverIdSet.iterator();
            while (it.hasNext()) {
                ag = new AccountsGroup();
                ag.setServerId(it.next());
                ag = new AccountsGroup(it.next());
                for (int i = 0; i < accountSet.size(); i++) {
                    route = routeManager.getRoute(accountSet.get(i).toString());
                    ag.addRoute(route);
@@ -141,9 +137,8 @@ public class PushUtil {
     */
    public static void pushToAccountSetByServerId(IDataset accountSet, String content, boolean isEncrypt) throws Exception {
        if (accountSet == null || accountSet.isEmpty()) {
            IpuLogger.error(log, "not found effective accountSet : " + accountSet);
            IpuUtility.error("not found effective accountSet : " + accountSet);
            return;
            log.error("not found effective accountSet : " + accountSet);
            throw new IpuBaseException("not found effective accountSet : " + accountSet);
        }
        IRouteManager routeManager = new DefaultRouteManager();
        Route route = routeManager.getRoute(accountSet.get(0).toString());
@@ -154,7 +149,7 @@ public class PushUtil {
        String url = "http://" + ip + ":" + httpPort + "/" + serverName + "/" + servletDataRequestName;
        IData dataParam = new DataMap();
        dataParam.put("CONTENT", content);
        dataParam.put("content", content);
        dataParam.put("accountSet", accountSet.toString());
        dataParam.put("SENDER", "system");
        Map<String, String> postData = new HashMap<String, String>();
@@ -181,27 +176,9 @@ public class PushUtil {
        }
        IData resultData = new DataMap(resultStr);
        if ("success".equals(resultData.getString("flag"))) {
            IpuLogger.debug("发送成功！");
            log.debug("发送成功！");
        } else {
            IpuLogger.debug("发送失败！");
        }
    }
    /**
     * 推送所有account
     */
    public static void pushToAllAccount(String content, boolean isEncrypt, boolean isMerge) throws Exception {
        IDataset pushServerList = BizDataCacheManager.getPushServerListCache();
        IData pushServer;
        String serverId = null;
        Set<String> accountSet;
        IDataset accountDataset;
        for (int i = 0; i < pushServerList.size(); i++) {
            pushServer = pushServerList.getData(i);
            serverId = pushServer.getString("server_id");
            accountSet = BizDataCacheManager.getPushServerAccountsCache(serverId);
            accountDataset = new DatasetList(accountSet.toString());
            pushToAccountSetByServerId(accountDataset, content, false);
            log.debug("发送失败！");
        }
    }

push-manager-server/src/main/java/com/ai/ipu/pushmanager/util/PushUtilOld.java

@@ -0,0 +1,205 @@
package com.ai.ipu.pushmanager.util;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.pushmanager.cache.BizDataCacheManager;
import com.ai.ipu.pushmanager.route.IRouteManager;
import com.ai.ipu.pushmanager.route.Route;
import com.ai.ipu.pushmanager.route.impl.DefaultRouteManager;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DataMap;
import com.ailk.common.data.impl.DatasetList;
/**
 * 推送工具类
 * 
 * @author Administrator
 *
 */
public class PushUtilOld {
    transient protected final static ILogger log = IpuLoggerFactory.createLogger(PushUtilOld.class);
    /**
     * 推送给单个account
     * 
     * @param account
     *            账号
     * @param content
     *            推送内容
     * @param isEncrypt
     *            是否加密传输
     * @throws Exception
     */
    public static void pushToAccount(String account, String content, boolean isEncrypt) throws Exception {
        IRouteManager routeManager = new DefaultRouteManager();
        Route route = routeManager.getRoute(account);
        String ip = route.getHost();
        String httpPort = route.getHttpPort();
        String serverName = route.getServerName();
        String servletDataRequestName = route.getServletDataRequestName();
        String url = "http://" + ip + ":" + httpPort + "/" + serverName + "/" + servletDataRequestName;
        IData dataParam = new DataMap();
        dataParam.put("CONTENT", content);
        dataParam.put("accountSet", account);
        dataParam.put("SENDER", "system");
        Map<String, String> postData = new HashMap<String, String>();
        isEncrypt = false;
        if (isEncrypt) {
            /* 参数加密处理 */
            postData.put("action", "MessageAction.sendTextMessageToAccountSet");
            // postData.put("key", MobileSecurity.getDesKey());
            String encryptData = "";// 加密后的数据
            postData.put("data", encryptData);
        } else {
            postData.put("action", "MessageAction.sendTextMessageToAccountSet");
            postData.put("data", dataParam.toString());
        }
        String data = HttpTool.toQueryStringWithEncode(postData);
        String resultStr = HttpTool.httpRequest(url, data, "POST");
        if (isEncrypt) {
            /* 解密 */
            // result = MobileSecurity.responseDecrypt(resultStr);
        }
        if (resultStr.endsWith("\r")) {
            resultStr = resultStr.substring(0, resultStr.lastIndexOf("\r")); // 待测试，之前尾部没有“\r”？？？？？？？？？？？
        }
        IData resultData = new DataMap(resultStr);
        if ("success".equals(resultData.getString("flag"))) {
            log.debug("发送成功！");
        } else {
            log.debug("发送失败！");
        }
    }
    /**
     * 按照account的列表推送
     * 
     * @param accounts
     *            账号数据
     * @param content
     *            消息内容
     * @param isEncrypt
     *            是否加密传输
     * @param isMerge
     *            是否合并发送到推送端
     * @throws Exception
     */
    public static void pushToAccountSet(IDataset accountSet, String content, boolean isEncrypt, boolean isMerge) throws Exception {
        if (!isMerge) {// 不合并，单个发送
            for (int i = 0; i < accountSet.size(); i++) {
                pushToAccount(accountSet.get(i).toString(), content, isEncrypt);
            }
        } else {
            // accounts经过分类，分为多个accounts
            IRouteManager routeManager = new DefaultRouteManager();
            Route route;
            Set<String> serverIdSet = new HashSet<String>();
            for (int i = 0; i < accountSet.size(); i++) {
                route = routeManager.getRoute(accountSet.get(i).toString());
                if (!serverIdSet.contains(route.getServerId())) {
                    serverIdSet.add(route.getServerId());
                }
            }
            AccountsGroup ag;
            Iterator<String> it = serverIdSet.iterator();
            while (it.hasNext()) {
                ag = new AccountsGroup(it.next());
                for (int i = 0; i < accountSet.size(); i++) {
                    route = routeManager.getRoute(accountSet.get(i).toString());
                    ag.addRoute(route);
                }
                pushToAccountSetByServerId(ag.getAccountSet(), content, isEncrypt);
            }
        }
    }
    /**
     * 给指定服务端的指定account集合推送消息
     * 
     * @param accountSet
     *            account集合
     * @param content
     *            推送内容
     * @param isEncrypt
     *            是否加密
     * @throws Exception
     */
    public static void pushToAccountSetByServerId(IDataset accountSet, String content, boolean isEncrypt) throws Exception {
        if (accountSet == null || accountSet.isEmpty()) {
            log.error("not found effective accountSet : " + accountSet);
            throw new IpuBaseException("not found effective accountSet : " + accountSet);
        }
        IRouteManager routeManager = new DefaultRouteManager();
        Route route = routeManager.getRoute(accountSet.get(0).toString());
        String ip = route.getHost();
        String httpPort = route.getHttpPort();
        String serverName = route.getServerName();
        String servletDataRequestName = route.getServletDataRequestName();
        String url = "http://" + ip + ":" + httpPort + "/" + serverName + "/" + servletDataRequestName;
        IData dataParam = new DataMap();
        dataParam.put("CONTENT", content);
        dataParam.put("accountSet", accountSet.toString());
        dataParam.put("SENDER", "system");
        Map<String, String> postData = new HashMap<String, String>();
        isEncrypt = false;
        if (isEncrypt) {
            /* 参数加密处理 */
            postData.put("action", "MessageAction.sendTextMessageToAccountSet");
            // postData.put("key", MobileSecurity.getDesKey());
            String encryptData = "";// 加密后的数据
            postData.put("data", encryptData);
        } else {
            postData.put("action", "MessageAction.sendTextMessageToAccountSet");
            postData.put("data", dataParam.toString());
        }
        String data = HttpTool.toQueryStringWithEncode(postData);
        String resultStr = HttpTool.httpRequest(url, data, "POST");
        if (isEncrypt) {
            /* 解密 */
            // result = MobileSecurity.responseDecrypt(resultStr);
        }
        if (resultStr.endsWith("\r")) {
            resultStr = resultStr.substring(0, resultStr.lastIndexOf("\r")); // 待测试，之前尾部没有“\r”？？？？？？？？？？？
        }
        IData resultData = new DataMap(resultStr);
        if ("success".equals(resultData.getString("flag"))) {
            log.debug("发送成功！");
        } else {
            log.debug("发送失败！");
        }
    }
    /**
     * 推送所有account
     */
    public static void pushToAllAccount(String content, boolean isEncrypt, boolean isMerge) throws Exception {
        IDataset pushServerList = BizDataCacheManager.getPushServerListCache();
        IData pushServer;
        String serverId = null;
        Set<String> accountSet;
        IDataset accountDataset;
        for (int i = 0; i < pushServerList.size(); i++) {
            pushServer = pushServerList.getData(i);
            serverId = pushServer.getString("serverId");
            accountSet = BizDataCacheManager.getPushServerAccountsCache(serverId);
            accountDataset = new DatasetList(accountSet.toString());
            pushToAccountSetByServerId(accountDataset, content, false);
        }
    }
}

push-manager-server/src/main/resources/memcache.xml

@@ -10,7 +10,7 @@
            <address master="127.0.0.1:11211" />
        </cluster>
        
		<!-- 数据缓存列表 -->
        <!-- 数据缓存列表 -->
		<cluster name="biz_data_cache">
			<heartbeat-second>2</heartbeat-second>
			<pool-size>16</pool-size>

push-manager-server/src/main/resources/server-config.xml

@@ -4,6 +4,10 @@
	<config name="engine" value="beetl"/>
	<config name="encode" value="UTF-8"/>
	<config name="indexPage" value="SendMessage"/>
	
	<!-- add by chengwb3 M端是否进行用户权限校验 -->
	<config name="userPermissionsCheck" value="true"/>
	
	<!-- 缓存类型,目前支持mem和jvm -->
	<config name="cache" value="mem"/>
	<!-- 文件是否加密 -->

push-manager-server/src/main/resources/server-data.xml

@@ -3,6 +3,10 @@
   	<!-- add by chengwb3 -->
	<!-- 通过负载均衡，获取其中一个ip+port -->
	<action name="ServerBean.getBestServer" class="com.ai.ipu.biz.bean.ServerBean" method="getBestServer" verify="false"></action>
	
	<!-- P向M注册服务端列表信息 -->
	<action name="ServerBean.addServer" class="com.ai.ipu.biz.bean.ServerBean" method="addServer" verify="false"/>
	
	<!-- 增加路由关系 -->
	<action name="RouteBean.addRoute" class="com.ai.ipu.biz.bean.RouteBean" method="addRoute" verify="false"></action>
	<!-- 删除路由关系 -->

push-manager-server/src/main/resources/server-page.xml

@@ -1,32 +1,4 @@
<?xml version="1.0" encoding="UTF-8"?>
<pages>
    <!-- 首页 -->
    <action name="Home" 		template="template/home/index.html"/>
    <action name="Index" template="template/home/index_forward.html"> </action>
 	<action name="Prod" 		template="template/home/prod.html"/>
 	<action name="Case" 		template="template/home/case.html"/>
 	<action name="CaseDetail" 	template="template/home/case-detail.html" data="CaseDetail"/>
 	<action name="Touch" 		template="template/home/touch-us.html"/>
 	<action name="ppt" template="ppt.html"/>
 	<!-- 文档 -->
 	<action name="Doc" 	template="template/doc/Index.html" data="MenuData"/>
 	<!-- 市场 -->
 	<action name="Appstore" 	template="template/appstore/index.html" data="appStore.appList"/>
 	<action name="AppDetail" 		template="template/appstore/app_detail.html" data="appStore.appDetail"/>
 	<!-- 众包 -->
 	<action name="zongbao.Index" template="template/zongbao/index.html" />
 	<action name="zongbao.Detail" template="template/zongbao/detail.html" />
 	<action name="zongbao.Mine" template="template/zongbao/mine.html" />
 	
 	<!-- IPU手机版 -->
    <action name="MobileHome" template="template/ipumobile/index.html" />
 	<action name="MobileProd" template="template/ipumobile/prod.html" />
 	<action name="MobileDoc" template="template/ipumobile/doc.html" />
 	<action name="MobileCase" template="template/ipumobile/case.html" />
 	<action name="MobileTouch" template="template/ipumobile/touch.html" />
 	<action name="MobileCaseDetail" template="template/ipumobile/case-detail.html" data="CaseDetail" />
 	
    <action name="SendMessage" template="template/webapp/SendMessage.html"/>
    
</pages>

push-server/.project

@@ -11,11 +11,6 @@
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>org.eclipse.wst.jsdt.core.javascriptValidator</name>
			<arguments>
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>com.genuitec.eclipse.j2eedt.core.WebClasspathBuilder</name>
			<arguments>
			</arguments>
@@ -51,8 +46,8 @@
		<nature>com.genuitec.eclipse.ast.deploy.core.deploymentnature</nature>
		<nature>com.genuitec.eclipse.j2eedt.core.webnature</nature>
		<nature>org.eclipse.jdt.core.javanature</nature>
		<nature>org.eclipse.wst.jsdt.core.jsNature</nature>
		<nature>org.eclipse.wst.common.project.facet.core.nature</nature>
		<nature>org.eclipse.wst.common.modulecore.ModuleCoreNature</nature>
		<nature>com.sysdeo.eclipse.tomcat.tomcatnature</nature>
	</natures>
</projectDescription>

push-server/etc/memcache.xml

@@ -10,5 +10,18 @@
            <address master="127.0.0.1:11211" />
        </cluster>
        
        <!-- 数据缓存列表 -->
		<cluster name="biz_data_cache">
			<heartbeat-second>2</heartbeat-second>
			<pool-size>16</pool-size>
			<address master="127.0.0.1:11211" />
		</cluster>
		
		<!-- 路由缓存 -->
		<cluster name="push_route_cache">
			<heartbeat-second>2</heartbeat-second>
			<pool-size>16</pool-size>
			<address master="127.0.0.1:11211" />
		</cluster>
    </datacenter>
</memcache>

push-server/etc/server-data.xml

@@ -6,7 +6,7 @@
 	<action name="OfflineSession" class="com.ai.server.action.SessionAction" method="offlineSession" verify="false"/>
 	<action name="getLRUSession" class="com.ai.server.action.SessionAction" method="getLRUSession" verify="false"/>
	<!-- C向M请求P的地址 -->
	<action name="get" class="com.ai.server.action.SessionAction" method="getLRUSession" verify="false"/>
	<!-- 手动注册P -->
	<action name="main" class="com.ai.server.action.PushServerManagerAction" method="startMain" verify="false"/>
	
</datas>

push-server/src/com/ai/server/PushServer.java

@@ -0,0 +1,71 @@
package com.ai.server;
import java.util.HashMap;
import java.util.Map;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
public class PushServer {
    
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(PushServer.class);
    
    public static void main(String[] args) {
//        args = new String[8];
//        //args应该读取配置文件
//        args[0] = "1";//server_id
//        args[1] = "192.168.253.1";//host
//        args[2] = "服务器1";//name
//        args[3] = "7070";//port
//        args[4] = "1";//weight
//        args[5] = "8080";//http_port
//        args[6] = "push-server";//server_name
//        args[7] = "mobiledata";//servlet_data_request_name
        
        String url = "http://localhost:8080/push-manager-server/wlwdata";//push-manager-server的url
        // 自动发送http请求到M端注册
        IData pushServerObj = new DataMap();
        pushServerObj.put("serverId", args[0]);
        pushServerObj.put("host", args[1]);
        pushServerObj.put("name", args[2]);
        pushServerObj.put("port", args[3]);
        pushServerObj.put("weight", args[4]);
        pushServerObj.put("httpPort", args[5]);
        pushServerObj.put("serverName", args[6]);
        pushServerObj.put("servletDataRequestName", args[7]);
        Map<String, String> postData = new HashMap<String, String>();
        boolean isEncrypt = false;// 默认不加密传输
        if (isEncrypt ) {
            /* 参数加密处理 */
            postData.put("action", "ServerBean.addServer");
            // postData.put("key", MobileSecurity.getDesKey());
            String encryptData = "";// 加密后的数据
            postData.put("data", encryptData);
        } else {
            postData.put("action", "ServerBean.addServer");
            postData.put("data", pushServerObj.toString());
        }
        String data = HttpTool.toQueryStringWithEncode(postData);
        try {
            String result = HttpTool.httpRequest(url, data, "POST");
            if(result.endsWith("\r")){
                result = result.substring(0, result.lastIndexOf("\r")); // 待测试，之前尾部没有“\r”？？？？？？？？？？？
            }
            IData resultData = new DataMap(result);
            if ("success".equals(resultData.getString("flag"))) {
                log.debug("注册push-server列表成功.");
            } else {
                log.debug("注册push-server列表失败.");
            }
        }
        catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
}

push-server/src/com/ai/server/action/MessageAction.java

@@ -1,7 +1,7 @@
package com.ai.server.action;
import com.ai.ipu.basic.string.StringUtil;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.mobile.push.msg.TextMessage;
import com.ai.server.core.action.AppAction;
import com.ai.server.push.DefaultMessagePusher;
@@ -23,7 +23,7 @@ public class MessageAction extends AppAction {
        TextMessage message = new TextMessage();
        IData data = new DataMap();
        try {
            message.setContent(param.getString("CONTENT"));
            message.setContent(param.getString("content"));
            message.setReceiver(param.getString("RECEIVER"));
            message.setSender(param.getString("SENDER", "system"));
            // 向客户端 发送消息
@@ -44,12 +44,12 @@ public class MessageAction extends AppAction {
    public IData sendTextMessageToAccountSet(IData param) {
        String accountSetStr = param.getString("accountSet");
        TextMessage message = new TextMessage();
        message.setContent(param.getString("CONTENT"));
        message.setContent(param.getString("content"));
        message.setSender(param.getString("SENDER", "system"));
        if (StringUtil.isJSONArray(accountSetStr)) {// 多个account推送
            IDataset accountSet = new DatasetList(accountSetStr);
            if(accountSet == null || accountSet.size()==0){
                IpuUtility.error("is not expect json format");
                throw new IpuBaseException("is not expect json format");
            }
            for (int i=0;i<accountSet.size();i++) {
                message.setReceiver(accountSet.get(i).toString());

push-server/src/com/ai/server/action/PushServerManagerAction.java

@@ -0,0 +1,23 @@
package com.ai.server.action;
import com.ai.server.PushServer;
import com.ai.server.core.action.AppAction;
import com.ailk.common.data.IData;
public class PushServerManagerAction extends AppAction {
    
    public IData startMain(IData param) {
        String[] args = new String[8];
        // args应该读取配置文件
        args[0] = "1";// server_id
        args[1] = "192.168.253.1";// host
        args[2] = "服务器1";// name
        args[3] = "7070";// port
        args[4] = "1";// weight
        args[5] = "8080";// http_port
        args[6] = "push-server";// server_name
        args[7] = "mobiledata";// servlet_data_request_name
        PushServer.main(args);
        return param;
    }
}

push-server/src/com/ai/server/push/cache/BizDataCacheManager.java

@@ -0,0 +1,203 @@
package com.ai.server.push.cache;
import java.util.HashSet;
import java.util.Set;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.server.cache.CacheFactory;
import com.ai.ipu.server.cache.intf.ICache;
import com.ai.server.util.PushConstant;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DatasetList;
/**
 * 业务数据缓存管理类
 */
public class BizDataCacheManager {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(BizDataCacheManager.class);
    private static final String BIZ_DATA_CACHE = PushConstant.BIZ_DATA_CACHE;
    public static final String PUSH_SERVER_LIST = PushConstant.PUSH_SERVER_LIST; // value:IDataSet
    public static final String PUSH_SERVER_ACCOUNTS_PREFIX = PushConstant.PUSH_SERVER_ACCOUNTS_PREFIX; // value:Set<String>
    public static final String AVAILABLE_ACCOUNTS = PushConstant.AVAILABLE_ACCOUNTS; // 用于P端用户有效性二次验证的集合，value:Set<String>
    public static final String PUSH_SERVER_ACCOUNTS_SIZE_PREFIX = PushConstant.PUSH_SERVER_ACCOUNTS_SIZE_PREFIX; // push-server链接account的数量,value:int
    public static ICache getBizDataCache() throws Exception {
        return CacheFactory.getCache(BIZ_DATA_CACHE);
    }
    /**
     * 获取push_server_list缓存
     */
    public static IDataset getPushServerListCache() throws Exception {
        if (null == getBizDataCache().get(PUSH_SERVER_LIST)) {
            synchronized (BizDataCacheManager.class) {
                if (null != getBizDataCache().get(PUSH_SERVER_LIST)) {// 避免时间差
                    return (IDataset) getBizDataCache().get(PUSH_SERVER_LIST);
                }
                initPushServerListCache();
            }
        }
        return (IDataset) getBizDataCache().get(PUSH_SERVER_LIST);
    }
    public static boolean containsPushServer(String serverId) throws Exception {
        if (null == serverId) {
            throw new IpuBaseException("serverId is null.");
        }
        IDataset list = getPushServerListCache();
        if (list.isEmpty()) {
            return false;
        }
        IData pushServer;
        for (int i = 0; i < list.size(); i++) {
            pushServer = list.getData(i);
            if (serverId.equals(pushServer.getString("serverId"))) {
                return true;
            }
        }
        return false;
    }
    /**
     * 读取数据库，初始化数据
     */
    // private static void initPushServerListCache() throws Exception {
    // ServerDao dao = new ServerDao(Constant.connName);
    // IData param = new DataMap();
    // param.put("STATE", Constant.Server.STATE_AVAILABLE);
    // IDataset list = dao.getServerList(param);
    // if (list == null || list.isEmpty()) {
    // IpuLogger.error(log, "tab_server表未找到数据.");
    // IpuUtility.error("tab_server表未找到数据.");
    // }
    // getBizDataCache().put(PUSH_SERVER_LIST, list);
    //
    // IpuLogger.debug(log, "初始化" + PUSH_SERVER_LIST + "成功.");
    // }
    /**
     * 初始化P的列表，应该是主动扫描P的列表
     */
    private static void initPushServerListCache() throws Exception {
        // 待处理。。。
        log.debug("待处理，初始化扫描可用的P的列表");
        IDataset list = new DatasetList();
        getBizDataCache().put(PUSH_SERVER_LIST, list);
    }
    /**
     * 主动更改缓存，用于数据库tab_server表变动
     */
    public static void putPushServerListCache(IDataset list) throws Exception {
        getBizDataCache().put(PUSH_SERVER_LIST, list);
        log.debug("更改" + PUSH_SERVER_LIST + "成功.");
    }
    /**
     * 获取指定push_server端的accounts的Set集合
     */
    @SuppressWarnings("unchecked")
    public static Set<String> getPushServerAccountsCache(String serverId) throws Exception {
        if (null == getBizDataCache().get(PUSH_SERVER_ACCOUNTS_PREFIX + serverId)) {
            return new HashSet<String>();
        }
        return (Set<String>) getBizDataCache().get(PUSH_SERVER_ACCOUNTS_PREFIX + serverId);
    }
    /**
     * 存放accountSet值
     */
    public static void putPushServerAccountsCache(Set<String> accountSet, String serverId) throws Exception {
        getBizDataCache().put(PUSH_SERVER_ACCOUNTS_PREFIX + serverId, accountSet);
    }
    /**
     * 初始化或者更改accountSet值
     */
    public static void addAccountToPushServerAccountsId(String account, String serverId) throws Exception {
        Set<String> accountSet = getPushServerAccountsCache(serverId);
        log.debug("M add route, put before:key=" + (PUSH_SERVER_ACCOUNTS_PREFIX + serverId) + ",value=" + accountSet.toString());
        accountSet.add(account);
        putPushServerAccountsCache(accountSet, serverId);
        log.debug("M add route, put after:key=" + (PUSH_SERVER_ACCOUNTS_PREFIX + serverId) + ",value=" + accountSet.toString());
    }
    /**
     * 删除指定serverId的一个account值
     */
    public static void removeAccountToPushServerAccountsId(String account, String serverId) throws Exception {
        Set<String> accountSet = getPushServerAccountsCache(serverId);
        if (null == accountSet || !accountSet.contains(account)) {
            log.debug("has not this account [" + account + "] on this " + serverId + "server");
            return;
        }
        accountSet.remove(account);
        putPushServerAccountsCache(accountSet, serverId);
    }
    public static void addAvailableAccount(String account) throws Exception {
        if (getAvailableAccountSet().contains(account)) {
            // account已经存在了
            log.debug("account[" + account + "] already exists.");
        }
        Set<String> accountSet = getAvailableAccountSet();
        accountSet.add(account);
        putAvailableAccountSet(accountSet);
    }
    @SuppressWarnings("unchecked")
    public static Set<String> getAvailableAccountSet() throws Exception {
        if (null == getBizDataCache().get(AVAILABLE_ACCOUNTS)) {
            return new HashSet<String>();
        }
        return (Set<String>) getBizDataCache().get(AVAILABLE_ACCOUNTS);
    }
    public static void putAvailableAccountSet(Set<String> accountSet) throws Exception {
        getBizDataCache().put(AVAILABLE_ACCOUNTS, accountSet);
    }
    public static boolean containsAvailableAccount(String account) throws Exception {
        return getAvailableAccountSet().contains(account);
    }
    public static void increasePushServerAccountsSize(String serverId) throws Exception {
        int size = getPushServerAccountsSize(serverId);
        putPushServerAccountsSize(serverId, size + 1);
        log.debug("Number of server connections plus one");
    }
    public static void decreasePushServerAccountsSize(String serverId) throws Exception {
        int size = getPushServerAccountsSize(serverId);
        if (size < 1) {
            throw new IpuBaseException("The number of current connected account is less than one.");
        }
        putPushServerAccountsSize(serverId, size - 1);
        log.debug("Number of server connections minus one");
    }
    private static void putPushServerAccountsSize(String serverId, int accountsSize) throws Exception {
        getBizDataCache().put(PUSH_SERVER_ACCOUNTS_SIZE_PREFIX + serverId, accountsSize);
    }
    private static int getPushServerAccountsSize(String serverId) throws Exception {
        if (null == getBizDataCache().get(PUSH_SERVER_ACCOUNTS_SIZE_PREFIX + serverId)) {
            return 0;
        }
        return (Integer) getBizDataCache().get(PUSH_SERVER_ACCOUNTS_SIZE_PREFIX + serverId);
    }
}

push-server/src/com/ai/server/push/cache/PushRouteCacheManager.java

@@ -0,0 +1,48 @@
package com.ai.server.push.cache;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.server.cache.CacheFactory;
import com.ai.ipu.server.cache.intf.ICache;
import com.ai.server.push.route.Route;
import com.ai.server.util.PushConstant;
/**
 * 管理服务端路由关系缓存管理类
 */
public class PushRouteCacheManager {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(PushRouteCacheManager.class);
    private static final String PUSH_ROUTE_CACHE = PushConstant.PUSH_ROUTE_CACHE;
    public static ICache getPushRouteCache() throws Exception {
        return CacheFactory.getCache(PUSH_ROUTE_CACHE);
    }
    public static Route getRoute(String account) throws Exception {
        if (null == getPushRouteCache().get(account)) {
            return null;
        }
        return new Route(getPushRouteCache().get(account).toString());
    }
    public static void putRoute(String account, Route route) throws Exception {
        if (null == account || "".equals(account) || null == route) {
            throw new IpuBaseException("account or route is null.");
        }
        getPushRouteCache().put(account, route.toString());
        log.debug("set key=[" + account + "] route success.");
    }
    public static void removeRoute(String account) throws Exception {
        if (null == getRoute(account)) {
            log.debug("this route account [" + account + "] is null.");
            return;
        }
        getPushRouteCache().remove(account);
        log.debug("remove key=[" + account + "] route success.");
    }
}

push-server/src/com/ai/server/push/handle/RegisterWithRouteHandler.java

@@ -1,14 +1,12 @@
package com.ai.server.push.handle;
import java.net.InetAddress;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
import org.apache.log4j.Logger;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.mobile.push.handle.IRequestHandler;
import com.ai.mobile.push.msg.AbstractMessage;
import com.ai.mobile.push.msg.RegisterMessage;
@@ -17,82 +15,86 @@ import com.ai.mobile.push.session.DefaultSessionManager;
import com.ai.mobile.push.session.IMSession;
import com.ai.mobile.push.session.ISessionManager;
import com.ai.mobile.push.util.IMConstant;
import com.ai.server.push.cache.PushRouteCacheManager;
import com.ai.server.push.route.IRouteManager;
import com.ai.server.push.route.Route;
import com.ai.server.push.route.impl.RouteManagerImpl;
import com.ai.server.usermanager.DefaultUserManager;
import com.ai.server.usermanager.IUserManager;
import com.ai.server.util.BeanHolder;
import com.ai.server.util.Constant;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
public class RegisterWithRouteHandler implements IRequestHandler{
	transient protected final Logger logger = Logger.getLogger(RegisterWithRouteHandler.class);
	@Override
	public ReplyMessage process(IMSession session, AbstractMessage msg) {
	    System.out.println("服务端接收到注册消息，处理中。。。。。。");
		// TODO Auto-generated method stub
		ISessionManager sessionManager= BeanHolder.getBean(DefaultSessionManager.class);
		RegisterMessage message = (RegisterMessage)msg;
		ReplyMessage reply = new ReplyMessage();
		String account = message.getAccount();
		Map<String, Object> map = message.getMap();
		IUserManager userManager = new DefaultUserManager();
		userManager.verify(map.get("account").toString(), map);//用户连接权限验证
		try {
			reply.setAccount(account);
			session.setAccount(account);
			session.setDeviceId(message.getDeviceId());
			session.setGid(UUID.randomUUID().toString());
			session.setHost(InetAddress.getLocalHost().getHostAddress());
			session.setDeviceType(message.getDeviceType());
			session.setDeviceModel(message.getDeviceModel());
			
			/*客户端连接断开,服务端无法获知情况,因此重连需要关闭旧的连接*/
			IMSession oldSession = sessionManager.getSession(account);
			if (oldSession != null) {
				// 如果是账号已经在另一台终端登录。则让另一个终端下线
				if ((oldSession.getDeviceId() != null
						&& !oldSession.getDeviceId().equals(session.getDeviceId()) 
						|| !oldSession.equals(session))) {
public class RegisterWithRouteHandler implements IRequestHandler {
    transient protected final Logger logger = Logger.getLogger(RegisterWithRouteHandler.class);
					//oldSession.removeAttribute(IMConstant.SESSION_KEY);
					ReplyMessage oldReply = new ReplyMessage();
					oldReply.setCode(Constant.MessageType.TYPE_999);// 强行下线消息类型
					oldReply.setAccount(account);
    @Override
    public ReplyMessage process(IMSession session, AbstractMessage msg) {
        System.out.println("服务端接收到注册消息，处理中。。。。。。");
        // TODO Auto-generated method stub
        ISessionManager sessionManager = BeanHolder.getBean(DefaultSessionManager.class);
        RegisterMessage message = (RegisterMessage) msg;
        ReplyMessage reply = new ReplyMessage();
        String account = message.getAccount();
        Map<String, Object> map = message.getMap();
        try {
            IUserManager userManager = new DefaultUserManager();
            boolean checkUserAvalible = userManager.verify(map.get("account").toString());// 用户连接权限验证
            if (!checkUserAvalible) {
                throw new IpuBaseException("不是有效用户，禁止连接推送服务端。");
            }
            reply.setAccount(account);
            session.setAccount(account);
            session.setDeviceId(message.getDeviceId());
            session.setGid(UUID.randomUUID().toString());
            session.setHost(InetAddress.getLocalHost().getHostAddress());
            session.setDeviceType(message.getDeviceType());
            session.setDeviceModel(message.getDeviceModel());
            /* 客户端连接断开,服务端无法获知情况,因此重连需要关闭旧的连接 */
            IMSession oldSession = sessionManager.getSession(account);
            if (oldSession != null) {
                // 如果是账号已经在另一台终端登录。则让另一个终端下线
                if ((oldSession.getDeviceId() != null && !oldSession.getDeviceId().equals(session.getDeviceId()) || !oldSession.equals(session))) {
                    // oldSession.removeAttribute(IMConstant.SESSION_KEY);
                    ReplyMessage oldReply = new ReplyMessage();
                    oldReply.setCode(Constant.MessageType.TYPE_999);// 强行下线消息类型
                    oldReply.setAccount(account);
                    if (!oldSession.isLocalhost()) {
                        /*
                         * 判断当前session是否连接于本台服务器，如不是发往目标服务器处理
                         * MessageDispatcher.execute(msg, oldSession.getHost());
                         */
                    } else {
                        oldSession.write(oldReply);
                        oldSession.close(true);
                        sessionManager.removeSession(account);
                    }
                    oldSession = null;
                }
            }
            if (oldSession == null) {
                // 第一次设置心跳时间为登录时间
                session.setBindTime(System.currentTimeMillis());
                session.setHeartbeat(System.currentTimeMillis());
                sessionManager.addSession(account, session);
                // 发送M，M记录路由关系，并有业务处理
                session.setAttribute("port", map.get("port"));
                this.addRoute(session, message, false);
            }
            reply.setCode(IMConstant.CODE_200);
        }
        catch (Exception e) {
            reply.setCode(IMConstant.CODE_500);
            e.printStackTrace();
        }
        logger.debug("[register account]:" + account + "|" + reply.getCode());
        return reply;
    }
					if (!oldSession.isLocalhost()) {
						/*
						 * 判断当前session是否连接于本台服务器，如不是发往目标服务器处理
						 * MessageDispatcher.execute(msg, oldSession.getHost());
						 */
					} else {
						oldSession.write(oldReply);
						oldSession.close(true);
						sessionManager.removeSession(account);
					}
					oldSession = null;
				}
			}
			
			if (oldSession == null) {
				// 第一次设置心跳时间为登录时间
				session.setBindTime(System.currentTimeMillis());
				session.setHeartbeat(System.currentTimeMillis());
				sessionManager.addSession(account, session);
				// 发送M，M记录路由关系，并有业务处理
				session.setAttribute("port", map.get("port"));
				this.addRoute(session, message, false);
			}
			
			reply.setCode(IMConstant.CODE_200);
		} catch (Exception e) {
			reply.setCode(IMConstant.CODE_500);
			e.printStackTrace();
		}
		logger.debug("[register account]:" + account + "|" + reply.getCode());
		return reply;
	}
	
    private void addRoute(IMSession session, RegisterMessage message, boolean isEncrypt) throws Exception {
        Route route = new Route();
        route.setAccount(session.getAccount());
@@ -111,41 +113,47 @@ public class RegisterWithRouteHandler implements IRequestHandler{
        route.setState("1");
        route.setWeight("1");
        route.setServerId(message.getMap().get("serverId").toString());
        IRouteManager routeManager = new RouteManagerImpl();
        routeManager.addRoute(route.getAccount(), route);
        
        // 1.memcache保存对象，因为不能序列化，故不能发送到M端保存，也可以节省网络开销
        //RouteCacheUtil.addRouteCache(session.getAccount(), session);
        System.out.println(PushRouteCacheManager.getRoute(route.getAccount()).toString());
        
        // 2.M端业务处理(暂时没有业务处理)
        IData dataParam = new DataMap();
        dataParam.put("key1", "value1");
        dataParam.put("route", route.toString());
        Map<String, String> postData = new HashMap<String, String>();
        if (isEncrypt) {
            /* 参数加密处理 */
            postData.put("action", "RouteBean.addRoute");
            // postData.put("key", MobileSecurity.getDesKey());
            String encryptData = "";// 加密后的数据
            postData.put("data", encryptData);
        } else {
            postData.put("action", "RouteBean.addRoute");
            postData.put("data", dataParam.toString());
        }
        String data = HttpTool.toQueryStringWithEncode(postData);
        String result = HttpTool.httpRequest("http://localhost:8080/push-manager-server/wlwdata", data, "POST");
        if (isEncrypt) {
            /*解密*/
            //result = MobileSecurity.responseDecrypt(result);
        }
        if(result.endsWith("\r")){
            result = result.substring(0, result.lastIndexOf("\r")); // 待测试，之前尾部没有“\r”？？？？？？？？？？？
        }
        IData resultData = new DataMap(result);
        if ("success".equals(resultData.getString("flag"))) {
            IpuLogger.debug(logger, "添加route路由关系成功.");
        } else {
            IpuLogger.debug(logger, "添加route路由关系失败.");
        }
        
//        // 1.memcache保存对象，因为不能序列化，故不能发送到M端保存，也可以节省网络开销
//        // RouteCacheUtil.addRouteCache(session.getAccount(), session);
//
//        // 2.M端业务处理(暂时没有业务处理)
//        IData dataParam = new DataMap();
//        dataParam.put("key1", "value1");
//        dataParam.put("route", route.toString());
//        Map<String, String> postData = new HashMap<String, String>();
//        if (isEncrypt) {
//            /* 参数加密处理 */
//            postData.put("action", "RouteBean.addRoute");
//            // postData.put("key", MobileSecurity.getDesKey());
//            String encryptData = "";// 加密后的数据
//            postData.put("data", encryptData);
//        } else {
//            postData.put("action", "RouteBean.addRoute");
//            postData.put("data", dataParam.toString());
//        }
//        String data = HttpTool.toQueryStringWithEncode(postData);
//
//        String result = HttpTool.httpRequest("http://localhost:8080/push-manager-server/wlwdata", data, "POST");
//        if (isEncrypt) {
//            /* 解密 */
//            // result = MobileSecurity.responseDecrypt(result);
//        }
//        if (result.endsWith("\r")) {
//            result = result.substring(0, result.lastIndexOf("\r")); // 待测试，之前尾部没有“\r”？？？？？？？？？？？
//        }
//        IData resultData = new DataMap(result);
//        if ("success".equals(resultData.getString("flag"))) {
//            IpuLogger.debug(logger, "添加route路由关系成功.");
//        } else {
//            IpuLogger.debug(logger, "添加route路由关系失败.");
//        }
    }
}

push-server/src/com/ai/server/push/handle/UnregisterWithRouteHandler.java

@@ -1,12 +1,7 @@
package com.ai.server.push.handle;
import java.util.HashMap;
import java.util.Map;
import org.apache.log4j.Logger;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.mobile.push.handle.IRequestHandler;
import com.ai.mobile.push.msg.AbstractMessage;
import com.ai.mobile.push.msg.RegisterMessage;
@@ -14,13 +9,14 @@ import com.ai.mobile.push.msg.ReplyMessage;
import com.ai.mobile.push.session.DefaultSessionManager;
import com.ai.mobile.push.session.IMSession;
import com.ai.mobile.push.session.ISessionManager;
import com.ai.server.push.route.IRouteManager;
import com.ai.server.push.route.Route;
import com.ai.server.push.route.impl.RouteManagerImpl;
import com.ai.server.util.BeanHolder;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
public class UnregisterWithRouteHandler implements IRequestHandler {
    transient protected final Logger logger = Logger.getLogger(UnregisterWithRouteHandler.class);
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(UnregisterWithRouteHandler.class);
    @Override
    public ReplyMessage process(IMSession session, AbstractMessage message) {
        // TODO Auto-generated method stub
@@ -58,36 +54,42 @@ public class UnregisterWithRouteHandler implements IRequestHandler {
        route.setServerName(registerMessage.getMap().get("serverName").toString());
        route.setServletDataRequestName(registerMessage.getMap().get("servletDataRequestName").toString());
        IData dataParam = new DataMap();
        dataParam.put("key1", "value1");
        dataParam.put("route", route.toString());
        Map<String, String> postData = new HashMap<String, String>();
        if (isEncrypt) {
            /* 参数加密处理 */
            postData.put("action", "RouteBean.removeRoute");
            // postData.put("key", MobileSecurity.getDesKey());
            String encryptData = "";// 加密后的数据
            postData.put("data", encryptData);
        } else {
            postData.put("action", "RouteBean.removeRoute");
            postData.put("data", dataParam.toString());
        }
        String data = HttpTool.toQueryStringWithEncode(postData);
        IRouteManager routeManager = new RouteManagerImpl();
        routeManager.removeRoute(route);
        String result = HttpTool.httpRequest("http://localhost:8080/push-manager-server/wlwdata", data, "POST");
        if (isEncrypt) {
            /* 解密 */
            // result = MobileSecurity.responseDecrypt(result);
        }
        if (result.endsWith("\r")) {
            result = result.substring(0, result.lastIndexOf("\r")); // 待测试，之前尾部没有“\r”？？？？？？？？？？？
        }
        IData resultData = new DataMap(result);
        if ("success".equals(resultData.getString("flag"))) {
            IpuLogger.debug(logger, "删除route路由关系成功.");
        } else {
            IpuLogger.debug(logger, "删除route路由关系成功.");
        }
        // IData dataParam = new DataMap();
        // dataParam.put("key1", "value1");
        // dataParam.put("route", route.toString());
        // Map<String, String> postData = new HashMap<String, String>();
        // if (isEncrypt) {
        // /* 参数加密处理 */
        // postData.put("action", "RouteBean.removeRoute");
        // // postData.put("key", MobileSecurity.getDesKey());
        // String encryptData = "";// 加密后的数据
        // postData.put("data", encryptData);
        // } else {
        // postData.put("action", "RouteBean.removeRoute");
        // postData.put("data", dataParam.toString());
        // }
        // String data = HttpTool.toQueryStringWithEncode(postData);
        //
        // String result =
        // HttpTool.httpRequest("http://localhost:8080/push-manager-server/wlwdata",
        // data, "POST");
        // if (isEncrypt) {
        // /* 解密 */
        // // result = MobileSecurity.responseDecrypt(result);
        // }
        // if (result.endsWith("\r")) {
        // result = result.substring(0, result.lastIndexOf("\r")); //
        // 待测试，之前尾部没有“\r”？？？？？？？？？？？
        // }
        // IData resultData = new DataMap(result);
        // if ("success".equals(resultData.getString("flag"))) {
        // log.debug("删除route路由关系成功.");
        // } else {
        // log.debug("删除route路由关系成功.");
        // }
    }
}

push-server/src/com/ai/server/push/route/IRouteManager.java

@@ -0,0 +1,36 @@
package com.ai.server.push.route;
import com.ai.ipu.server.cache.intf.ICache;
public interface IRouteManager {
    /**
     * 添加新的路由关系
     */
    public void addRoute(String account, Route route) throws Exception;
    /**
     * 用账号来获取route
     */
    Route getRoute(String account) throws Exception;
    /**
     * 获取所有route
     */
    public ICache getRoutes() throws Exception;
    /**
     * 删除route
     */
    public void removeRoute(Route route) throws Exception;
    /**
     * 删除route
     */
    public void removeRoute(String account) throws Exception;
    /**
     * 判断route是否存在
     */
    public boolean containsRoute(Route route) throws Exception;
}

push-server/src/com/ai/server/push/route/Route.java

@@ -2,7 +2,7 @@ package com.ai.server.push.route;
import java.io.Serializable;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ailk.common.data.impl.DataMap;
/**
@@ -210,7 +210,7 @@ public class Route extends DataMap implements Serializable {
                }
            }
        } else {
            IpuLogger.debug("无法解析，不是自定义解析格式。");
            throw new IpuBaseException("无法解析，不是自定义解析格式。");
        }
    }

push-server/src/com/ai/server/push/route/impl/DefaultRouteManager.java

@@ -0,0 +1,55 @@
package com.ai.server.push.route.impl;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.server.cache.intf.ICache;
import com.ai.server.push.cache.BizDataCacheManager;
import com.ai.server.push.cache.PushRouteCacheManager;
import com.ai.server.push.route.IRouteManager;
import com.ai.server.push.route.Route;
public class DefaultRouteManager implements IRouteManager {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(DefaultRouteManager.class);
    @Override
    public void addRoute(String account, Route route) throws Exception {
        PushRouteCacheManager.putRoute(account, route);
        BizDataCacheManager.addAccountToPushServerAccountsId(account, route.getServerId());
    }
    @Override
    public Route getRoute(String account) throws Exception {
        return PushRouteCacheManager.getRoute(account);
    }
    @Override
    public ICache getRoutes() throws Exception {
        return PushRouteCacheManager.getPushRouteCache();
    }
    @Override
    public void removeRoute(Route route) throws Exception {
        removeRoute(route.getAccount());
    }
    @Override
    public void removeRoute(String account) throws Exception {
        Route route = PushRouteCacheManager.getRoute(account);
        if (null == route) {
            log.debug("Not found this designated account of the Route.");
            return;
        }
        BizDataCacheManager.decreasePushServerAccountsSize(route.getServerId());
        PushRouteCacheManager.removeRoute(account);
    }
    @Override
    public boolean containsRoute(Route route) throws Exception {
        if (null != PushRouteCacheManager.getPushRouteCache().get(route.getAccount())) {
            return true;
        }
        return false;
    }
}

push-server/src/com/ai/server/push/route/impl/RouteManagerImpl.java

@@ -0,0 +1,58 @@
package com.ai.server.push.route.impl;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.server.cache.intf.ICache;
import com.ai.server.push.cache.BizDataCacheManager;
import com.ai.server.push.cache.PushRouteCacheManager;
import com.ai.server.push.route.IRouteManager;
import com.ai.server.push.route.Route;
/**
 * 路由关系管理实现类。 注：不保存push-server对象的account列表，只保存account的数量。
 */
public class RouteManagerImpl implements IRouteManager {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(RouteManagerImpl.class);
    @Override
    public void addRoute(String account, Route route) throws Exception {
        PushRouteCacheManager.putRoute(account, route);
        BizDataCacheManager.increasePushServerAccountsSize(route.getServerId());
    }
    @Override
    public Route getRoute(String account) throws Exception {
        return PushRouteCacheManager.getRoute(account);
    }
    @Override
    public ICache getRoutes() throws Exception {
        return PushRouteCacheManager.getPushRouteCache();
    }
    @Override
    public void removeRoute(Route route) throws Exception {
        removeRoute(route.getAccount());
    }
    @Override
    public void removeRoute(String account) throws Exception {
        Route route = PushRouteCacheManager.getRoute(account);
        if (null == route) {
            log.debug("Not found this designated account of the Route.");
            return;
        }
        BizDataCacheManager.decreasePushServerAccountsSize(route.getServerId());
        PushRouteCacheManager.removeRoute(account);
    }
    @Override
    public boolean containsRoute(Route route) throws Exception {
        if (null != PushRouteCacheManager.getPushRouteCache().get(route.getAccount())) {
            return true;
        }
        return false;
    }
}

push-server/src/com/ai/server/usermanager/AbstractUserManager.java

@@ -1,16 +0,0 @@
package com.ai.server.usermanager;
import java.util.Map;
import com.ai.ipu.basic.util.IpuUtility;
public abstract class AbstractUserManager implements IUserManager {
    @Override
    public void verify(String account, Map<String, Object> map) {
        if (account == null || "".equals(account)) {
            IpuUtility.error("account为空");
        }
        customVerify(account, map);
    }
}

push-server/src/com/ai/server/usermanager/DefaultUserManager.java

@@ -1,22 +1,12 @@
package com.ai.server.usermanager;
import java.util.Map;
import com.ai.server.push.cache.BizDataCacheManager;
import com.ai.ipu.basic.util.IpuLogger;
import com.ai.ipu.basic.util.IpuUtility;
public class DefaultUserManager extends AbstractUserManager{
public class DefaultUserManager implements IUserManager{
    @Override
    public void customVerify(String account, Map<String, Object> map) {
        // 用户名和密码的校验
        String user = (String) map.get("userName");
        String passwd = (String) map.get("passwd");
        if(user!=null&&passwd!=null){
            IpuLogger.debug("用户名密码校验未通过.");
            IpuUtility.error("User and password validation failed");
        }
        IpuLogger.debug("用户连接权限校验通过.");
    public boolean verify(String account) throws Exception {
        return BizDataCacheManager.containsAvailableAccount(account);
    }
}

push-server/src/com/ai/server/usermanager/IUserManager.java

@@ -1,24 +1,11 @@
package com.ai.server.usermanager;
import java.util.Map;
public interface IUserManager {
    /**
     * 验证account有效性
     * 
     * @param account
     * @param map
     * @throws Exception
     */
    public void verify(String account, Map<String, Object> map);
    public boolean verify(String account) throws Exception;
    /**
     * 自定义校验map
     * 
     * @param account
     * @param map
     * @throws Exception
     */
    public void customVerify(String account, Map<String, Object> map);
}

push-server/src/com/ai/server/util/PushConstant.java

@@ -0,0 +1,42 @@
package com.ai.server.util;
public class PushConstant {
    /**
     * 业务数据缓存key，memcache.xml的cluster name
     */
    public static final String BIZ_DATA_CACHE = "biz_data_cache";
    
    /**
     * 业务数据缓存之一，服务端列表缓存，即tab_server表数据
     */
    public static final String PUSH_SERVER_LIST = "PUSH_SERVER_LIST"; // value:IDataSet
    /**
     * 业务数据缓存之一的前缀，+serverId即key，单个push-server的链接accounts列表
     */
    public static final String PUSH_SERVER_ACCOUNTS_PREFIX = "PUSH_SERVER_ACCOUNTS_"; // value:Set<String>
    
    /**
     * 业务数据缓存之一的前缀，+serverId即key，单个push-server链接account的数量
     */
    public static final String PUSH_SERVER_ACCOUNTS_SIZE_PREFIX = "PUSH_SERVER_ACCOUNTS_SIZE_"; // value:int
    
    /**
     * 业务数据缓存之一，是account的Set集合
     */
    public static final String AVAILABLE_ACCOUNTS = "AVAILABLE_ACCOUNTS"; // value:Set<String>
    /**
     * 路由缓存key，memcache.xml的cluster name
     */
    public static final String PUSH_ROUTE_CACHE = "push_route_cache"; // value:Route
    public class Server {
        
        public static final String STATE_AVAILABLE = "1";// 可用
        public static final String STATE_UNAVAILABLE = "0";// 不可用
    }
}