2. 建立连接池,线程池中线程从连接池获取一个连接将SOAP报文下发到网元上。
3. 其他线程:SOAP报文读取线程,将生成的SOAP报文文件映射到内存文件,每次读取1w条数据到SOAP报文下发队列,SOAP下发队列数据结构进行
封装,添加信号量,每次数据push_back一条信号量递增
SOAP报文下发线程,独立的线程从SOAP报文下发队列中取数据,等待下发队列的信号,如果有信号则从队列中取数据,构建下发任务
将下发任务压入线程池工作任务队列,同时信号量递减1
SOAP报文保存线程,SOAP报文下发后会收到网元的响应报文,解析模块分析响应报文,获取SOAP发送报文的执行结果,并将执行失败
的SOAP报文进行保存,对执行成功的报文写入日志。
4. 连接池:连接池工厂,连接池,连接器实体
连接池工厂建立连接池名称和连接池实例的映射,管理所有连接池。
连接池管理所有会话连接(IOSession),建立空闲会话队列和使用会话队列,如果空闲队列为空,同时又有新的连接请求,则建立一条新的连接。
连接数不能超过最大连接数,如果已经达到最大连接数,则进入等待状态,当空闲队列空状态取消
AttachHttpHeader() // 附加Http报头
DetachHttpHeader() // 获取Http响应报头
PraseHttpHeader() // 解析Http响应报头
http://www.cnpaf.net/Class/HTTP/200707/20984_2.html
队列采用状态模式,空闲状态
队列包含一个事件,类型转换 *** 作符到事件句柄,当空闲队列为空时,事件变为无信号状态,当变为非空时变为有信号状态。每次出现这种状况都要写日志信息。
加锁时要用自动锁,将锁包装在一个局部变量中,防止死锁的发生。
CMultiLock包装多个同步对象
CSingleLock包装单个同步对象
CSingleLock singleLock(&m_CritSection)// 包装一个临界区
singleLock.Lock() // 尝试给共享资源加锁
if (singleLock.IsLocked()) // 判断共享资源是否被锁住
{
// 开始使用共享资源
// 使用结束,释放共享资源使用权
singleLock.Unlock()
}
如何查看linux soap port一般都是先知道soap端口,才能通过jmx监控was的程序,当然你可以通过配置文件得到这个端口号。最快的办法,登录WAS console,选择server-》application server-》server1(default),从这里边找到port一项,然后展开就可看到所有你需要的端口,...1、 打开soapUI,新建工程
输入工程名:1234,添加WSDL资源(此处添加的WSDL资源是服务提供方提供服务的WSDL资源),点击OK
2、 打开工程1234,点击Request 1,
3、 在Request 1窗口中,用参数把“?”替换,点击“执行”按钮(前提必须要确定替代“?”的测试报文格式是准确无误的)
此处输入的是参数是“5566”(这个参数要看系统,不是随便输入,一般都是用XML报文,此次参数5566只是展现,不要参考),如果在右边的的测试结果回馈窗口看到一些成功的信息(成功信息不是单一的,各服务返回的信息都不同,看情况而论),而且看到自己的系统有相应信息以及数据进来,则说明服务是正常的;如果结果反馈窗口出现报错信息(报错信息很多,视实际情况而论),而且本系统服务没有响应信息以及数据进来,则说明服务本身可能有问题。
4、测试ESB配置是否正确
把此服务的代理服务地址添加到上图中的地址栏中,进行测试,如下图所示:
出现如图所示类似信息,说明ESB配置是没有问题的。如果执行没有成功,ESB配置可能有问题。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)