客戶端（Client）示例

#-------------------------------------
# 服務(wù)模塊--客戶端初始化參數(shù)
#-------------------------------------

# 客戶端配置列表，多個客戶端名稱間用'|'分隔，默認(rèn)為default
ymp.configs.serv.client.name_list=default

# 服務(wù)名稱, 默認(rèn)為default
ymp.configs.serv.client.default.name=default

# 遠(yuǎn)程主機(jī)IP地址, 默認(rèn)為0.0.0.0
ymp.configs.serv.client.default.host=0.0.0.0

# 遠(yuǎn)程主機(jī)端口號, 默認(rèn)為8281
ymp.configs.serv.client.default.port=8281

# 編解碼字符集, 默認(rèn)為UTF-8
ymp.configs.serv.client.default.charset=UTF-8

# 緩沖區(qū)大小, 默認(rèn)為4096
ymp.configs.serv.client.default.buffer_size=4096

# 執(zhí)行線程池大小, 默認(rèn)為10
ymp.configs.serv.client.default.executor_count=10

# 連接超時時間(秒), 默認(rèn)為30
ymp.configs.serv.client.default.connection_timeout=30

# 心跳發(fā)送時間間隔(秒), 默認(rèn)為60
ymp.configs.serv.client.default.heartbeat_interval=60

# 自定義參數(shù), 可選
ymp.configs.serv.client.default.params.xxx=xxx

@Client(reconnectClass = DefaultReconnectService.class,
        hearbeatClass = DefaultHeartbeatService.class, codec = TextLineCodec.class)
public class TcpClient extends NioClientListener {

    @Override
    public void onSessionConnected(INioSession session) throws IOException {
        super.onSessionConnected(session);
        //
        session.send("Hello from client.");
    }

    @Override
    public void onMessageReceived(Object message, INioSession session) throws IOException {
        super.onMessageReceived(message, session);
        //
        System.out.println(session + "--->" + message);
    }

    @Override
    public void onExceptionCaught(Throwable e, INioSession session) throws IOException {
        System.out.println(session + "--->" + e.getMessage(), e);
    }
}

@Client(implClass = NioUdpClient.class, codec = TextLineCodec.class)
public class UdpClient extends NioUdpListener {

    public Object onSessionReady() throws IOException {
        return "Hello from client.";
    }

    public Object onMessageReceived(InetSocketAddress sourceAddr, Object message) throws IOException {
        System.out.println(sourceAddr + "--->" + message);
        return null;
    }

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