Types & classes — github.com/MyCATApache/Mycat-NIO

CodeHub MCPcopy Create free account

hub / github.com/MyCATApache/Mycat-NIO / types & classes

Types & classes84 in github.com/MyCATApache/Mycat-NIO

⨍ Functions 708◇ Types & classes 84

InterfaceAlarms

Mycat报警关键词定义 @author mycat

src/main/java/io/mycat/net2/mysql/definination/Alarms.java:31

ClassAuthPacket

From client to server during initial handshake. <pre> Bytes Name ----- ---- 4

src/main/java/io/mycat/net2/mysql/packet/AuthPacket.java:54

InterfaceBackendConnection

src/main/java/io/mycat/net2/BackendConnection.java:6

ClassBufferUtil

src/main/java/io/mycat/net2/mysql/packet/util/BufferUtil.java:31

ClassByteBufferArray

ByteBuffer数组，扩展的时候从BufferPool里动态获取可用的Buffer 非线程安全类 @author wuzhih

src/main/java/io/mycat/net2/ByteBufferArray.java:14

InterfaceCapabilities

处理能力标识定义 @author mycat

src/main/java/io/mycat/net2/mysql/definination/Capabilities.java:31

@author mycat @author mycat

src/main/java/io/mycat/net2/mysql/util/CharTypes.java:29

ClassCharsetCollation

该类用来表示 mysqld 数据库中字符集、字符集支持的collation、字符集的collation的index、字符集的默认collation 的对应关系：一个字符集一般对应(支持)多个collation，其中一个是默认的 collation，每一个 collation对应一个唯一的ind

src/main/java/io/mycat/net2/mysql/packet/util/CharsetUtil.java:103

ClassCharsetUtil

该类被彻底重构，fix 掉了原来的 collationIndex 和 charset 之间对应关系的兼容性问题，比如 utf8mb4 对应的 collationIndex 有 45, 46 两个值，如果我们只配置一个 45或者46的话，那么当mysqld(my.cnf配置文件)中的配置了：col

src/main/java/io/mycat/net2/mysql/packet/util/CharsetUtil.java:52

InterfaceClosableConnection

src/main/java/io/mycat/net2/ClosableConnection.java:26

ClassCommonPacketUtil

src/main/java/io/mycat/net2/mysql/packet/util/CommonPacketUtil.java:15

src/main/java/io/mycat/net2/mysql/connection/back/ConMap.java:12

src/main/java/io/mycat/net2/mysql/connection/back/ConQueue.java:8

ClassConnectIdGenerator

连接ID生成器 @author mycat

src/main/java/io/mycat/net2/ConnectIdGenerator.java:8

ClassConnection

src/main/java/io/mycat/net2/Connection.java:16

ClassConnectionException

src/main/java/io/mycat/net2/ConnectionException.java:3

ClassConnectionFactory

src/main/java/io/mycat/net2/ConnectionFactory.java:13

ClassConnectionMeta

connection metadata info @author wuzhih

src/main/java/io/mycat/net2/mysql/connection/back/ConnectionMeta.java:34

ClassDBHostConfig

src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:27

src/main/java/io/mycat/net2/Connection.java:30

From Server To Client, at the end of a series of Field Packets, and at the end of a series of Data Packets.With prepared statements, EOF Packet can al

src/main/java/io/mycat/net2/mysql/packet/EOFPacket.java:50

ClassEmptyPacket

@author mycat暂时只发现在load data infile时用到

src/main/java/io/mycat/net2/mysql/packet/EmptyPacket.java:29

InterfaceErrorCode

src/main/java/io/mycat/net2/mysql/definination/ErrorCode.java:29

ClassErrorPacket

From server to client in response to command, if error. <pre> Bytes Name ----- ---- 1

src/main/java/io/mycat/net2/mysql/packet/ErrorPacket.java:50

ClassExecutorUtil

生成一个有名字的（Nameable）Executor，容易进行跟踪和监控 @author wuzh

src/main/java/io/mycat/net2/ExecutorUtil.java:10

ClassFakeResultSet

src/main/java/io/mycat/net2/mysql/response/FakeResultSet.java:10

ClassFieldPacket

From Server To Client, part of Result Set Packets. One for each column in the result set. Thus, if the value of field_columns in the Result Set Header

src/main/java/io/mycat/net2/mysql/packet/FieldPacket.java:59

InterfaceFields

字段类型及标识定义 @author mycat

src/main/java/io/mycat/net2/mysql/definination/Fields.java:31

ClassHandshakePacket

From server to client during initial handshake. <pre> Bytes Name ----- ---- 1

src/main/java/io/mycat/net2/mysql/packet/HandshakePacket.java:55

InterfaceIsolations

事务隔离级别定义 @author mycat

src/main/java/io/mycat/net2/mysql/definination/Isolations.java:31

ClassMockMySQLServer

src/main/java/io/mycat/net2/mysql/MockMySQLServer.java:26

ClassMySQLBackendConnection

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:20

ClassMySQLBackendConnectionFactory

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnectionFactory.java:9

ClassMySQLBackendConnectionHandler

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnectionHandler.java:22

ClassMySQLBackendConnectionStatus

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:92

ClassMySQLConnection

src/main/java/io/mycat/net2/mysql/connection/MySQLConnection.java:11

ClassMySQLConnectionStatus

src/main/java/io/mycat/net2/mysql/connection/MySQLConnectionStatus.java:3

ClassMySQLDataSource

src/main/java/io/mycat/net2/mysql/connection/back/MySQLDataSource.java:34

ClassMySQLFrontConnectionHandler

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontConnectionHandler.java:28

ClassMySQLFrontendConnection

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontendConnection.java:18

