平臺-專題技術emp tcpip組件設計

TCPIP通訊組件是EMPTCPIP通訊的框架及擴展機制。在TCPIP通訊功能，通過配置和少量EMPTCPIPTCPIP通訊的客戶端邏輯和服務器端邏輯。在進行應用系統(tǒng)TCPIP組件來實現(xiàn)接出（本系統(tǒng)作為客戶端，連接其他系統(tǒng)作為主機也可以使用TCPIP組件來實現(xiàn)接入（本系統(tǒng)作為服務器提供業(yè)務邏輯服務，其他系統(tǒng)主動EMPTCPIPTCPIP組件的基礎工作原EMPTCPIP組件支持單雙工通訊模式，支持長連接和短連接，并可以提供連接池功服務服務器服務器客戶客戶客戶雙 單TCPIP連接有多種模式，對于雙工模式，一條連接既可以發(fā)送，又可以接收。對于單工模，客戶端只需要啟動socket連接即可，無需啟動端口，服務器端只需要啟動端口，無需定義向客戶端的連接；而單工模式下，客戶端在啟動socket連接的同時，還要啟動端口監(jiān) <TCPIPService…或<TCPIPServerService…EMPTCPIP<TCPIPService…<TCPIPService…或<TCPIPServerService…TCPIP連接中，通常會涉及到通訊協(xié)議報頭的處理，例如在報文數(shù)據(jù)中，最前面幾位EMP的TCPIP組件提供了處理這些問題的擴展接口，com 在應用開發(fā)中，如何需要進行上述處理，則可以開發(fā)特定的代碼，實現(xiàn)CommProcessor接口，并將其配置在TCPIPService或TCPIPServerService上。<TCPIPService…<TCPIPService…或<TCPIPServerService…TCPIPTCPIPEMP的TCPIP組件（作為客戶端應用時）能夠定義多個主機連接，并輪流這些主<TCPIPService<ConnectToHost…port=”…”<TCPIPService<ConnectToHost…port=”…”hostAddr=”…”…<ConnectToHost…port=”…”hostAddr=”…”TCPIPEMPTCPIP組件在客戶端應用中，無論長短連接，都提供連接池功能。socket連接持續(xù)保持；<TCPIPService<TCPIPService…TCPIPEMPTCPIP組件在服務器端應用中，無論長短連接，可以提供線程池功能（有屬性對于長連接，線程池中的對象….還不確定，待將該連接關閉，但是線程對象仍然存在（進入wait狀態(tài)，等待下接處理（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長短標數(shù)長短標最大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"/>臺主機，最大連接數(shù)都為<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"/>直接使用編程調(diào)用（客戶端除了可以在中通過配置來進行TCPIP之外，還可以通過編碼來調(diào)用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