ncv61-信息交换平台技术红皮书

信息交换平台总体结 信息交换平台功能特 信息交换平台V50版新增功 信息交换平台V55版新增功 信息交换平台V60版新增功 实施方法简 Servlet的URL地址参数与XML交换文档头属性的关 向NC系统发送数据方 回执及异常出错信 信息交换平台总体参数设 单据流水号和单据并发控 日志查 翻译器配 校验文件全局配 表记录的配 字段属性项的配 单据相关信 生成＆配置交换规则定义文 辅助信息项设 插件代码.........................................................................................第五章单据集成示 问题描 设 具体开发指 第六章安 加密类编 加密类.............................................................................................第七章扩 第八章JMS及大文件传输模 信息交换平台异步通信解决方 JMS简 JMS传输模 JMSFor 4大文件传输模 发送结果错误 K系统自定义项目样本 XMLXMLXMLXMLXML1.1.1信息交换平台主要用于外部系统和NC系统进行集成。利用信息交换平台，可以将外系统的基本和业务数据发送到NC系统中并进行相关的业务操作，如、弃审，也可以通过发送XML格式的查询条件导出NC系统的数据（需HTTP请求。模式。XMLXML面向服务的架构。这使得第系统可以随时随地向NC系统发送相关的业务数据，NC内部的服务及工作流引擎使得NC系统可以在合适的时候向第系统传送需要的数据，并且满足第系统的格式规个字段定义XML结构查询的。这些都得益于对XPath功能的模拟，XMLXML文件增加和EXCEL文NC系统中，实现 目标URL地址、 EXCEL内外对照数据导入分为两列，其中第一列为外系统值，第二列为NC所对应值，系统会自动检查NC值的，NCNC（服务）NC系统在有一个Servlet伺候服务，等待并处理客户端的POST方法请以自定义发送客户端ServletURL2.32.1节介绍了要将某个外系统的某种单据类型的数据文件导入至NC系统的NC 2.2；头中receiverServletURL（XML2.2NCXML 信息交换平台服务端 结构安排如图2.1.1所示，其 为安装盘 ，也是中间件的工 pfxx与webapps一样同在安 XML文件、传送失败的文件。 ，存放所有需要交换的和单据的交换规则文件 所涉及单据的辅助信息格式。详细情况参考4.3节辅助信息项设置。 元数据ID、单据加锁级别等。详细内容参考4.1节单据相关信息。图2.1.1信息交换平台服务端文 结ServletURLXML数据文件的文档头属性中指定的信息有更高的优先级别。比如在Servlet的URL地址参数中指定yk组织。2.2.1NC服务器的Servlet的URL地址“”是Servlet?”号之后的“account=0001&groupcode=xx”就是设置的URL地址参数一般情况下这个地方只设置帐套编码接收至于这些属性2.2.1ServletURL图2.2.2是一个典型的XML文档头，文档头的根名是ufinterface，后面跟着就是各种初始化信息的设置。这些属性分为三类：必须设置的属性、ServletURL参数设置决定是否必设的属性和根据需要决定是否设置的属2.2.2XMLServletURLaccountNCgroupcode属性，这个属性值指定接 的编码filename属性，在数据导入过程中，对于每张单据我们都可以记录其原始数filenameichange属性，这个属性值决定了在外系统的数据在导入NC系统的过程Y”和“nrece属性，这个属性值决定是否允许将相同单据往同一个接收方重复导V502.6节内容。如果不允许相同nurlNCpkServletURL，[信息交换平台]→[手动加载界面]，在打开的界面中选择需要发送的文件，2.3.1点击：[开发平台]→[开发配置工具]→[任务类型]→[增加]，在弹出的任务类型框中配置一个类型“外部交换数据发送” 图 任务类型该条件阈值用于设置用户数据文件（不能为空该条件阈值用于设置存放单据导入之后的回执信息的每张单据一个回执文件，如果用户不设置这个阈值，系统在待发送文件下默认创建/logdir作为回执；该条件阈值对于想将能够成功加载的文件备份走的用户有（一般；该条件阈值是一个可扩展的条件阈值它用于配置将什么样的URL地址（不能为空。这个配置值的格式如下：URLest1系统编码为“1101NCServlet 2.3.3”发送配置信息是一个可扩展的条件阈值其意思就是用户可以在预警平台的类型框中修改名为“外部交换数据发送”的类型定义，增加作为条件的发送配置信息项，以实现数据文件的多点发送。点击：[开发平台]→[开发配置工具]→[任务类型]→[选中“外部数据交换发送”行]→[修改]，弹出“类型框，如图2.3.4所”postconfig1ostconfig2图2.3.4任务类型 JavaNCStringurl= URLrealURL=newURL(url);HttpURLConnectionconnection=connection.setRequestProperty("Content-type","text/xml");// FileFilefile=newFile("C:/samples/psndoc.xml");BufferedOutputStreamout=newBufferedInputStreaminput=newBufferedInputStream(newintbyte[]buffer=newwhile((length=input.read(buffer,0,1000))!=-1)out.write(buffer,0,}InputStreaminputStream=resDoc= publicstaticintpublicstaticintsendFile(Filefile,Stringurl,StringStringmovedir,booleanfileQueuepublicstaticSendResultsendFileWithResults(Filefile,Stringurl,Stringbackdir,Stringmovedir,booleanbcompress,FileQueuepublicstaticString doc,StringoutputEncoding,booleanbcompress)throwspublicstaticStringoutputEncoding)throws(doc,Stringurl,[说明]XMLXMLUtil类,APIjarPostFileXML文件，其一般格式如下：<?xml<?xmlversion="1.0"encoding='UTF-<ufinterfacebilltype="bspsn"filename="人 样本数据文件 change="Y"receiver="yk"re ce="Y"roottag="sendresult"sender="1001" 译值:部门yk,翻译方式:按名称.,翻译参照的公司：yk。 值:测试,翻译方式:按名称.,翻译参照的公司：yk。 值:测试人员yk,翻译方式:按名称.,翻译参照的公司：yk。单据12315601022323处理错误:单据翻译转换错误: <docitemname="abc">部门<docitemname="岗 <docitemname="人员类别">测试人员2.4.1中心，外系统发送过来一个消息，NC系统回应一个消息。如查询类的单据，外系统发送一个表示查询条件的信息，NC系统返回所有符合查询条件的单据，这XML交换文档在导入NC系统过程中所需处理阶段而给出的。如果单据导入失如果需要更详细的出错信息，请检查日志，信息交换平台对于导入数据过程nchome/nclogs/server/pfxx-log.log日志文件中。的回执信息的<resultcode>中给出。这些错误编码信息主要是给第系统程序1表示正确传送，段中<docitemname="abc">部门yk</docitem>name表示改文档在外系统中对应的文档名称(如果nc基本资源列表里没有，则为基础数据对照表中对应外系统名称)，文本内容为其代翻译的值。生换规<?xml<?xmlversion="1.0"encoding='UTF-<ufinterfaceaccount="develop"billtype="user"filename=""groupcode=""i change="Y"re roottag=""sender=""><bill <abledate>2011-07-13<disabledate>2011-07-13 packagepackageimportimportimportimportimportimportimportnc.vo.pfxx.auxiliary.AggxsysregisterVO;importnc.vo.pfxx.exception.PfxxPluginException;importnc.vo.pfxx.util.PfxxPluginUtils;importimport import;importimport<b**Createon2006-4-6@author@versionYourProjectVer5.0@sincepublicclassQueryPluginextendsPfxxPlugin@param。@param@param辅助信息@throwsBusines@date2006-1-protectedObjectprocessBill(Objectvo,ISwapContextswapContext,AggxsysregisterVOaggvo)throwsBusinesception{//1.得到转换后的VO数据,取决于向导第一步的VO信息CommonQueryVOresvo=(CommonQueryVO)vo;KeyValueVO[keyValueVOsresvo.getConditions();intn=keyValueVOs.length;String[]keys=newfor(inti=0;i<n;i++)keys[i]=}2.查询此单据是否已经被导入过，有三个方法，具体使用哪一个请参考方法说明//1)Stringvopk=//2)Stringvopk//3)Stringvopk////3如果单据设置有辅助信息，xsysvo4.如果此单据没有导入过，那么准备保存新单据，保存单据前请进行必要的数据检查，并// //5.如果此单据已经导入过，请调用ufvo)//如果不允许更新,此方抛出业务异// //doc=XMLUtil.getNew//new////////////}catch(java.io.IOException//////查询NC数据，通过回执返回到外系统示例代码开始resdoc=null;/*获取导出服务IPFxxEJBServicerunner=try/*查询需要导出的VO,这里查全部,实际应用应该通过XML*/IAccsubjDataQueryqueryService=AccsubjVO[]vos=//Collectioncol=/*实例代码仅演示ValueObject,如果是AGGVOresdoc=runner.exportBills(vos,swapContext.getAccount(),"bsaccsubj",swapContext.getOrgPk(),swapContext.geder(),null);//getidsfromandinserttodbString[]docids=newString[vos.length];intfor(int{Elementnode=(Element)basdocList.item(i);}}for(inti=0;i<docids.length;i++){swapContext.getOrgPk(),}StringBuffersbRet=newStringBuffer();XMLUtil.writeXMLFormatString(sbRet,resdoc,0);}catch(Exceptione){Logger.error("导出单据失败e);thrownewPfxxPluginException(this.getClass().getName()失败}//!!!!6.如果希望单据将来可以更新，请调用下列接口插入文档流水号与生成PK第2步查询对照关系相对应，也有三个方法，具体请看//////////对于查询插件要求返回org.w3c.dom.Node[]return}}<?xml<?xmlversion="1.0"encoding='UTF-<ufinterfacebilltype="kjkm1"filename="kjkm1e9a8164U860xml"i change="Y"receiver="0001"re roottag="sendresult"sender="U860"successful="Y"><filename>kjkm1e9a8164U860<resuescription>单据CORPe40702bkjkmquery开始处理...单据CORPe40702bkjkmquery处理完毕!</resuescription><ufinterfaceaccount="design"basedocid="0001a9f7bbsaccsubj"billtype="bsaccsubj"filename="0001a9f7bbsaccsubj"ichange="Y"proc=""receiver="U860"rece="Y"roottag="code"sender="0001"subbilltype=""><code<</<</<</<</<</<</<</<</<</ <suev>1</su平台日志界面打开参数设置框，如图2.5.1所示。在这个框中，可以设置进行改动。设置的参数值实时生效，不用重起服务器。2.5.1ServletURLaccountaccount决定的，但是如果这两个地方都没有申明这个值，20M文件，请自行在应NCHOME/pfxx/globalset.xmlmax-transfer-size的值，并考虑OutOfMemory的风险。这个参数主要用于控制所导入文档的每张单据是否在服务器本地做备份记至目录_HOME/pfxx/fxxtmp/inocs/下，后者备份至目录_HOME/pfxx/pfxtemp/translatd/下。这些信息在找错排错中是非常有用的，者发送的话，回执信息都会以文件的形式保存到指定下，但是如果备份这个参数就是用于控制是否gb2312编码格式的文件，经过配置之后就可以相当方便的达到目的，只是此时gb2312编码字符，则可能显示不正常。系统默认回执和导XMLXML文档对象XML文档由一百张凭证组成，这个参数属于信息交换平台安全性方面的设置。我们在这里设置允许向NC端发送数据，那么我们就启用这个属性设置，并将这两个IP地址输入至其输入NC系统新增A公司发送某A公司某个用户登陆并打开相应单据界面进行制A公司发送具有相同流水号的单据，就相当于在界面上修改原来新增的BA公司新增2.5.2单据类 发送文档单据类发送 外部系接收 接收组单据编 文档 翻译后文 交换平台翻译后文输入流解决问题。打开输入流，将降低系统性能在参数设置中打开输入流这样所有通过信息交换平台传输的数据将会配置翻译器，可以根据用户需要创建个性化的翻译器。自定义翻译器需要实现nc.bs.pfxx.ITranslatorStrategy接口，并将新的翻译器类名到“自定义翻译器”界NCtranslateNCToEx(StringdocPk,StringmetaDataID,ITranslateContextNC上述两个方法中都有上下文ITranslateContext作为参数，该上下文中提供了当前主键，组织主键，外系统主键，翻译策略（PK；按编码；按名称）及用户自定义1）keyITranslateContextgetUserdata(Stringkey)取得特定的变量数据。2）本章介绍在“交换规则定义”界面上如何为在信息交换平台中的单据进NCU8外部系（Sibeil,SAP等等的第数据的集成的支持关于单据交换规则的exsystemexsystem的元数据，如下所示：3.1.1XML的交换规则。3.1.2NC3.1.2XML1.2单据根<billdata>定义的元素称为单据数据元素一个外系统数据3.1.3XML的根属性值设置为billdata。如图3.1.4所示。3.1.4修改交换文档根 所示。billhead所示。图设置表头记录“外系统定义的表”属性项的实体元素。DOM树中的叶子节点（简单元素）我们称之为简单字段元素，因为一般情况下它与我们NC系统中的一个数据对象的属性或者数据库表中的一个示例了数据文件中的简单字段元素。NCNC系统的元数据决定的，则就会丢失信息。如表体记录定义的字段exsystemcode默认的外系统名称为<exsystemcode>，与数据文件中相应字段元素的名<excode>不一致，需要将“excode，图数据文件中简单字段的NC的数据结构中的数据类型，在转换过程中用于校验外系统数据。NCNC内的非空字段，但外系统不具备相应字段元素值的情形，比如导入U860的部门、会计科目时，U860相应数234节点，而不是<ufinterface>元素节点。路径由外系统元素名或者符号“^”“^”a的元素。弟元素，是单据元素<billdata>的子元素。这种情况下我们就需要设置字段^123该元素定义了当前字段属于何种基 REF为字段定义需要参照的基本自定义翻译器中可能需要特定的变量值用于翻译，如，组织等等信息，NC系统数据间的简单映射，比如“False=0;True=1”表示如果外系统当前字段的值为False那么导入到NC系统为0True，NC1；导出时则恰好相反。下面的图例说明了如何定义NC系统的字符串值上。【导入XMLXMLNC系统内部的数据结构VO。导入主要用于标准XML文件到VO这一过程中对字段的取值做进一图5为字段定义导入属6图7根据导入生成的VO内【导出导出，以及导出在单据导出时的作用。图8为字段定义导出属904.1.1单据插件信息＝＝模块信息[模块名]–单据所属模块，比如部门属于”uapbd”模块，凭证属于”gl”模块，＝＝插件配置[单据标识]一般填写相应的单据类型即可如果没有单据类型比如基础，可以取一个能唯一标识当前的名称。比如部门取名为”bsdept”NC注意:SuperVO。[插件类名称]接口，具体可以看后面的[插件类生成及]。配置好单据相关信息后，就可以自动生换规则定义文件的大纲了，段配置参照等。.2校验&对照文件.1，XML方接受方及凭证类别由用户灵活控制的另外如存货基础发送到时，用户也需要配置可以分配到那些公司。诸如此类的信息，在交换平台中称，4.4.1插件代码类为PfxxPlugin，一般也无需修改。转换后的VO序列化到，最终台进行展现，以便开发人员观察转换后的ECLIPSE修改好的代码也可以拷贝到这里，进行编译(中间件需要设置参数enableHotDeployed=true),4.4.2利用插件开发向导为自定义单据“自定义”开发集成功能K在进行具体开发前须先期完成的任务在信息交换平台为K系统编码为1101的外部系统，准备好K系统的自定义样本数据defdoc.xml文NC在单据标识输入框中输入defdoc，在单据描述输入框中输入自定义，在在校验&对照文 界面上，对自动生成的单据转换规则进行定义，主需要参照该单据的单据模版（pk_org参照组织。pk_defdoclistprocessBill(Object,ISwapContext,AggxsysregisterVO)中，编DefdocVODefdocVOdefdocvo=(DefdocVO)vo;IDefdocServiceimp=defdocvo.setDatatype(newInteger(1));imp.insertDefdocs(swapContext.getOrgPk(),newDefdocVO[]{defdocvo});return在打 在打 defdoc。pk_defdoclist节点，修改右表中该字段在外系统中的名称defdoc。在另存 在另存 中浏览输入defdoc.xml文件所在 义定义，查看数据是否插入成功。本章介绍如何为在信息交换平台中进行单据内容502packagepackageimport@authorpublicinterface@author@param@returnstructured@throwspublicStringdecrypt(Stringbase64text)throwsBASE64@author@param@return@throwspublicStringencrypt(Stringtext)throws}对于加密后的单据内容，一般情况下需要将密文转换成BASE64文本编码。同 BASE64文本转换成密文然后再packageimportimportpackageimportimportimportimportimportpublicclassDefaultCryptProcessorimplementsprotectedbyte[]deBASE64String(Stringbase64text)throwsreturnnew}catch(IOExceptionLogger.error("不能解析base64文本\r\ne.getMessage()thrownew}}protectedStringgetBASE64String(byte[]bytes)throwsreturnnew}@author@seepublicStringdecrypt(Stringbase64text)throwsreturnnew}BASE64@author@seepublicStringencrypt(Stringtext)throwsreturn}}前和处理后，以及单据导出前和导出后的处理，二次开发人员可以通过实继承原有的加密实现类，然后修改原来的加密类为新的实现类。类publicpublicinterfaceIExtensionProcessorextendsICryptProcessor@author@param*vo数据，在NC@param@param@param@throwspublicvoidbeforeBusinessProcessor(Objectvo,final doc,ISwapContextthrows@author@param@param@param@param@return@throwspublicObjectafterBusinessProcessor(Objectresobj,AggxsysregisterVO ISwapContextcontext)throws@author@param需要导出的@param@throwspublicvoidbeforeExportBusinessProcessor(Object[]vos,ISwapContextcontext)throwsPfxxException;@author@param导出的@param@return@throws doc,ISwapContextcontext)throwsPfxxException;}JMS发给的业务处理插件处理完毕后将结果以httpResponse的方式返回给客户.post很难充分地利用服务端的资源——所有客户端来的请求接收完成后必须马上处理，没有机会根据应用服务器上的负载情况进行实时的调度。JMS发布/订阅点对点（PeertoJMS（Java消息服务）J2EE应用程序（asynchronousJMS产生连接的部分（ConnectionFactory）JMS连接的对象。每个ConnectionFactoryQueueConnectionFactoryTopicConnectionFactory的一（copy在－预订模型中，它使用的是javax.jms.TopicConnectionFactory。模型：javax.jms.Queuejavax.jms.Topic。连接（Connection）TCP/IP。start()stop()。（Session）JMS连接的帮助下建立的对象，被客户端用作发送为了同步接收消息，需要使用receive()方法。对于异步的情形，使用MessageListener和唯一的方法——onMessage()消息（Message）——消息本身。JMS属性（不是必要的JMS消息交互

