SOCKET统一接入的方法

摘要

SOCKET统一接入的方法，根据具体的业务需求选择并配置工作方式，工作方式通过配置文件来配置实现：对于通信的接口部分：服务端模式下，线程/进程是动态启动的，有接入就起线程/进程；根据配置判断完整消息报文；客户端模式下，根据业务处理模块的要求将消息发送到不同的连接；启动业务处理模块并监控其是否正常，在业务处理模块不正常的时候能将其重启；对于业务处理的接口部分：客户端多线程/进程并行处理业务，对于不同的接口协议，提供统一的开发模板；在后台数据库/服务堵塞的时候，对于外围的长时间等待的业务请求，能暂停业务处理，直接返回超时；SOCKET接口的两个模块之间采用UNIX域协议进行进程间通讯。

主权项

SOCKET统一接入的方法，根据具体的业务需求选择并配置SOCKET统一接入平台的工作方式，工作方式通过配置文件来配置实现：通讯协议：双方通讯方式的约定，一端为客户端，另一端为服务端，客户端发送请求，服务端返回应答，通讯协议方式决定数据处理的方式和数据的流向；连接信息：通讯双方建立连接的指定信息，TCP/IP协议定义的IP地址、端口号、连接方式；运行方式：指定SOCKET统一接入平台的工作方式是线程方式还是进程方式，并合理配置线程数或者进程数，达到充分合理地利用资源；报文格式：依据接口定义规范指定报文的组织构成，报文头中关键字段的指定、位置定义、长度定义；数据信息：指定SOCKET统一接入平台后台的业务处理模块的访问数据源的相关信息；日志管理：指定SOCKET统一接入平台的消息日志和业务日志的记录方式和存储位置；其特征是SOCKET统一接入平台用于银行代收费接口：包括业务场景描述；数据流向：银行将手机号码、缴费金额信息通过socket传输到移动运营商，移动运行商socket接口收到请求消息后对消息进行分析判断，调用缴费销帐、停开机模块来完成对用户的缴费的处理并将处理结果返回给银行，银行收到应答后告诉用户缴费成功；配置管理：配置银行接口的socket监听的IP，端口号，银行为客户端，本端为服务端，按照线程工作方式，连接方式为长连接，最大并发数设置为10；系统测试：和银行进行测试，分析银行接口请求和应答报文的正确性，对用户的缴费销帐、停开机处理进行核查；压力测试：和银行之间数据量、并发度、异常的压力测试；首先把SOCKET接口分成两部分：与外围系统交互的通信的接口部分；与后台数据库交易的业务处理的接口部分；对于通信的接口部分：服务端模式下，线程/进程是动态启动的，有接入就起动线程/进程；根据配置判断完整消息报文；客户端模式下，根据业务处理模块的要求将消息发送到不同的连接；启动业务处理模块并监控其是否正常，在业务处理模块不正常的时候能将其重启；对于业务处理的接口部分：客户端多线程/进程并行处理业务，对于不同的接口协议，提供统一的开发模板；在后台数据库/服务堵塞的时候，对于外围的长时间等待的业务请求，能暂停业务处理，直接返回超时；SOCKET接口的客户端、服务端两个模块之间采用UNIX域协议进行进程间通讯；服务端线程/进程动态起动和客户端多线程/进程并行处理业务的步骤是：1)发起与业务处理线程交互的线程、2)是否有报文需要提交、3)是则递交报文到后台业务处理进程、4)发送报文到后台业务处理进程、5)从业务处理进程接收待发送至外围系统的报文、6)收到报文、7)报文放入业务处理进程接收缓存、8)数据插入，存放待发送至外围系统的报文链表、9)数据取出，是否有报文要发送，是进入10)，否进入12)、10)从缓存读出发送报文、11)发送报文、12)从外围系统接收报文、13)收到报文，进入7)；发起业务处理线程，读取配置后：21)消息接收线程和业务处理线程起动、22)消息接收、23)接收存款数据、24)存款数据从外围系统接收到消息链表、25)取出数据进行业务处理、26)消息发送；SOCKET统一接入平台的工作过程：启动程序；如果是服务端模式，则并行起动监听线程；对方发起连接，则并行起动连接线程；如果是客户端模式，则并行起动连接线程；连接线程负责从外围接收数据放入外围系统接收消息的链表，负责从存放待发送到外围系统的消息链表中读取消息发送到外围系统；并行起动与后台业务处理进程交互的线程，该线程负责将存放外围系统接受到的消息的链表中的消息提交给后台业务处理进程，负责将后台业务处理线程发送的消息存放到待发送到外围系统的消息链表；并行起动后台业务处理进程；后台业务处理进程并行起动多个业务处理线程，并行起动消息接收线程。