程序包 com.sh.util.communication.common

类 CommunicationUtil

java.lang.Object
com.sh.util.communication.common.CommunicationUtil
public class CommunicationUtil extends Object
Description: 通讯工具 Title:首亨软件 - CRM、TSS、ERP等信息化管理软件

  • 字段详细资料

    • MAIN_SERVER

      public static final int MAIN_SERVER
      另请参阅:

    • OTHER_SERVER

      public static final int OTHER_SERVER
      另请参阅:

    • mainServerIp

      public static String mainServerIp

    • connectServerSuccess

      public static boolean connectServerSuccess

    • NOTIFY_MSG_KEY

      public static final 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(String ip, int port, String sendStr)
      发送TCP报文,非阻塞模式
      参数:
      ip - 对端IP
      port - 对端端口
      sendStr - 发送报文

    • sendTcpClientImmediate

      public static Object sendTcpClientImmediate(String ip, int port, String sendStr)
      立即获取返回值，即时通讯，阻塞模式
      参数:
      ip - String
      port - int
      sendStr - String
      返回:
      Object

    • sendTdpClient

      public static void sendTdpClient(String ip, int port, 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, JSONObject obj)
      通知主程序
      参数:
      operateType - int
      obj - JSONObject

    • notifyMainServerImmediate

      public static Object notifyMainServerImmediate(int operateType, JSONObject obj)
      通知主程序,阻塞模式
      参数:
      operateType - int
      obj - JSONObject
      返回:
      Object

    • processNotify

      public static Object processNotify(String msg)
      处理收到的消息
      参数:
      msg - String
      返回:
      Object

    • notifyAllProxy

      public static void notifyAllProxy(JSONObject obj)
      服务器接收到消息后，将消息分派到各个结点，并在消息中添加参数： NOTIFY_BY_MAIN_SERVER_FLAG，以区别该消息由主服务器派发
      参数:
      obj - JSONObject

    • addClient

      public static void addClient(String ip, int port)
      收到客户端数据
      参数:
      ip - String
      port - int

    • getClientList

      public static List<String> getClientList()
      获取其他服务器结点信息
      返回:
      List

    • connectMainServer

      public static void connectMainServer()
      请求连接服务器

    • consleLog

      public static void consleLog()
      打印日志