本人拙见，如有不同意见，欢迎拍砖，同时献给特别有对服务端跨语言需求的程序猿们！

客户端（GQT Demo V3（服务端配套版）.rar）太大请挪步到ＱＱ群下载（群号：101189702），注明：GQT或Java，C++等；

Java工程代码请挪步下载：http://cxlh.iteye.com/blog/2074307 

总体设计思路： 

1. 高可用性：每个业务服务端都是独立的个体，任何一个业务服务器Crash时，都不会影响服务，并且业务服务器可以按需增加，业务服务端使用Java代码实现，主要是为了考虑更好的数据库操作，更好的事务支持，更好的社区支持以及可用更多的开源服务，提高开发效率；
2. 自动负载均衡：当某个接口频繁调用，增加的响应服务器自动分流接口调用压力，也就说我们的异步的请求/响应模式下，有一个Broker仲裁程序决定客户端发来的请求交由哪个Java业务服务器来处理，这个Broker程序我们采用C++代码实现；
3. 客户端（包括桌面或移动端）网关：根据策略选取远程Socket服务器连接，Socket服务器与服务器之间的消息通讯通过地址寻址远程路由，以便连在不同Socket服务器上的用户之间可以相互通讯，典型的应用就是聊天程序；
4. Sub/Pub类消息：客户端订阅服务端的服务，服务端有多个Pub服务器（Java编写），交由Socket服务器将客户端Sub的消息Push给Client，此时Socket服务只作为Proxy用；

　　好了，其实这里只有2个C++核心组件（Socket服务器，Broker仲裁程序）和N个Java业务服务器（请求处理服务器，Pub服务器），以下介绍用法（需要一定的客户端编程知识和一些脚本只是）：

客户端发送请求，异步收取，编写业务代码步骤：

编写Java服务端，比如我们编写一个按关键字读取股票列表等接口（依赖注入用的Spring）：

@Repository @CacheNamespace(implementation = org.mybatis.caches.ehcache.EhcacheCache.class, readWrite = true) public interface StockDao { 	@Select("select SYMBOL,SHORT_NAME from `master`") 	public List<Map> listStock(); 	 	@Select("select SYMBOL,SHORT_NAME from `master` where SHORT_NAME like '%${k}%' or SPELL_NAME like '%${k}%' or SYMBOL like '%${k}%' limit 0,10") 	public List<Map> listStockByKeyword(Map<String,String> map); 	 	@Select("select SYMBOL,SHORT_NAME from `master` where exch_id=8") 	public List<Map> listAllSh(Map<String,String> map); 	 	@Select("select SYMBOL,SHORT_NAME from `master` where trade_date=#dt#") 	public List<Map> listStockByDate(Map<String,String> map); }

编写Java服务就这么简单：

编写客户端C++或脚本：

gw.req("命令代码"."命令代码对应的参数列表"); //回调函数 gw.s_cb_gw.connect(function(trcode,msg){ 	log("-----------------------------------------------------------------"); 	log("<p>gqt server异步方式获取数据，回调信息：trcode=" + trcode + ",msg=" + msg+"</p>"); });

效果如下：

这样做的好处：

1. 桌面或移动的客户端再也不用编写繁琐的网络通信相关的程序，只需要发送请求/订阅，处理响应/订阅数据包即可，也不用关心底层的数据分包合包，客户端代理，网络传输的加解密和压缩等；
2. 客户端开发人员也几乎不用和服务端程序员沟通，通过JSON解析请求透传给Java，Java响应的数据带上包头和响应给客户端，客户端解析JSON即可；
3. 跨语言的服务端虽然会损失一定的性能，但似乎这点ZeroMQ已做的足够好；

Demo程序部署步骤：

1. 创建一个MySQL Demo数据库，数据库名：stock，utf-8编码，导入output下的stock.sql；
2. 配置output下的config.properties文件，指定机器IP，配置jdbc.properties，确保数据库配置正确；
3. 点击runStockServer.bat，运行stock的Java Demo服务器，可以开任意个；
4. 配置gqt-server-communicator(cpp)下的config_ims.ini文件，IP地址全部换成机器IP；
5. 启动ss_server.exe，ss_zserver.exe；
6. 点击客户端GQT程序，配置config_ims.ini中的IP地址，切换到gateway的标签页，enjoy it！

