/**
* 2012-8-3 上午10:25:29
* @author zhangjun
*/
package org.fdzz.service;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.fdzz.db.DBManager;
import org.fdzz.proxy.ServiceProxy;
import org.fdzz.server.BusinessClient;
import org.fdzz.service.impl.BalanceServiceImpl;
import org.fdzz.service.impl.ChargeServiceImpl;
import org.fdzz.service.impl.LoginServiceImpl;
import org.fdzz.service.impl.MessageServiceImpl;
import org.fdzz.service.impl.SPServiceImpl;
import org.fdzz.service.impl.WeatherServiceImpl;
import org.fdzz.util.PropertyUtil;
import org.fdzz.util.ProtocolAnalysis;
/**
* @author zhangjun
* 2012-8-3 上午10:25:29
* 业务转发功能模块，主要获得各种业务功能接口
*/
public class ServiceManager {
private static ServiceManager serviceManager = null;
private Map<String, BaseService> services = new HashMap<String, BaseService>();//存放各种业务接口
private ProtocolAnalysis protocolAnalysis = ProtocolAnalysis.getInstance();//协议工具类
private DBManager dbManager = DBManager.getInstance();//数据库管理类
private String path = "src/proxy.properties";//代理方法事务配置文件
private PropertyUtil propertyUtil = PropertyUtil.getInstance();//读取配置文件工具类
private Set<String> methodNames = new HashSet<String>();
private Log logger = LogFactory.getLog(ServiceManager.class);
//这里的常量主要是获取代理方法的配置
public static String LOGIN_SERVICE = "LoginService";//登陆业务
public static String MESSAGE_SERVICE = "MessageService";//短信业务
public static String SP_SERVICE = "SPService";//SP服务业务
public static String CHARGE_SERVICE = "ChargeService";//话费业务
public static String WEATHER_SERVICE = "WeatherService";//天气业务
public static String Balance_SERVICE = "BalanceService";//话费查询
private ServiceManager() {
}
/**
* 打开一个连接
* @return
*/
public Connection openConnection() {
return dbManager.getConnection();
}
/**
* 获取业务接口
* @param serviceName
* @return
*/
public BaseService getService(String serviceName) {
Connection connection = dbManager.getConnection();
BaseService service = services.get(serviceName);
service.setConnection(connection);
return service;
}
/**
* 获取业务功能模块接口
* @return
*/
public static ServiceManager getInstance() {
if (serviceManager == null) {
serviceManager = new ServiceManager();
serviceManager.initialServices();
}
return serviceManager;
}
/**
* 初始化业务管理类，主要是实例化各业务类的代理对象和读取需要添加事务的方法名
*/
@SuppressWarnings("unchecked")
public void initialServices() {
Properties prop = propertyUtil.getProperty(path);
String loginMethod = prop.getProperty(LOGIN_SERVICE);
if (loginMethod != null) {
String[] methods = loginMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String spMethod = prop.getProperty(SP_SERVICE);
if (spMethod != null) {
String[] methods = spMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String messageMethod = prop.getProperty(MESSAGE_SERVICE);
if (messageMethod != null) {
String[] methods = messageMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String weatherMethod = prop.getProperty(WEATHER_SERVICE);
if (weatherMethod != null) {
String[] methods = weatherMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String balanceMethod = prop.getProperty(Balance_SERVICE);
if (balanceMethod != null) {
String[] methods = balanceMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String chargeMethod = prop.getProperty(CHARGE_SERVICE);
if (chargeMethod != null) {
String[] methods = chargeMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
LoginServiceImpl ls = new LoginServiceImpl();
Class clazz = ls.getClass();
BaseService loginProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(ls));
serviceManager.services.put(LOGIN_SERVICE, loginProxy);
SPServiceImpl si = new SPServiceImpl();
clazz = si.getClass();
BaseService spProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(si));
serviceManager.services.put(SP_SERVICE, spProxy);
MessageServiceImpl ms = new MessageServiceImpl();
clazz = ms.getClass();
BaseService messageProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(ms));
serviceManager.services.put(MESSAGE_SERVICE, messageProxy);
WeatherServiceImpl ws = new WeatherServiceImpl();
clazz = ws.getClass();
BaseService weatherProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(ws));
serviceManager.services.put(ProtocolAnalysis.MAP_DESTINATE_WEATHER, weatherProxy);
BalanceServiceImpl bs = new BalanceServiceImpl();
clazz = bs.getClass();
BaseService balanceProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(bs));
serviceManager.services.put(ProtocolAnalysis.MAP_DESTINATE_LEFTMONEY, balanceProxy);
ChargeServiceImpl cs = new ChargeServiceImpl();
clazz = cs.getClass();
BaseService chargeProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(cs));
serviceManager.services.put(ProtocolAnalysis.MAP_DESTINATE_CHARGE, chargeProxy);
}
/**
* 获取代理方法名称
* @return
*/
public Set<String> getMethodNames() {
return methodNames;
}
/**
* 实现业务转发
* @param request
* @
*/
public void doBusiness(BusinessClient bizClient, Map<String, String> request) {
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "进行业务选择....");
}
String cmd = request.get(ProtocolAnalysis.MAP_PDU);
Map<String, String> response = null;
if (cmd.equals(ProtocolAnalysis.CMD_LOGOUT)) {//登出请求
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "启动登出业务....");
}
LoginService loginService = (LoginService) serviceManager.getService(ServiceManager.LOGIN_SERVICE);
String username = request.get(ProtocolAnalysis.MAP_USERNAME);
response = loginService.logout(username);
String message = protocolAnalysis.makeResponseMessage(response);
bizClient.sendMessage(message);
bizClient.clients.remove(username);
bizClient.beConnected = false;
} else if (cmd.equals(ProtocolAnalysis.CMD_LOGIN)) {//登入请求
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "启动登陆业务....已在登陆状态，重复登入，出错啦！");
}
//已在登陆状态，重复登入，出错啦
response = new HashMap<String, String>();
response.put(ProtocolAnalysis.MAP_STATUS, ProtocolAnalysis.STATUS_REPEATLOGIN);
String message = protocolAnalysis.makeResponseMessage(response);
bizClient.sendMessage(message);
} else if (cmd.equals(ProtocolAnalysis.CMD_MESSAGE)) {//短信请求
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "启动短信请求业务....");
logger.info("把这条短信记录下来....");
}
String destinate = request.get(ProtocolAnalysis.MAP_DESTINATE).trim();
//首先记录这条短信
MessageService messageService = (Message
MCP.rar_增值 （225个子文件） 
ServiceManager.class 11KB MessageServiceImpl.class 10KB ProtocolAnalysis.class 8KB PhoneInterface2.class 7KB WeatherServiceImpl.class 7KB ChargeServiceImpl.class 6KB ChinaMobile.class 6KB PhoneInterface.class 6KB CellPhone.class 6KB BalanceServiceImpl.class 5KB BusinessClient.class 5KB MtpmsgDAOImpl.class 5KB JdbcTemplate.class 5KB LoginInterface.class 4KB MtpuserDAOImpl.class 4KB LoginServiceImpl.class 4KB MtptransDAOImpl.class 4KB MtpspcardDAOImpl.class 3KB ReceiveClient.class 3KB MtpmsgDAOTest.class 3KB BaseServiceImpl.class 3KB MtpmsghisDAOImpl.class 3KB MtpspDAOImpl.class 3KB StatusMessageUtil.class 3KB DBManager.class 3KB MtpspqsinfoDAOImpl.class 3KB Mtpspcard.class 2KB MtpuserDAOTest.class 2KB Mtpmsghis.class 2KB Mtpuser.class 2KB ServiceProxy.class 2KB Mtpmsg.class 2KB MtpoperatorDAOImpl.class 2KB DAOFactory.class 2KB MappingFactory.class 2KB SptxtinfoDAOImpl.class 2KB MtpmsghisDAOTest.class 2KB Mtptrans.class 2KB MtpspcardDAOTest.class 2KB MtptransDAOTest.class 2KB PropertyUtil.class 2KB Mtpsp.class 2KB MtpspDAOTest.class 2KB MtpoperatorDAOTest.class 2KB MtpspqsinfoDAOTest.class 2KB SptxtinfoDAOTest.class 2KB LoginInterface$3.class 2KB LoginServiceTest.class 1KB BalanceServiceTest.class 1KB SPServiceImpl.class 1KB MtpspcardMapping.class 1KB MtpuserMapping.class 1KB MtpmsghisMapping.class 1KB MtpmsgMapping.class 1KB MtptransMapping.class 1KB ProtocolAnalysisTest.class 1KB Test.class 1KB MtpspMapping.class 1KB MessageServiceTest.class 1KB WeatherServiceTest.class 1KB Mtpoperator.class 1KB TestDate.class 1KB MessageService.class 1KB BaseDAOImpl.class 999B MtpoperatorMapping.class 977B MtpspqsinfoMapping.class 969B Mtpspqsinfo.class 941B PhoneInterface2$1.class 922B LoginInterface$1.class 881B LoginInterface$2.class 861B SptxtinfoMapping.class 852B StatusMessageUtilTest.class 825B PhoneInterface$1.class 812B Sptxtinfo.class 724B TestStringSub.class 702B MtpmsgDAO.class 616B BaseDAOTest.class 559B WeatherService.class 516B LoginService.class 488B BaseService.class 445B MtpuserDAO.class 438B SPService.class 430B ChargeService.class 426B BalanceService.class 344B MtptransDAO.class 310B MtpspqsinfoDAO.class 275B MtpspcardDAO.class 272B MtpspDAO.class 249B EntityMapping.class 235B SptxtinfoDAO.class 221B MtpoperatorDAO.class 221B MtpmsghisDAO.class 215B BaseDAO.class 174B .classpath 446B
ok.gif 2KB ok.gif 2KB 5.gif 2KB 5.gif 2KB 7.gif 2KB 7.gif 2KB共 225 条
- 1
- 2
- 3
资源评论
小波思基
- 粉丝: 85
- 资源: 1万+
最新资源
- 随着前端技术越来越成熟，JS,TS已成为各大厂开发的必备使用语言，本站从易到难深入理解JS,TS，同时提供TS做题功能，让你边学边实践，快速掌握.zip
- 通过中缀、后缀实现一个四则运算器，并设计求解界面，由于我喜欢前端嘛，用前端语言实现起来容易以及界面写起来很顺手 .zip
- 该项目是一个使用TypeScript实现的简易版Web系统框架，旨在提供一套搭建Web应用程序的基础设施 它具备以下主要特点和功能1. 虚拟文件系统2. 语言系统3. 常用接口集合.zip
- 网页编辑器，拖拽读取文件，保存文件，支持大部分编程语言文件编辑，简单易用，无需安装，这正是我想要的.zip
- 电力系统分析：基于VBA的分布式电源最佳接入点判定方法与程序实现
- MATLAB实现线性代数方程组直接解法算法解析与实践案例
- 基于MATLAB的线性代数方程组雅克比迭代解法研究与应用
- 基于MATLAB实现的线性代数方程组高斯消去法解析与应用
- MATLAB实现拉格朗日插值多项式的数值计算方法
- 数值计算方法中艾特肯插值法的MATLAB实现与应用
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
