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));
        }



    }

}