package com.ld.io.netty.server;
|
|
import com.alibaba.fastjson.JSON;
|
import com.ld.io.api.InvokeResult;
|
import com.ld.io.api.IoSession;
|
import com.ld.io.api.IoSessionQuery;
|
import com.ld.io.api.IoServerOption;
|
import com.ld.io.netty.NettyServer;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import java.io.UnsupportedEncodingException;
|
import java.util.List;
|
|
public class IoServerTest {
|
private final static Logger logger = LoggerFactory.getLogger(IoServerTest.class);
|
private static DefaultMessageConsume messageConsume = new DefaultMessageConsume();
|
private static DefaultIoSessionListener defaultIoSessionListener = new DefaultIoSessionListener();
|
|
public static void main(String[] args) throws InterruptedException, UnsupportedEncodingException {
|
IoServerOption ioServerOption = new IoServerOption();
|
ioServerOption.setDelimiter("AA".getBytes("UTF-8"));
|
|
NettyServer ioServer = new NettyServer(ioServerOption, messageConsume, defaultIoSessionListener);
|
ioServer.startup();
|
|
Thread.sleep(15000);
|
|
IoSessionQuery sessionFactory = ioServer.getSessionQuery();
|
List<IoSession> sessions = sessionFactory.getAllSession();
|
for (IoSession session : sessions) {
|
logger.info("start send second message!");
|
InvokeResult invoke = session.invoke("EEFFAA".getBytes("UTF-8"));
|
logger.info("second invoke result=" + invoke);
|
|
logger.info(JSON.toJSONString(session));
|
}
|
|
|
|
}
|
|
}
|
