mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-11 03:13:51 +00:00
chore[version]: update version
This commit is contained in:
1 parent
4ca6715860
commit
64a9fec7ba
656 files changed
-661
No files matched your search
@@ -41,7 +41,6 @@ import java.util.concurrent.ExecutorService;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class NetContext implements ApplicationListener<ApplicationContextEvent>, Ordered {
|
||||
|
||||
|
||||
@@ -19,7 +19,6 @@ import java.lang.annotation.*;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Documented
|
||||
@Retention(RetentionPolicy.RUNTIME)
|
||||
|
||||
@@ -27,7 +27,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ConfigManager implements IConfigManager {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.consumer.registry.IRegistry;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IConfigManager {
|
||||
|
||||
|
||||
@@ -19,7 +19,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ConsumerConfig {
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ConsumerModule {
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class MonitorConfig {
|
||||
|
||||
|
||||
@@ -20,7 +20,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class NetConfig {
|
||||
private String id;
|
||||
|
||||
@@ -22,7 +22,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ProviderConfig {
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ProviderModule {
|
||||
|
||||
|
||||
@@ -20,7 +20,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class RegistryConfig {
|
||||
|
||||
|
||||
@@ -45,7 +45,6 @@ import java.util.concurrent.TimeoutException;
|
||||
* 在clientSession中选择一个可用的session,最终还是调用的IRouter中的方法
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class Consumer implements IConsumer {
|
||||
|
||||
|
||||
@@ -21,7 +21,6 @@ import org.springframework.lang.Nullable;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IConsumer {
|
||||
|
||||
|
||||
@@ -27,7 +27,6 @@ import java.util.function.Consumer;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public abstract class AbstractConsumerLoadBalancer implements IConsumerLoadBalancer {
|
||||
|
||||
|
||||
-1
@@ -33,7 +33,6 @@ import java.util.concurrent.atomic.AtomicReferenceArray;
|
||||
* 通过argument计算一致性hash
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ConsistentHashConsumerLoadBalancer extends AbstractConsumerLoadBalancer {
|
||||
|
||||
|
||||
@@ -19,7 +19,6 @@ import org.springframework.lang.Nullable;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IConsumerLoadBalancer {
|
||||
|
||||
|
||||
@@ -22,7 +22,6 @@ import com.zfoo.protocol.util.RandomUtils;
|
||||
* 随机负载均衡器,任选服务提供者的其中之一
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class RandomConsumerLoadBalancer extends AbstractConsumerLoadBalancer {
|
||||
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ConsumerStartEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -23,7 +23,6 @@ import java.util.function.Consumer;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IRegistry {
|
||||
|
||||
|
||||
@@ -32,7 +32,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class RegisterVO {
|
||||
|
||||
|
||||
@@ -60,7 +60,6 @@ import java.util.stream.Collectors;
|
||||
* 服务注册,服务发现
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ZookeeperRegistry implements IRegistry {
|
||||
private static final Logger logger = LoggerFactory.getLogger(ZookeeperRegistry.class);
|
||||
|
||||
@@ -32,7 +32,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public abstract class AbstractClient<C extends Channel> extends ChannelInitializer<C> implements IClient {
|
||||
|
||||
|
||||
@@ -31,7 +31,6 @@ import java.util.List;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public abstract class AbstractServer<C extends Channel> extends ChannelInitializer<C> implements IServer {
|
||||
private static final Logger logger = LoggerFactory.getLogger(AbstractServer.class);
|
||||
|
||||
@@ -19,7 +19,6 @@ import java.util.*;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class HostAndPort {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IClient {
|
||||
|
||||
|
||||
@@ -15,7 +15,6 @@ package com.zfoo.net.core;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IServer {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author tingyanshen
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ClientSessionActiveEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ClientSessionInactiveEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author meiw
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ServerExceptionEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author tingyanshen
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ServerSessionActiveEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.session.Session;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ServerSessionInactiveEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -27,7 +27,6 @@ import java.util.function.BiFunction;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class GatewayServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ package com.zfoo.net.core.gateway;
|
||||
* 网关负载均衡使用计算一致性hash的参数,如果packet继承了这个接口,则网关的一致性hash负载均衡优先使用这个接口计算一致性hash;
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IGatewayLoadBalancer {
|
||||
|
||||
|
||||
@@ -32,7 +32,6 @@ import java.util.function.BiFunction;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebsocketGatewayServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -36,7 +36,6 @@ import java.util.function.BiFunction;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebsocketSslGatewayServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 22)
|
||||
public class AuthUidAsk {
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
* 网关登录成功过后,将uid授权给网关
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 20)
|
||||
public class AuthUidToGatewayCheck {
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
* 网关登录成功过后,将uid授权给网关的返回
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 21)
|
||||
public class AuthUidToGatewayConfirm {
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.event.model.IEvent;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class AuthUidToGatewayEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 23)
|
||||
public class GatewaySessionInactiveAsk {
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.event.model.IEvent;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class GatewaySessionInactiveEvent implements IEvent {
|
||||
|
||||
|
||||
@@ -21,7 +21,6 @@ import java.util.Map;
|
||||
* 同步网关的session信息到push
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 24)
|
||||
public class GatewaySynchronizeSidAsk {
|
||||
|
||||
@@ -29,7 +29,6 @@ import java.util.function.Function;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class HttpServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -27,7 +27,6 @@ import java.util.function.BiFunction;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JProtobufGatewayServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -23,7 +23,6 @@ import io.netty.handler.timeout.IdleStateHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JProtobufTcpClient extends AbstractClient<SocketChannel> {
|
||||
|
||||
|
||||
@@ -23,7 +23,6 @@ import io.netty.handler.timeout.IdleStateHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JProtobufTcpServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -27,7 +27,6 @@ import io.netty.handler.stream.ChunkedWriteHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JsonWebsocketClient extends AbstractClient<SocketChannel> {
|
||||
|
||||
|
||||
@@ -26,7 +26,6 @@ import io.netty.handler.stream.ChunkedWriteHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JsonWebsocketServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -23,7 +23,6 @@ import io.netty.handler.timeout.IdleStateHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class TcpClient extends AbstractClient<SocketChannel> {
|
||||
public TcpClient(HostAndPort host) {
|
||||
|
||||
@@ -23,7 +23,6 @@ import io.netty.handler.timeout.IdleStateHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class TcpServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -30,7 +30,6 @@ import io.netty.channel.socket.nio.NioDatagramChannel;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class UdpClient extends AbstractClient<Channel> {
|
||||
|
||||
|
||||
@@ -30,7 +30,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class UdpServer extends AbstractServer<Channel> {
|
||||
private static final Logger logger = LoggerFactory.getLogger(UdpServer.class);
|
||||
|
||||
@@ -28,7 +28,6 @@ import io.netty.handler.stream.ChunkedWriteHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebsocketClient extends AbstractClient<SocketChannel> {
|
||||
|
||||
|
||||
@@ -26,7 +26,6 @@ import io.netty.handler.stream.ChunkedWriteHandler;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebsocketServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -35,7 +35,6 @@ import java.security.NoSuchAlgorithmException;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebsocketSslClient extends AbstractClient<SocketChannel> {
|
||||
|
||||
|
||||
@@ -33,7 +33,6 @@ import java.io.InputStream;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebsocketSslServer extends AbstractServer<SocketChannel> {
|
||||
|
||||
|
||||
@@ -28,7 +28,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ChannelHandler.Sharable
|
||||
public abstract class BaseRouteHandler extends ChannelInboundHandlerAdapter {
|
||||
|
||||
@@ -25,7 +25,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ChannelHandler.Sharable
|
||||
public class ClientRouteHandler extends BaseRouteHandler {
|
||||
|
||||
@@ -40,7 +40,6 @@ import java.util.function.BiFunction;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ChannelHandler.Sharable
|
||||
public class GatewayRouteHandler extends ServerRouteHandler {
|
||||
|
||||
@@ -25,7 +25,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ChannelHandler.Sharable
|
||||
public class ServerRouteHandler extends BaseRouteHandler {
|
||||
|
||||
@@ -28,7 +28,6 @@ import java.util.function.Function;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class HttpCodecHandler extends MessageToMessageCodec<FullHttpRequest, EncodedPacketInfo> {
|
||||
|
||||
|
||||
@@ -34,7 +34,6 @@ import java.util.List;
|
||||
* header = body(bytes.length) + protocolId.length(2byte)
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JProtobufTcpCodecHandler extends ByteToMessageCodec<EncodedPacketInfo> {
|
||||
|
||||
|
||||
@@ -15,7 +15,6 @@ package com.zfoo.net.handler.codec.json;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JsonPacket {
|
||||
|
||||
|
||||
@@ -28,7 +28,6 @@ import java.util.List;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class JsonWebSocketCodecHandler extends MessageToMessageCodec<WebSocketFrame, EncodedPacketInfo> {
|
||||
|
||||
|
||||
@@ -34,7 +34,6 @@ import java.util.List;
|
||||
* header = body(bytes.length) + protocolId.length(2byte)
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class TcpCodecHandler extends ByteToMessageCodec<EncodedPacketInfo> {
|
||||
|
||||
|
||||
@@ -33,7 +33,6 @@ import java.util.List;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class UdpCodecHandler extends MessageToMessageCodec<DatagramPacket, EncodedPacketInfo> {
|
||||
|
||||
|
||||
@@ -36,7 +36,6 @@ import java.util.List;
|
||||
* header = body(bytes.length) + protocolId.length(2byte)
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class WebSocketCodecHandler extends MessageToMessageCodec<WebSocketFrame, EncodedPacketInfo> {
|
||||
|
||||
|
||||
@@ -26,7 +26,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ChannelHandler.Sharable
|
||||
public class ClientIdleHandler extends ChannelDuplexHandler {
|
||||
|
||||
@@ -24,7 +24,6 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ChannelHandler.Sharable
|
||||
public class ServerIdleHandler extends ChannelDuplexHandler {
|
||||
|
||||
@@ -15,7 +15,6 @@ package com.zfoo.net.packet;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class DecodedPacketInfo {
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ import org.springframework.lang.Nullable;
|
||||
* 被解码后的Packet的信息
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class EncodedPacketInfo {
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ import com.zfoo.protocol.ProtocolManager;
|
||||
* The interface of IPacket is just an identification interface
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IPacket {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import org.springframework.lang.Nullable;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IPacketService {
|
||||
|
||||
|
||||
@@ -41,7 +41,6 @@ import java.util.function.Predicate;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class PacketService implements IPacketService {
|
||||
|
||||
|
||||
@@ -22,7 +22,6 @@ import org.slf4j.helpers.MessageFormatter;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ProtobufClass
|
||||
@Protocol(id = 101)
|
||||
|
||||
@@ -18,7 +18,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ProtobufClass
|
||||
@Protocol(id = 102)
|
||||
|
||||
@@ -21,7 +21,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
* 通用的返回,既可以用在远程调用,又可以嵌套在其它协议里
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ProtobufClass
|
||||
@Protocol(id = 100)
|
||||
|
||||
@@ -21,7 +21,6 @@ import java.util.Objects;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 110)
|
||||
public class PairIntLong {
|
||||
|
||||
@@ -21,7 +21,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
* Long + String
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 113)
|
||||
public class PairLS {
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 111)
|
||||
public class PairLong {
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 112)
|
||||
public class PairString {
|
||||
|
||||
@@ -18,7 +18,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ProtobufClass
|
||||
@Protocol(id = 103)
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@ProtobufClass
|
||||
@Protocol(id = 104)
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 117)
|
||||
public class TripleLLS {
|
||||
|
||||
@@ -21,7 +21,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
* Long + String + String
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 116)
|
||||
public class TripleLSS {
|
||||
|
||||
@@ -19,7 +19,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 114)
|
||||
public class TripleLong {
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 115)
|
||||
public class TripleString {
|
||||
|
||||
@@ -20,7 +20,6 @@ import org.springframework.lang.Nullable;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IRouter {
|
||||
|
||||
|
||||
@@ -50,7 +50,6 @@ import java.util.concurrent.TimeoutException;
|
||||
* Message distribution
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class Router implements IRouter {
|
||||
|
||||
|
||||
@@ -22,7 +22,6 @@ import java.util.function.Consumer;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class AsyncAnswer<T> implements IAsyncAnswer<T> {
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ import java.util.function.Consumer;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface IAsyncAnswer<T> {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.router.attachment.SignalAttachment;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public interface ISyncAnswer<T> {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.router.attachment.SignalAttachment;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class SyncAnswer<T> implements ISyncAnswer<T> {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public enum AttachmentType {
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 2)
|
||||
public class GatewayAttachment {
|
||||
|
||||
@@ -18,7 +18,6 @@ import io.netty.handler.codec.http.HttpResponseStatus;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 4)
|
||||
public class HttpAttachment {
|
||||
|
||||
@@ -18,7 +18,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
* not used attachment
|
||||
*
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 5)
|
||||
public class NoAnswerAttachment {
|
||||
|
||||
@@ -22,7 +22,6 @@ import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 0)
|
||||
@JsonIgnoreProperties("responseFuture")
|
||||
|
||||
@@ -16,7 +16,6 @@ import com.zfoo.protocol.anno.Protocol;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
@Protocol(id = 3)
|
||||
public class UdpAttachment {
|
||||
|
||||
@@ -17,7 +17,6 @@ import com.zfoo.net.packet.common.Error;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
* @version 3.0
|
||||
*/
|
||||
public class ErrorResponseException extends RuntimeException {
|
||||
|
||||
|
||||
Loaded 100 of 656 files, more files were not shown because too many files have changed in this diff.
Show more
Reference in new issue
Block a user