基于Web的含工作流的项目看起来并不如想象的那么简单，主要需求：

1. 灵活定制工作流，并跟踪流程进度；
2. 每个Order含有历史轨迹记录，可在历史中查看；
3. 工作流的Action灵活，认领任务不一定非要先提取表单，因为很多节点都只有几个动作，直接按钮操作即可；
4. 待办事宜列表在不刷新页面情况下也能变动；

项目要求：

1. 操作简单高效；
2. 权限细节到按钮级别；
3. 并发数少，不超过3000个在线用户；

主要可能使用到技术：

1. 工作流引擎，我这里选用Activiti5，很灵活好用；
2. 权限使用Spring Security，基于标签式管理权限很方便；
3. 通知引擎使用WebSocket，基于Flash实时通信，基于socket.io；
4. 权限粒度基于经典的RBAC；
5. 总体框架Spring MVC+Mybatis；

实现的WebSocket的总体思路：

1. WebSocket Server独立于Web项目，Web Server与WebSocket Server之间的局域网通信基于简单的Socket通信，这样这个组件可以完全解耦和通用；
2. 当Web项目要Push消息到Client时，通过Web Server的Socket Client向WebSocket Server的Socker Server发送消息，然后WebSocket Server收到消息后解码，广播到所有浏览器；

我们实现的事件通知非常简单，设定全局变量并让浏览器侦听：

var G_WebSocket=false; 
var EVENT_ORDER_CHANGE_STATUS = "orderChange"; 
var EVENT_ORDER_CHANGE_AMOUNT = "amountChange"; 
var EVENT_ORDER_CHANGE_REFUND = "refundChange";  
WebSocket.init = function(callbackFunc){ 	
socket = io.connect(connUrl, connOptions); 	
socket.on('connect', function() { 		
G_WebSocket=true; 		
callbackFunc("connect",null); 	
}); 	
socket.on('disconnect', function() { 		
G_WebSocket=false; 		
callbackFunc("disconnect",null); 	
}); 	
socket.on('clientQuit', function(obj){ 		
G_WebSocket=false; 		
callbackFunc("clientQuit",obj); 	
}); 	
socket.on('broadcast', function(obj) { 		
callbackFunc("broadcast",obj); 	
});
};

在需要侦听WebSocket接受Web Server推送消息的地方加上一个函数即可：

	WebSocket.init(function(command,jsonObj){ 		
if(command=="broadcast"){ 			
if(jsonObj.e == EVENT_ORDER_CHANGE_STATUS){ 				
//TODO:write your code here 			
}else if(jsonObj.e == EVENT_ORDER_CHANGE_AMOUNT){ 				
//TODO:write your code here 			
}else if(jsonObj.e == EVENT_ORDER_CHANGE_REFUND){ 				
//TODO:write your code here 			
} 		
} 	
});

 这样的结构要扩展推送服务很简单，比如按频道推送等，都可以很容易的扩展。

再看看看工作流，我们实现了activiti通用的申请提交任务流程和自定义表单功能，提取跟踪流程图功能等，这样你要设计一个新流程也变得非常简单，只需要在eclipse里划上工作流图，在后台发布，然后通过SpringMVC的RestAPI启动实例流程，申领完成任务等，如下图：

 流程走到了分支的两个节点上，这样对后续新增的工作流提供了极大的遍历。

最后说说Spring Security，基于RBAC的权限体系搭建好后（可以用在任何管理系统中），要在页面中访问一个资源，首先判断一下是否有权限，如下HTML：

<sec:authorize ifAllGranted="r_pd"> 
<a href="#">resource access here</a> 
</sec:authorize>

<sec:authorize url="/XXX/XXX/XXX.html"> 	
<a href="XXX/XXX/XXX.html'"> 	
<span>XXX功能</span> 	
</a> 
</sec:authorize>

前台由于项目比较小，没有用到js的MVC框架，如backbone等，这里就不再记录了。

