Exemple de serveur


Paramètres d'initialisation du serveur : 

#-------------------------------------
# 服务模块--服务端初始化参数
#-------------------------------------

# 服务端配置列表，多个服务端名称间用'|'分隔，默认为default
ymp.configs.serv.server.name_list=default

# 服务名称, 默认为default
ymp.configs.serv.server.default.name=default

# 绑定IP地址, 默认为0.0.0.0
ymp.configs.serv.server.default.host=0.0.0.0

# 监听端口号, 默认为8281
ymp.configs.serv.server.default.port=8281

# 编解码字符集, 默认为UTF-8
ymp.configs.serv.server.default.charset=UTF-8

# 缓冲区大小, 默认为4096
ymp.configs.serv.server.default.buffer_size=4096

# NIO选择器数量, 默认为1
ymp.configs.serv.server.default.selector_count=1

# 执行线程池大小, 默认为10
ymp.configs.serv.server.default.executor_count=10

# 自定义参数, 可选
ymp.configs.serv.server.default.params.xxx=xxx

représente un serveur en implémentant une déclaration de classe @Serverannotation dans l'écouteur L'annotation a les paramètres suivants :

QQ截图20170207105055.png

Un serveur basé sur le protocole TCP doit hériter de NioServerListener. La classe prend en charge la surveillance des événements suivants :


QQ截图20170207105121.png

Le serveur basé sur le protocole UDP doit hériter de la classe d'écoute NioUdpListener et prend en charge la surveillance des événements suivants :

QQ截图20170207105147.png
Sample code
Serveur TCP 
// 采用默认配置的TCP服务端
@Server
public class TcpServer extends NioServerListener {
    @Override
    public void onSessionAccepted(INioSession session) throws IOException {
        super.onSessionAccepted(session);
    }

    @Override
    public void onMessageReceived(Object message, INioSession session) throws IOException {
        super.onMessageReceived(message, session);
        // 输出接收到的消息
        System.out.println("Message received: " + message);
        // 向客户端发送消息
        session.send("Hi, guys!");
    }

    @Override
    public void onAfterSessionClosed(INioSession session) throws IOException {
        super.onAfterSessionClosed(session);
    }

    @Override
    public void onBeforeSessionClosed(INioSession session) throws IOException {
        super.onBeforeSessionClosed(session);
    }
}
Serveur UDP
// 采用默认配置的UDP服务端，其中implClass参数必须指定为NioUpdServer.class
@Server(implClass = NioUdpServer.class, codec = TextLineCodec.class)
public class UdpServer extends NioUdpListener {

    public Object onSessionReady() throws IOException {
        // 此接口方法的返回值将作为消息发送至客户端
        return null;
    }

    public Object onMessageReceived(InetSocketAddress sourceAddr, Object message) throws IOException {
        // 输出接收到的消息
        System.out.println("Message received: " + message);
        // 此接口方法的返回值将作为消息发送至客户端
        return message;
    }

    public void onExceptionCaught(InetSocketAddress sourceAddr, Throwable e) throws IOException {
        System.out.println(sourceAddr + "--->" + e);
    }
}