MQ

NC用户利用JMS框架发送消息（可以是文件，字符串或者一个文档对象等）到ActiveMQ服务器，在NCServer的交换平台模块中，开发人员增加了对ActiveMQServer的功能，从而可以迅速的取得用户发送的信息，把这些消息发送到NCServerActiceMQServer的对应队列中，用户可以利用JMS框架很方便的取得这些回执，然JMSMSsub-clusterMSMSMS JMS ActiveActiveMQMaster/SlaveNC、U8他 系stoShared数据处NodeNode在本方案中，每一个数据交换平台涉及到的点上都会部署一个或者多个用户的请求（JMS消息）发送到本地子集群，这是第一级缓存。一旦进子集群详细架构ActiveMQ节点，这些节点使用相同的共享来保证本地系统的高可用性——只要有一个ActiveMQ节点能够正常工作，那本地的通信平台就可以正常工作。注：共享可以有多个选择共享。如果对数据可靠性有最高的要求建议使用第的共 解决方案JMS 中间生效）10个ActvieMQ设置，JMSURL形如：tcp://localhost:61616（重启中间生效JMS（重启中间生效URLJMS项YYYJmsJMSYJMS接收队列(客户端相YJmsJms文件ufinterface中roottag属性值，不能为JMSJMSJMSForJMSforNC6.0(以下简称JMS)是为了满足NC5.6及以后版本信JMSAPI，JMS式，用户发送消息以后，程序无需等待应答，用户可以订阅相应的信息，知用户响应信息已经到达，从而极大的提高的系统的效率。引入JMS以进行发布/订阅方式，的消息传送方式使得用户在与NC之间的通讯选择最通过JMS发送的JMS消息还可以设置优先级，使得对时间敏感的送者(生产者)传送到接收者(消费者)，因此，JMS的引入给ＮＣ带来的好JMSJMS主要是封装了JMS的相关API，向用户提供利用JMS规范跟NC服务器交message-javax.jms.JMmessage-javax.jms.JMmessage-javax.jms.JMmessage-javax.jms.JMmessage-javax.jms.JMmessage-javax.jms.JMurlActvieMQ连接，并启动urljavax.jms.JMpublicstaticjava.lang.StringgetFilePathMD5(java.lang.StringfilePathpublicstaticintsendFileDual(java.lang.Stringjava.lang.StringfilePath,java.lang.StringqueueName,java.lang.StringdualQueueName,intdualLength,throwsjava.lang.Exceptionurl-filePathqueueName-dualQueueName-dualLength-requestMap-publicstaticintsendFile(java.lang.Stringjava.lang.StringfileID,java.lang.Stringjava.lang.StringqueueName,java.lang.StringdualQueueName,intdualLength,booleanthrowspublicstaticintsendFile(javax.jms.Connectionjava.lang.String

