com.sh.util.communication.common

类 CommunicationUtil

java.lang.Object

com.sh.util.communication.common.CommunicationUtil

public class CommunicationUtil
extends java.lang.Object

Description: 通讯工具 Title:首亨软件 - CRM、TSS、ERP等信息化管理软件

版本:

3.0

作者:

江兴春

字段概要

字段

限定符和类型	字段和说明
static boolean	connectServerSuccess
static int	MAIN_SERVER
static java.lang.String	mainServerIp
static java.lang.String	NOTIFY_MSG_KEY
static int	OPERATE_CLIENT_KEY_SIZE
static int	OPERATE_CLIENT_SIZE
static int	OPERATE_notifyAllClient
static int	OPERATE_requireConnect
static int	OPERATE_sendMsg1 已过时。
static int	OPERATE_sendMsg2 已过时。
static int	OPERATE_sendMsg2_online
static int	OPERATE_sendMsgByEndsKey
static int	OPERATE_sendMsgByEqualKey
static int	OPERATE_sendMsgByParam
static int	OPERATE_sendMsgByStartsKey
static int	OTHER_SERVER
static int	REFRESH_CACHE_ALL
static int	REFRESH_CACHE_CONTEXT
static int	REFRESH_CACHE_DSCONTEXT
static int	REFRESH_CACHE_DSCONTEXT2

构造器概要

构造器

构造器和说明
CommunicationUtil()

方法概要

限定符和类型	方法和说明
static void	addClient(java.lang.String ip, int port) 收到客户端数据
static void	connectMainServer() 请求连接服务器
static void	consleLog() 打印日志
static java.util.List<java.lang.String>	getClientList() 获取其他服务器结点信息
static int	isMainServer() 判断是否主服务器,如果未连接到主服务器，则默认返回主服务
static void	notifyAllProxy(net.sf.json.JSONObject obj) 服务器接收到消息后，将消息分派到各个结点，并在消息中添加参数： NOTIFY_BY_MAIN_SERVER_FLAG，以区别该消息由主服务器派发
static void	notifyMainServer(int operateType, net.sf.json.JSONObject obj) 通知主程序
static java.lang.Object	notifyMainServerImmediate(int operateType, net.sf.json.JSONObject obj) 通知主程序,阻塞模式
static java.lang.Object	processNotify(java.lang.String msg) 处理收到的消息
static void	sendTcpClient(java.lang.String ip, int port, java.lang.String sendStr) 发送TCP报文,非阻塞模式
static java.lang.Object	sendTcpClientImmediate(java.lang.String ip, int port, java.lang.String sendStr) 立即获取返回值，即时通讯，阻塞模式
static void	sendTdpClient(java.lang.String ip, int port, java.lang.String sendStr) 发送UDP报文
static void	setAsMainServer() 设置成默认主服务，即当主服务器未启或通信中断时，转为独立服务器模式
static void	startTcpServer() 启动TCP服务
static void	startUdpServer(int port) 启动UDP服务

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

MAIN_SERVER

public static final int MAIN_SERVER

另请参阅:

常量字段值

OTHER_SERVER

public static final int OTHER_SERVER

另请参阅:

常量字段值

mainServerIp

public static java.lang.String mainServerIp

connectServerSuccess

public static boolean connectServerSuccess

NOTIFY_MSG_KEY

public static final java.lang.String NOTIFY_MSG_KEY

另请参阅:

常量字段值

OPERATE_requireConnect

public static final int OPERATE_requireConnect

另请参阅:

常量字段值

OPERATE_sendMsg1

@Deprecated
public static final int OPERATE_sendMsg1

已过时。

另请参阅:

常量字段值

OPERATE_notifyAllClient

public static final int OPERATE_notifyAllClient

另请参阅:

常量字段值

OPERATE_sendMsg2

@Deprecated
public static final int OPERATE_sendMsg2

已过时。

另请参阅:

常量字段值

