平台-专题技术emp tcpip组件设计

TCPIP通讯组件是EMPTCPIP通讯的框架及扩展机制。在TCPIP通讯功能，通过配置和少量EMPTCPIPTCPIP通讯的客户端逻辑和服务器端逻辑。在进行应用系统TCPIP组件来实现接出（本系统作为客户端，连接其他系统作为主机也可以使用TCPIP组件来实现接入（本系统作为服务器提供业务逻辑服务，其他系统主动EMPTCPIPTCPIP组件的基础工作原EMPTCPIP组件支持单双工通讯模式，支持长连接和短连接，并可以提供连接池功服务服务器服务器客户客户客户双 单TCPIP连接有多种模式，对于双工模式，一条连接既可以发送，又可以接收。对于单工模，客户端只需要启动socket连接即可，无需启动端口，服务器端只需要启动端口，无需定义向客户端的连接；而单工模式下，客户端在启动socket连接的同时，还要启动端口监 <TCPIPService…或<TCPIPServerService…EMPTCPIP<TCPIPService…<TCPIPService…或<TCPIPServerService…TCPIP连接中，通常会涉及到通讯协议报头的处理，例如在报文数据中，最前面几位EMP的TCPIP组件提供了处理这些问题的扩展接口，com 在应用开发中，如何需要进行上述处理，则可以开发特定的代码，实现CommProcessor接口，并将其配置在TCPIPService或TCPIPServerService上。<TCPIPService…<TCPIPService…或<TCPIPServerService…TCPIPTCPIPEMP的TCPIP组件（作为客户端应用时）能够定义多个主机连接，并轮流这些主<TCPIPService<ConnectToHost…port=”…”<TCPIPService<ConnectToHost…port=”…”hostAddr=”…”…<ConnectToHost…port=”…”hostAddr=”…”TCPIPEMPTCPIP组件在客户端应用中，无论长短连接，都提供连接池功能。socket连接持续保持；<TCPIPService<TCPIPService…TCPIPEMPTCPIP组件在服务器端应用中，无论长短连接，可以提供线程池功能（有属性对于长连接，线程池中的对象….还不确定，待将该连接关闭，但是线程对象仍然存在（进入wait状态，等待下接处理（notify<ListenPort<ListenPort…poolThread=”true”maxConnection=”20”EMPEMP（TCPIPTCPIPService在流程中定义步骤，并在步骤定义中指向特定的TCPIP接出服务。<ListenPort…<ListenPort…<CommProcessor<ListenPort…<ListenPort…<CommProcessor（TPIPServerServce（acaeProcessor<ListenPort…<ListenPort…<CommProcessor<PackageProcessor<ListenPort…<ListenPort…<CommProcessor<PackageProcessorEMPTCPIPTCPIP组件的使ActionService长短标数长短标最大TCPIPServerServiceListenPort（一到多个、ConnectToHost（一到多个，TCPIPService下，可以定义ListenPort（一到多个、ConnectToHost（一到多个、TCPIPXML配置（客户端在定义的XML配置中使用TCPIP组件作为连接器，则需要在流程定义中，定义特定的TCPIPAction组件。在EMP中提供了默认的TCPIP（com.ecc.ep.tcpip.TCPIAccesActionTCPIPService服务（businesslogicservice.xml文件<actionid="TCPIPAccessAction0"implClass="com.ecc.emp.tcpip.TCPIPAccessAction"timeOut="10000"sendFormatName="sendFormat"serviceName="aService"receiveFormatName="receFormat"><transition<TCPIPServicename="aService"keepAlive="false"dual="true"<ConnectToHostport="12345"maxConnection="30"hostAddr="192.168.0.6"class="com.ecc.emp.tcpip.ConnectToHost"<ConnectToHostport="12345"maxConnection="30"hostAddr="192.168.0.7"class="com.ecc.emp.tcpip.ConnectToHost"<CommProcessorname="commProcessor" mProcessor"/>台主机，最大连接数都为<actionid="TCPIPAccessAction0"implClass="com.ecc.emp.tcpip.TCPIPAccessAction"timeOut="10000"sendFormatName="sendFormat"serviceName="aService"receiveFormatName="receFormat"><transition<TCPIPServicename="aService"keepAlive="false"dual="true"<ConnectToHostport="12345"maxConnection="30"hostAddr="192.168.0.6"class="com.ecc.emp.tcpip.ConnectToHost"<ConnectToHostport="12345"maxConnection="30"hostAddr="192.168.0.7"class="com.ecc.emp.tcpip.ConnectToHost"<CommProcessorname="commProcessor" mProcessor"/>直接使用编程调用（客户端除了可以在中通过配置来进行TCPIP之外，还可以通过编码来调用TCPIP组tryTCPIPServiceservice=newTCPIPService();ConnectToHostconnectToHost=newConnectToHost();byte[]result=tryTCPIPServiceservice=newTCPIPService();ConnectToHostconnectToHost=newConnectToHost();byte[]result=.getBytes(),10000); }catch(Exceptione){}TCPIPXML配置（服务器端在服务器端，在服务定义或相关定义中，可以定义TCPIP服务的方式（12345，<TCPIPServerServicename="SRVService"keepAlive="false"<TCPIPServerServicename="SRVService"keepAlive="false"<ListenPortkeepAlive="false"port="12345"poolThread="true"<CommProcessorname="commProcessor" mProcessor"/>TCPIP组件的扩byte[]readPackage(java.io.InputStreamin)throwsIOException,byte[]wrapMessagePackage(byte[]byte[]readPackage(java.io.InputStreamin)throwsIOException,byte[]wrapMessagePackage(byte[]publicbyte[]processNe ckage(byte[]publicbyte[]processNe ckage(byte[]msg,TCPIPServic