YMP ??? ???
/ 客戶端（Client）示例
客戶端（Client）示例
客戶端初始化參數(shù)：
#------------------------------------- # 服務(wù)模塊--客戶端初始化參數(shù) #------------------------------------- # 客戶端配置列表，多個客戶端名稱間用'|'分隔，默認為default ymp.configs.serv.client.name_list=default # 服務(wù)名稱, 默認為default ymp.configs.serv.client.default.name=default # 遠程主機IP地址, 默認為0.0.0.0 ymp.configs.serv.client.default.host=0.0.0.0 # 遠程主機端口號, 默認為8281 ymp.configs.serv.client.default.port=8281 # 編解碼字符集, 默認為UTF-8 ymp.configs.serv.client.default.charset=UTF-8 # 緩沖區(qū)大小, 默認為4096 ymp.configs.serv.client.default.buffer_size=4096 # 執(zhí)行線程池大小, 默認為10 ymp.configs.serv.client.default.executor_count=10 # 連接超時時間(秒), 默認為30 ymp.configs.serv.client.default.connection_timeout=30 # 心跳發(fā)送時間間隔(秒), 默認為60 ymp.configs.serv.client.default.heartbeat_interval=60 # 自定義參數(shù), 可選 ymp.configs.serv.client.default.params.xxx=xxx
通過在監(jiān)聽器實現(xiàn)類聲明@Client注解來表示一個客戶端，該注解有如下參數(shù)：
基于TCP協(xié)議的客戶端，需要繼承NioClientListener監(jiān)聽器類，支持監(jiān)聽如下事件：
基于UDP協(xié)議的客戶端，需要繼承NioUdpListener監(jiān)聽器類，支持監(jiān)聽如下事件：
示例代碼
TCP客戶端
@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);
}
}UDP客戶端
@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);
}
}