程序包 top.yqingyu.common.qymsg

类 MsgTransfer

java.lang.Object

top.yqingyu.common.qymsg.MsgTransfer

public class MsgTransfer
extends Object

版本:

1.0.0

作者:

YYJ

构造器概要

构造器

构造器	说明
MsgTransfer()

方法概要

修饰符和类型	方法	说明
static ArrayList<byte[]>	assembly(QyMsg qyMsg)
static QyMsg	disassembly(Socket socket, Queue<QyMsg> segmentation$queue, long sleep)
static QyMsg	disassembly(SocketChannel socketChannel, Queue<QyMsg> segmentation$queue)
static void	init(int radix, int body_length_max, ExecutorService pool)
static String	readMessage(Socket socket)	description: 读取 Socket 中的杨氏消息体
static String	readMessage(Socket socket, int timeout)	description: 读取 Socket 中的杨氏消息体
static String	readMessage(SocketChannel socketChannel)	description: 读取 SocketChannel 中的杨氏消息体
static QyMsg	readMessage2(SocketChannel socketChannel)
static QyMsg	readMsg(Socket socket)
static QyMsg	readMsg(Socket socket, int timeout)
static byte[]	readQyBytes(Socket socket)
static byte[]	readQyBytes(Socket socket, int timeout)
static byte[]	readQyBytes(SocketChannel socketChannel)
static QyMsg	readSerializable(Socket socket)	序列化读取
static QyMsg	readSerializable(SocketChannel socketChannel)	序列化读取
static void	writeBytes(Socket socket, byte[] bytes)
static void	writeBytes(SocketChannel socketChannel, byte[] bytes)
static void	writeMessage(Socket socket, String msg)	description: 通过 Socket 写出杨氏消息体
static void	writeMessage(Socket socket, QyMsg msg)	写出带有用户名的信息 date 2022/5/7 1:12 return void
static void	writeMessage(SocketChannel socketChannel, String msg)	description: 通过 SocketChannel 写出杨氏消息体
static void	writeMessage(SocketChannel socketChannel, String userId, String msg)
static void	writeQyBytes(Socket socket, byte[] bytes)
static void	writeQyBytes(SocketChannel socketChannel, byte[] bytes)
static void	writeQyMsg(Socket socket, QyMsg qyMsg)
static void	writeQyMsg(SocketChannel socketChannel, QyMsg qyMsg)
static void	writeSerializable(SocketChannel socketChannel, QyMsg qyQyMsg)	序列化写出
static void	writeSerializable$(Socket socket, QyMsg qyQyMsg)	序列化写出

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

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

构造器详细资料

MsgTransfer

public MsgTransfer()

方法详细资料

init

public static void init(int radix,
 int body_length_max,
 ExecutorService pool)

writeQyMsg

public static void writeQyMsg(SocketChannel socketChannel,
 QyMsg qyMsg)
                       throws Exception

抛出:

Exception

writeQyMsg

public static void writeQyMsg(Socket socket,
 QyMsg qyMsg)
                       throws Exception

抛出:

Exception

assembly

public static ArrayList<byte[]> assembly(QyMsg qyMsg)
                                  throws IOException

参数:

qyMsg - 消息

抛出:

IOException

disassembly

public static QyMsg disassembly(Socket socket,
 Queue<QyMsg> segmentation$queue,
 long sleep)
                         throws IOException,
ClassNotFoundException,
InterruptedException

抛出:

IOException

ClassNotFoundException

InterruptedException

disassembly

public static QyMsg disassembly(SocketChannel socketChannel,
 Queue<QyMsg> segmentation$queue)
                         throws IOException,
ClassNotFoundException

抛出:

IOException

ClassNotFoundException

writeMessage

public static void writeMessage(SocketChannel socketChannel,
 String userId,
 String msg)
                         throws Exception

抛出:

Exception

writeMessage

public static void writeMessage(SocketChannel socketChannel,
 String msg)
                         throws Exception

description: 通过 SocketChannel 写出杨氏消息体

抛出:

Exception

writeQyBytes

public static void writeQyBytes(SocketChannel socketChannel,
 byte[] bytes)
                         throws Exception

抛出:

Exception

writeBytes

public static void writeBytes(SocketChannel socketChannel,
 byte[] bytes)
                       throws Exception

抛出:

Exception

writeBytes

public static void writeBytes(Socket socket,
 byte[] bytes)
                       throws Exception

抛出:

Exception

writeMessage

public static void writeMessage(Socket socket,
 QyMsg msg)
                         throws Exception

写出带有用户名的信息 date 2022/5/7 1:12 return void

抛出:

Exception

readMsg

public static QyMsg readMsg(Socket socket)
                     throws Exception

抛出:

Exception

readMsg

public static QyMsg readMsg(Socket socket,
 int timeout)
                     throws Exception

抛出:

Exception

writeMessage

public static void writeMessage(Socket socket,
 String msg)
                         throws Exception

description: 通过 Socket 写出杨氏消息体

抛出:

Exception

writeQyBytes

public static void writeQyBytes(Socket socket,
 byte[] bytes)
                         throws Exception

抛出:

Exception

readMessage2

public static QyMsg readMessage2(SocketChannel socketChannel)
                          throws IOException

抛出:

IOException

readMessage

public static String readMessage(SocketChannel socketChannel)
                          throws IOException

description: 读取 SocketChannel 中的杨氏消息体

抛出:

IOException

readQyBytes

public static byte[] readQyBytes(SocketChannel socketChannel)
                          throws IOException

抛出:

IOException

readMessage

public static String readMessage(Socket socket)
                          throws IOException

description: 读取 Socket 中的杨氏消息体

抛出:

IOException

readQyBytes

public static byte[] readQyBytes(Socket socket)
                          throws IOException

抛出:

IOException

readMessage

public static String readMessage(Socket socket,
 int timeout)
                          throws Exception

description: 读取 Socket 中的杨氏消息体

抛出:

Exception

readQyBytes

public static byte[] readQyBytes(Socket socket,
 int timeout)
                          throws Exception

抛出:

Exception

writeSerializable

public static void writeSerializable(SocketChannel socketChannel,
 QyMsg qyQyMsg)
                              throws Exception

序列化写出

抛出:

Exception

writeSerializable$

public static void writeSerializable$(Socket socket,
 QyMsg qyQyMsg)
                               throws Exception

序列化写出

抛出:

Exception

readSerializable

public static QyMsg readSerializable(SocketChannel socketChannel)
                              throws Exception

序列化读取

抛出:

Exception

readSerializable

public static QyMsg readSerializable(Socket socket)
                              throws Exception

序列化读取

抛出:

Exception