1. 安装和部署Openfire 3.7.0
2. 安装fastpath插件
3. 从openfire的svn上下载webchat源码，webchat导入到eclipse中的工程如下图：

安装FD，你首先需要安装：

1. JDK 1.6以上版本
2. .Net运行环境

 

 

• —软件人才免语言低担保 赴美带薪读研！—
• 限时报名参加Oracle技术大会

PS：附上酒店小图一张，以之纪念……

• 限时报名参加Oracle技术大会
• —软件人才免语言低担保 赴美带薪读研！—

Spring 3.0开始将全面支持Rest，而且配置实现起来也相当简单，利用Spring MVC在web.xml定义片段：

	<servlet>  
        <servlet-name>mydemo</servlet-name>  
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>  
        <load-on-startup>1</load-on-startup>  
    </servlet>  
      
    <servlet-mapping>  
        <servlet-name>mydemo</servlet-name>  
        <url-pattern>/</url-pattern>  
    </servlet-mapping> 

继而在Web-INF目录下增加mydemo-servlet.xml，内容如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
		http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
		http://www.springframework.org/schema/context
		http://www.springframework.org/schema/context/spring-context-3.0.xsd">
	
	<!-- Auto scan, declare the location path -->  
	<context:component-scan base-package="com.mydemo.springmvc.rest" />  

	<!-- Using annontation -->  
	<bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter" /> 
	
	<!-- Resolve the view, declare the prefix and suffix -->  
	<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"  
		p:prefix="/view/" p:suffix=".jsp" p:viewClass="org.springframework.web.servlet.view.JstlView" />  
	 
	<bean id="multipartResolver"  
		class="org.springframework.web.multipart.commons.CommonsMultipartResolver"  
		p:defaultEncoding="utf-8" /> 
</beans>

这里我们定义了JSP文件的标签库用jstl，并启动了注解功能，并自动扫描com.mydemo.springmvc.rest下的controller，接着我们就可以在com.mydemo.springmvc.rest包下编写controller代码

并可以使用注解功能，如类似的代码如下：

@Controller
public class MyDemoController {
	private CommonDAO commonDAO;
	@Autowired
	public void setCommonDAO(CommonDAO commonDAO) {
		this.commonDAO = commonDAO;
	}

	private MyDemoController (){}
	
	@RequestMapping(value="/home", method=RequestMethod.GET)
	public String welcome(){
		return "/home";
	}
}

然后就可以在view目录下通过增加home.jsp来实现显示层代码的编写工作，所有的步骤就以上这些，接下去你就可以通过类似：http://localhost:8080/mydemo/home，来访问了（这里Controller通过注解的方式注入DAO以便进行数据库的访问）

• —软件人才免语言低担保 赴美带薪读研！—
• 限时报名参加Oracle技术大会

本周主要在上海探讨产品架构，以及针对需求的概要设计，将公司的新产品有概念转化为产品，虽然新公司是个刚起步的公

司，但作为产品还是相当有市场潜力的，而且目前国内做同类产品的相对很少，希望能做出点成绩，也作为而立之年的小小

考验，加油……

• —软件人才免语言低担保 赴美带薪读研！—
• 限时报名参加Oracle技术大会

我也是其中一员，曾经心仪的高中女生，自我读大学后，我也跟她保持的书信来往，记得第一次写信地址还是通过校友录知道的，很快我们成为了“笔友”，相对来说，我和写那篇博文的作者差不多，自身条件并不怎么优越，170的身高，还要打个99折，她算是个“全优女生”，成绩好，长相也不错，所以我始终没有表白，也是怕最后连“笔友”也没得做，一直维持着大学结束，她读医的，所以比我多读一年，工作后，“笔友”变成了“话友”，短信IP电话时时骚扰，在大学期间，我还为她和我的经历虚构写成了一篇侦探小说，但我比写博客的作者幸运的是，我在最后的时刻还是表白了，她没马上答复我，一周后，她成为了我的女友，2年后，她成为了我的妻子……

爱要大声说出来，要不然就会连最后的希望都没有……男女单纯的友谊能维持多久呢……我想都是用来忽悠的吧，所以应该抓住每一次机会，爱要大声说出来……

