hy.common.net

特点1： 客户端请求数据、服务端响应数据均为Java对象，无须格式转换（如Json、xml报文的转换工作）。大大降低了开发成本，使两个物理分离的程序或服务间的访问如同一个程序一样的操作。

特点2： 数据通讯均通过浮动的临时端口，高频访问时不会造成主端口1721的拥塞瓶颈。

特点3： 支持免密登陆或密码验证登陆，并且密码验证规则可自行定义。

特点4： 支持自定义事件，程序或服务间的事件。默认为XJava事件处理机制，即 内存共享模式 。

特点5： 数据通讯的浮动端口，超时自动关闭功能。

服务端配置举例

<?xml version="1.0" encoding="UTF-8"?>

<config>

	<import name="xconfig"         class="java.util.ArrayList" />
	<import name="server"          class="org.hy.common.net.ServerSocket" />
	
	
	
	<!-- 系统服务配置信息 -->
	<xconfig>
	
		<server id="Server">
			<port>1721</port>               <!-- 服务端监听主端口 -->
			<minPort>17000</minPort>        <!-- 数据通讯的浮动端口的最小值 -->
			<maxPort>17999</maxPort>        <!-- 数据通讯的浮动端口的最大值 -->
			<closeTimeout>60</closeTimeout> <!-- 数据通讯的浮动端口的自动关闭超时时长（单位：秒） -->
			<log>false</log>                <!-- 是否显示通讯日志 -->
			
			<!-- 自定义服务端登陆验证接口。可选的，当没有定义验证方法时，免登陆 -->
			<validate class="org.hy.demo.ServerValidate" />
			
			<call name="addListener">       <!-- 添加自定义通讯事件 -->
				<listener class="org.hy.demo.ServerDemo" />
			</call>
			
			<call name="open" />            <!-- 打开监听主端号服务 -->
		</server>
		
	</xconfig>
	
</config>

服务端自定义事件

public class ServerDemo implements ServerEventListener
{
    
    /**
     *  数据通讯的事件类型。
     *  
     *  事件类型区分大小写
     */
    public String getEventType()
    {
        return "Demo";
    }
    
    
    
    /**
     * 数据通讯事件的执行动作
     */
    public CommunicationResponse communication(CommunicationRequest i_RequestData)
    {
        CommunicationResponse v_ResponseData = new CommunicationResponse();
        
        // 获取客户端请求数据
        Map<String ,Object> v_DataMap = (Map<String ,Object>)i_RequestData.getData();
        
        System.out.println("-- 服务端接收到的数据为：");
        Help.print(v_DataMap);
        
        v_ResponseData.setData(Help.toListKeys(v_DataMap));   // 设置返回结果
        
        return v_ResponseData;
    }
    
}

客户端访问举例

    Map<String ,Object> v_DataMap = new HashMap<String ,Object>();
    v_DataMap.put("String"  ,"ABCDEFG");
    v_DataMap.put("Integer" ,1234567890);
    v_DataMap.put("Date"    ,new Date());

    
    CommunicationRequest  v_RequestData  = new CommunicationRequest();
    CommunicationResponse v_ResponseData = null;
    List<String>          v_Results      = null;
    
    v_RequestData.setEventType("Demo");                // 通讯的事件类型。如果没有设置此属性，默认为XJava事件类型
    v_RequestData.setDataXID(  "2017");                // 通讯数据的标识ID。可选的，按具体业务而定
    v_RequestData.setData(      i_DataMap);            // 通讯数据。可选的，按具体业务而定。可为任何Java类型，须实现 java.io.Serializable 接口
	
    ClientSocket v_Client = new ClientSocket("服务端IP" ,1721);
	
    v_Client.setValidate(new ClientValidate());        // 如果服务端启用了登陆验证，则客户端要提供用户名及密码
	
    v_ResponseData = v_Client.send(v_RequestData);     // 发送通讯数据
	
    v_Results = (List<String>)v_ResponseData.getData();// 获取服务端的返回结果。可为任何Java类型，只须实现 java.io.Serializable 接口即可