java.lang.StringfileID,java.lang.StringbatchID,java.lang.StringID,java.lang.Stringjava.lang.StringdualQueueName,intdualLength,booleanthrowspublicstaticintsendFile(java.lang.Stringjava.lang.StringfilePath,java.lang.StringqueueName,throwsjava.lang.ExceptionurlfilePathqueueNamereplyQueueName-里的参数信息，将覆盖xml中ufinterface的requestMappublicstaticjava.lang.Stringpublicstaticjava.lang.StringpublicstaticvoidsendReceiptMessage(javax.jms.Sessionjava.lang.StringqueueName,java.lang.Stringjava.lang.StringfileID,java.lang.StringseqID,java.lang.StringID,booleanisSuccessed,throwsjavax.jms.JMception发送回执消息其中batchID+fileID+ID能确定同一批次发送的消息session-queueName-fileID-batchID-seqID-IDisSuccessedmapjavax.jms.JMpublicstatic<Textendsjavax.jms.Message>TcreateEAIReceiptMessage(TbooleanisSuccessed,java.lang.StringfileID,java.lang.StringseqID,java.lang.StringID,throwsjavax.jms.JMception创建回执消息其中batchID+fileID+ID能确定同一批次发送的回执消息Tmessage-fileID-batchID-seqID-IDmap- java.lang.StringreplyQueueName,java.lang.StringmessageText,java.lang.StringmessageID,java.lang.StringfileID,java.lang.StringseqID,java.lang.StringID,throwsjavax.jms.JMceptionmessageText-消息正文session-JmsSessionproducer-JmsProducermessageID-IDseqID-IDfileID-ID-map-消息属性javax.jms.JMjava.lang.StringreplyQueueName,java.lang.StringmessageText,java.lang.StringmessageID,java.lang.StringfileID,java.lang.StringseqID,java.lang.StringID,throwsjavax.jms.JMceptionjmstxtMsg-messageText-messageID-fileID-seqID-IDmapjavax.jms.JMpublicstatic<Textendsjavax.jms.Message>TcreateEA(Tjava.lang.StringmessageID,java.lang.StringfileID,java.lang.StringseqID,java.lang.StringID,throwsjavax.jms.JMception创建一个携带UAP-EAI平台特定属性的JMS消息。其中batchID+fileID+ID能确定smessagereplyQueueName-QueuemessageID-ID（唯一）fileID-IDbatchID-IDseqID-IDID-IDmap-其他附加属性javax.jms.JMjava.lang.StringfileID,java.lang.StringID,intseqCount) publicstaticvoidreceive(javax.jms.Sessionjava.lang.StringfileID,java.lang.StringbatchID,java.lang.StringID,throwsjavax.jms.JMceptionsession-fileIDIDlistener-javax.jms.JMjava.lang.StringbatchID,java.lang.StringfileID,java.lang.StringID,java.lang.StringqueueName,longtimeout)url-filePathqueueNametimeoutjavax.jms.JMjava.lang.StringbatchID,java.lang.StringfileID,java.lang.StringID,

longjava.lang.StringfileID,java.lang.StringbatchID,java.lang.StringID,longtimeout)session-fileIDIDqueueNametimeoutjavax.jms.JMpublicstaticvoidreceive(java.lang.Stringjava.lang.StringfileID,java.lang.StringID,java.lang.StringbatchID,longtimeout,java.lang.StringbakMsgPath)urlfilePathqueueName-timeout-bakMsgPath-publicstaticvoidreceive(java.lang.Stringjava.lang.StringfileID,java.lang.StringID,java.lang.StringbatchID,longtimeout,throwsjava.io.FileNotFoundException,urlfileID-timeout-writer-java.lang.StringfileID,java.lang.StringID,java.lang.StringbatchID,urlfileID-timeout-

longtimeout)throwsjava.lang.StringbatchID,java.lang.StringfileID,java.lang.StringID,java.lang.StringqueueName,longtimeout,java.lang.Stringcharset)java.lang.StringbatchID,java.lang.StringfileID,java.lang.StringID,longtimeout,java.lang.Stringcharset)java.lang.StringfileID,java.lang.StringbatchID,java.lang.StringID,longtimeout,java.lang.Stringcharset)java.lang.StringbatchID,java.lang.StringfileID,java.lang.StringID,java.lang.StringqueueName,longcount,java.lang.Stringcharset)java.lang.StringfileID,java.lang.StringbatchID,java.lang.StringID,java.lang.StringqueueName,longcount,java.lang.Stringcharset)javax.jms.Sessionsession,java.lang.StringfileID,java.lang.StringbatchID,java.lang.StringID,longcount)session-fileIDIDqueueNametimeoutjavax.jms.JMjava.lang.StringID,java.lang.StringbatchID,java.lang.StringfileID,java.lang.StringqueueName,longcount)url-filePathqueueNamejava.lang.Stringjava.lang.StringbatchID,java.lang.StringfileID,longcount) publicstaticvoidreceiveWithCount(java.lang.Stringjava.lang.StringID,java.lang.StringbatchID,java.lang.StringfileID,java.lang.StringqueueName,longcount,java.lang.StringbakMsgPath)url-queueName-count-bakMsgPath-publicstaticvoidreceiveWithCount(java.lang.Stringjava.lang.StringID,java.lang.StringfileID,urlfileID-queueName-count-bakMsgPath-

longcount,java.lang.Stringcharset)throwsjava.io.FileNotFoundException,java.lang.StringID,java.lang.StringbatchID,java.lang.StringfileID,java.lang.StringqueueName,longcount,java.lang.Stringcharset)throwsjava.io.FileNotFoundException,u