ClassMySQLFrontendConnectionFactory

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontendConnectionFactory.java:10

ClassMySQLFrontendConnectionStatus

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontendConnection.java:43

ClassMySQLMessage

src/main/java/io/mycat/net2/mysql/packet/MySQLMessage.java:37

ClassMySQLPacket

src/main/java/io/mycat/net2/mysql/packet/MySQLPacket.java:5

ClassNIOAcceptor

src/main/java/io/mycat/net2/NIOAcceptor.java:19

ClassNIOConnector

NIO 连接器，用于连接对方Sever @author wuzh

src/main/java/io/mycat/net2/NIOConnector.java:20

InterfaceNIOHandler

NIOHandler是无状态的，多个连接共享一个，用于处理连接的事件，每个方法需要不阻塞，尽快返回结果 @author wuzh

src/main/java/io/mycat/net2/NIOHandler.java:10

ClassNIOHandlerWrap

src/main/java/io/mycat/net2/ConnectionFactory.java:46

ClassNIOReactor

网络事件反应器 @author wuzh

src/main/java/io/mycat/net2/NIOReactor.java:19

ClassNIOReactorPool

src/main/java/io/mycat/net2/NIOReactorPool.java:5

ClassNameableExecutor

src/main/java/io/mycat/net2/NameableExecutor.java:11

InterfaceNameableExecutorService

src/main/java/io/mycat/net2/NameableExecutorService.java:8

ClassNameableThreadFactory

src/main/java/io/mycat/net2/NameableThreadFactory.java:6

ClassNamebleScheduledExecutor

src/main/java/io/mycat/net2/NamebleScheduledExecutor.java:6

存放当前所有连接的信息，包括客户端和服务端等，以及Network部分所使用共用对象 @author wuzhih

src/main/java/io/mycat/net2/NetSystem.java:20

From server to client in response to command, if no error and no result set. <pre> Bytes Name ----- ----

src/main/java/io/mycat/net2/mysql/packet/OkPacket.java:51

ClassPacketUtil

src/main/java/io/mycat/net2/mysql/packet/util/PacketUtil.java:36

src/main/java/io/mycat/net2/mysql/util/ParseUtil.java:29

ClassPhysicalDBNode

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBNode.java:31

ClassPhysicalDBPool

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBPool.java:39

ClassPhysicalDatasource

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:35

src/main/java/io/mycat/net2/NIOReactor.java:48

ClassRandomUtil

src/main/java/io/mycat/net2/mysql/util/RandomUtil.java:29

ClassReactorBufferPool

此BufferPool主要是为单一线程使用，即Reactor线程专用的BufferPool，因此读取数据不用加锁，如果是其他线程来获取或归还数据，则用Volatile的机制和延迟技术以获取最高的性能 @author wuzhih

src/main/java/io/mycat/net2/ReactorBufferPool.java:14

ClassReply323Packet

src/main/java/io/mycat/net2/mysql/packet/Reply323Packet.java:38

InterfaceResponseHandler

@author mycat @author mycat

src/main/java/io/mycat/net2/mysql/handler/ResponseHandler.java:35

ClassResultSetHeaderPacket

From server to client after command, if no error and result set -- that is, if the command was a query which returned a result set. The Result Set Hea

src/main/java/io/mycat/net2/mysql/packet/ResultSetHeaderPacket.java:54

ClassRowDataPacket

From server to client. One packet for each row in the result set. <pre> Bytes Name ----- ---- n (Length Coded Str

src/main/java/io/mycat/net2/mysql/packet/RowDataPacket.java:57

ClassSecurityUtil

加密解密工具类 @author mycat

src/main/java/io/mycat/net2/mysql/packet/util/SecurityUtil.java:34

ClassSelectHandler

src/main/java/io/mycat/net2/mysql/handler/SelectHandler.java:39

ClassSelectVersionComment

src/main/java/io/mycat/net2/mysql/response/SelectVersionComment.java:39

ClassServerParse

src/main/java/io/mycat/net2/mysql/parser/ServerParse.java:34

ClassServerParseSelect

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:32

ClassSharedBufferPool

线程安全的共享ByteBufferPool，可以用于在ReactorPool之间调剂 @author wuzhih

src/main/java/io/mycat/net2/SharedBufferPool.java:16

src/main/java/io/mycat/net2/Connection.java:23

ClassStreamUtil

src/main/java/io/mycat/net2/mysql/packet/util/StreamUtil.java:34

ClassSystemConfig

系统基础配置项 @author mycat

src/main/java/io/mycat/net2/SystemConfig.java:34

ClassSystemConfig

系统基础配置项 @author mycat

src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:36

ClassTestMySQLPackageSplitter

src/test/java/io/mycat/net2/mysql/TestMySQLPackageSplitter.java:22

ClassTestReactorBufferPool

src/test/java/io/mycat/net2/TestReactorBufferPool.java:10

ClassTestWriteQueue

测试WriteQueue功能 @author wuzhih

src/test/java/io/mycat/net2/TestWriteQueue.java:15

弱精度的计时器，考虑性能不使用同步策略。

src/main/java/io/mycat/net2/TimeUtil.java:6

InterfaceVersions

src/main/java/io/mycat/net2/mysql/definination/Versions.java:29

ClassWriteQueue

Connection所要写入的数据队列，只有reactor线程来负责将此队列中的数据写到socket里，其他任何线程不能写Socket，避免竞争问题同一时刻只允许一个线程放入数据，通过volatile的标记属性来确保数据在多线程之间的可见性当队列中的数据超过指定的阀值后，后继的写入则放入磁盘文

src/main/java/io/mycat/net2/WriteQueue.java:13