OPERATE_sendMsgByEqualKey

public static final int OPERATE_sendMsgByEqualKey

另请参阅:

常量字段值

OPERATE_sendMsgByStartsKey

public static final int OPERATE_sendMsgByStartsKey

另请参阅:

常量字段值

OPERATE_sendMsgByEndsKey

public static final int OPERATE_sendMsgByEndsKey

另请参阅:

常量字段值

OPERATE_sendMsgByParam

public static final int OPERATE_sendMsgByParam

另请参阅:

常量字段值

OPERATE_sendMsg2_online

public static final int OPERATE_sendMsg2_online

另请参阅:

常量字段值

OPERATE_CLIENT_SIZE

public static final int OPERATE_CLIENT_SIZE

另请参阅:

常量字段值

OPERATE_CLIENT_KEY_SIZE

public static final int OPERATE_CLIENT_KEY_SIZE

另请参阅:

常量字段值

REFRESH_CACHE_CONTEXT

public static final int REFRESH_CACHE_CONTEXT

另请参阅:

常量字段值

REFRESH_CACHE_DSCONTEXT

public static final int REFRESH_CACHE_DSCONTEXT

另请参阅:

常量字段值

REFRESH_CACHE_DSCONTEXT2

public static final int REFRESH_CACHE_DSCONTEXT2

另请参阅:

常量字段值

REFRESH_CACHE_ALL

public static final int REFRESH_CACHE_ALL

另请参阅:

常量字段值

构造器详细资料

CommunicationUtil

public CommunicationUtil()

方法详细资料

startTcpServer

public static void startTcpServer()

启动TCP服务

startUdpServer

public static void startUdpServer(int port)

启动UDP服务

参数:

port - 服务端口

sendTcpClient

public static void sendTcpClient(java.lang.String ip,
                                 int port,
                                 java.lang.String sendStr)

发送TCP报文,非阻塞模式

参数:

ip - 对端IP

port - 对端端口

sendStr - 发送报文

sendTcpClientImmediate

public static java.lang.Object sendTcpClientImmediate(java.lang.String ip,
                                                      int port,
                                                      java.lang.String sendStr)

立即获取返回值，即时通讯，阻塞模式

参数:

ip - String

port - int

sendStr - String

返回:

Object

sendTdpClient

public static void sendTdpClient(java.lang.String ip,
                                 int port,
                                 java.lang.String sendStr)

发送UDP报文

参数:

ip - 对端IP

port - 对端端口

sendStr - 发送报文

isMainServer

public static int isMainServer()

判断是否主服务器,如果未连接到主服务器，则默认返回主服务

返回:

int

setAsMainServer

public static void setAsMainServer()

设置成默认主服务，即当主服务器未启或通信中断时，转为独立服务器模式

notifyMainServer

public static void notifyMainServer(int operateType,
                                    net.sf.json.JSONObject obj)

通知主程序

参数:

operateType - int

obj - JSONObject

notifyMainServerImmediate

public static java.lang.Object notifyMainServerImmediate(int operateType,
                                                         net.sf.json.JSONObject obj)

通知主程序,阻塞模式

参数:

operateType - int

obj - JSONObject

返回:

Object

processNotify

public static java.lang.Object processNotify(java.lang.String msg)

处理收到的消息

参数:

msg - String

返回:

Object

notifyAllProxy

public static void notifyAllProxy(net.sf.json.JSONObject obj)

服务器接收到消息后，将消息分派到各个结点，并在消息中添加参数： NOTIFY_BY_MAIN_SERVER_FLAG，以区别该消息由主服务器派发

参数:

obj - JSONObject

addClient

public static void addClient(java.lang.String ip,
                             int port)

收到客户端数据

参数:

ip - String

port - int

getClientList

public static java.util.List<java.lang.String> getClientList()

获取其他服务器结点信息

返回:

List

connectMainServer

public static void connectMainServer()

请求连接服务器

consleLog

public static void consleLog()

打印日志