• 限时报名参加Oracle技术大会
• —软件人才免语言低担保 赴美带薪读研！—

• 在数据库中获取XMLType类型的列值，比如存储过程返回XmlType等，代码如下：

public static String getOracleXMlType2String(Object obj){
		try{
			if(obj instanceof OPAQUE){
				StringBuffer sb = new StringBuffer();
				OPAQUE op =(OPAQUE)obj; 
				if(op!=null){
					XMLType poxml = XMLType.createXML(op);
					if(poxml!=null){
						sb.append(poxml.getStringVal());
					}
				}
				return sb.toString();
			}
			return obj.toString();
		}catch(Exception ex){
			return null;
		}
	} 

 Object[] res = DbUtils.ExecuteSP("{call 存储过程名(?,?)}", new Object[]{
		new SpParameter(Types.VARCHAR, "IN", "in参数", "in参数值")
		,new SpParameter(OracleTypes.OPAQUE,"OUT","x",null)}, conn);

• 可以通过XmlType列的clob值，代码如下：

select x.sys_nc_rowinfo$.getclobval() as column_value	from xmltypeTable

	public static final Object[] ExecuteSP(String stmt, Object[] inparams,
			Connection connection) {
		int i = 1;
		CallableStatement st = null;
		SpParameter sp = null;
		SpParameter outp = null;
		int DataType;
		String Direction;
		String Name;
		String DataValue;

		try {
			st = connection.prepareCall(stmt);

			int oupcount = 0;

			for (i = 0; i < inparams.length; i++) {
				if (inparams[i] instanceof SpParameter) {
					sp = (SpParameter) inparams[i];

					if (sp.GetDirection().toUpperCase().equals("IN")) {
						switch (sp.GetDataType()) {
						case Types.FLOAT:
						case Types.INTEGER:
							st
									.setLong(i + 1, Long.parseLong(sp
											.GetDataValue()));
							break;

						case Types.DATE:
							st.setDate(i + 1, java.sql.Date.valueOf(sp
									.GetDataValue()));
							break;
						case Types.SQLXML:
							st.setSQLXML(i + 1, null);
							break;
						default:
							st.setString(i + 1, sp.GetDataValue());
							break;
						}
					} else {
						if(sp.getDataType() == OracleTypes.OPAQUE){
							st.registerOutParameter (i+1, OracleTypes.OPAQUE,"SYS.XMLTYPE");
						}else
							st.registerOutParameter(i + 1, sp.GetDataType());
						oupcount = oupcount + 1;
					}
				} else
					st.setObject(i + 1, inparams[i]);
			}

			st.execute();
			i = 1;

			if (oupcount > 0) {
				Object[] outps = new Object[oupcount];
				int j = 0;
				for (i = 0; i < inparams.length; i++) {
					if (!(inparams[i] instanceof SpParameter))
						continue;

					sp = (SpParameter) inparams[i];

					if (!sp.GetDirection().toUpperCase().equals("IN")) {
						DataType = sp.GetDataType();
						Direction = sp.GetDirection();
						Name = sp.GetName();

						switch (DataType) {
						case Types.FLOAT:
							DataValue = String.valueOf(st.getLong(i + 1));
							break;

						case Types.INTEGER:
							DataValue = String.valueOf(st.getInt(i + 1));
							break;

						case Types.DATE:
							DataValue = st.getDate(i + 1).toString();
							break;

						case OracleTypes.OPAQUE:
							DataValue = getOracleXMlType2String(st.getObject(i+1));
							break;
						default:
							DataValue = st.getString(i + 1);
							break;
						}

						sp.setDataValue(DataValue);
						outps[j++] = DataValue;

						// res.addElement(new SpParameter(DataType, Direction,
						// Name,
						// DataValue));
					}
				}

				return outps;
			} else {
				return null;
			}
		} catch (SQLException ex) {
			
		} finally {
			if (st != null) {
				try {
					st.close();
				} catch (Exception ex) {
					log.error(ex);
				}

			}
		}
	}

• —软件人才免语言低担保 赴美带薪读研！—
• 限时报名参加Oracle技术大会

• —软件人才免语言低担保 赴美带薪读研！—
• 限时报名参加Oracle技术大会