채널 이벤트 계층 개발

public class ExampleHandler extends ChannelEventHandler {
    private SocketChannel socketChannel;
    private ByteBuffer    readBuffer;
    private ByteBuffer    writeBuffer;

    public ExampleHandler(SocketChannel socketChannel) throws IOException {
        this.socketChannel = socketChannel;
        init(SelectionKey.OP_READ);
    }

    @Override
    public void init(int interestOps) throws IOException {
        setChannel(socketChannel);
        ChannelManager.register(socketChannel, this, interestOps);

        readBuffer = ByteBuffer.allocateDirect(HEADER_SIZE);
    }

    @Override
    public void onRead(AbstractSelectableChannel channel) {
        try {
            if(readBuffer.hasRemaining()) {
                if(socketChannel.read(readBuffer) <= 0) {
                    close();
                }
            }

            if(readBuffer.hasReamining()) {
                // handle header
            }
        } catch (Throwable e) {
            onError(channel, e);
        }
    }

    @Override
    public void onWrite(AbstractSelectableChannel channel, Object data, UserContext userContext, long requestId) {
        try {
            byte[] bytes = (byte[])data;
            writeBuffer = ByteBuffer.allocate(bytes.length);
            writeBuffer.put(bytes);
            ChannelManager.register(socketChannel, this, SelectionKey.OP_WRITE);
        } catch (Throwable e) {
            onError(channel, e);
        }
    }

    @Override
    public void onWritable(AbstractSelectableChannel channel) {
        try {
            if(writeBuffer.hasRemaining() == false) {
                writeBuffer = null;
                ChannelManager.update(getChannel(), SelectionKey.OP_READ);
            }
        } catch (Throwable e) {
            onError(channel, e);
        }
    }

    @Override
    public void onConnect(AbstractSelectableChannel channel) { }

    @Override
    public void onError(AbstractSelectableChannel channel, Throwable error) {
        if(logger.isLoggable(Level.SEVERE)) {
            logger.severe("Exception is occured!", error);
        }
        close();
    }
}

MessageChannelEventHandler(SocketChannel channel)
MessageChannelEventHandler(SocketChannel channel, int initialHeaderLength)

void readMessage(int length)
void readMessage(int length, ReadMessageListener listener)

void onMessageReceive(AbstractSelectableChannel channel, ByteBuffer buffer)

interface ReadMessageListener {
    public void onComplete(AbstractSelectableChannel channel, ByteBuffer buffer);
    public void onError(AbstractSelectableChannel channel, Throwable exceptoin);
}

Header header = ChannelEventHandlerUtil.unmarshalHeader(headerDataObjectClassName, bytes, ProMapperMessageType.FLD);
readMessage(header.getBodyLength(), new ReadMessageListener() {
    @Override
    public void onError(AbstractSelectableChannel channel, Throwable exception) {
        // 오류 처리.
    }

    @Override
    public void onComplete(AbstractSelectableChannel channel, ByteBuffer buffer) {
        // 메시지 처리.
    }
});

void writeMessage(byte[] buffer)
void writeMessage(byte[] buffer, WriteMessageListener listener)
void writeMessage(ByteBuffer buffer)
void writeMessage(ByteBuffer buffer, WriteMessageListener listener)

void onMessageSent(AbstractSelectableChannel channel)

interface WriteMessageListener {
    public void onComplete(AbstractSelectableChannel channel, ByteBuffer buffer);
    public void onError(AbstractSelectableChannel channel, Throwable exceptoin);
}

// 메시지를 보낸 이후 다른 메시지를 기다린다.
byte[] bytes = new bytes[bodyLength];
...
writeMessage(bytes, new WriteMessageListener() {
    @Override
    public void onError(AbstractSelectableChannel channel, Throwable exception) {
        // 오류 처리.
    }

    @Override
    public void onComplete(AbstractSelectableChannel channel, ByteBuffer buffer) {
        readMessage(...);  // ACK 메시지를 읽어들이도록 지정한다.
    }
});

public class ExampleMessageChannelEventHandler extends MessageChannelEventHandler {
    private ProObjectLogger logger = ChannelEventLogger.getLogger();

    public ExampleMessageChannelEventHandler(SocketChannel channel)
     throws InstantiationException, IllegalAccessException, ClassNotFoundException {
        this(channel, 4);
    }

    @Override
    public void onMessageReceive(AbstractSelectableChannel channel, ByteBuffer buffer) {
        try {
            int bodyLength = buffer.getInt();
            readMessage(bodyLength, new ReadMessageListener() {
                @Override
                public void onError(AbstractSelectableChannel channel, Throwable exception) {
                    logger.severe("[ExampleMessageChannelEventHandler] Exception is occured while receiving header!\r\n"
                            + "Client IP   : {0}\r\n"
                            + "Client Port : {1}", getRemoteIp(), String.valueOf(getRemotePort()), exception);
                }

                @Override
                public void onComplete(AbstractSelectableChannel channel, ByteBuffer buffer) {
                    byte[] bytes = new byte[buffer.limit()];
                    buffer.get(bytes);
                    buffer = null;

                    writeMessage(bytes);
                }
            });
        } catch (Throwable e) {
            logger.severe("[ExampleMessageChannelEventHandler] Exception is occured while unmarshaling header!\r\n"
                    + "Client IP   : {0}\r\n"
                    + "Client Port : {1}", getRemoteIp(), String.valueOf(getRemotePort()), e);
        }
    }

    @Override
    public void onMessageSent(AbstractSelectableChannel channel) {
        close();

        logger.info("[ExampleMessageChannelEventHandler] Response complete. Channel closed.\r\n"
                + "Client IP   : {0}\r\n"
                + "Client Port : {1}", getRemoteIp(), String.valueOf(getRemotePort()));
    }
}

<channel-config>
    <channel-accept-handler>
        <name>exampleAccepter</name>
        <class-name>com.tmax.proobject.example.channel.ExampleAccepter</class-name>
    </channel-accept-handler>
</channel-config>

<channel-config>
    <channel-event-handler>
        <name>exampleHandler</name>
        <class-name>com.tmax.proobject.example.channel.ExampleHandler</class-name>
        <keep-connection>false</keep-connection>
        <reconnect-count>0</reconnect-count>
        <reconnect-period>300000</reconnect-period>
    </channel-event-handler>
</channel-config>

<channel-config>
    <channel-accept-handler>
        <name>exampleAccepter</name>
        <class-name>com.tmax.proobject.example.channel.ExampleAccepter</class-name>
    </channel-accept-handler>
    <server-channel>
        <port>5000</port>
        <accept-handler>exampleAccepter</accept-handler>
    </server-channel>
</channel-config>

<channel-config>
    <channel-event-handler>
        <name>exampleHandler</name>
        <class-name>com.tmax.proobject.example.channel.ExampleHandler</class-name>
    </channel-event-handler>
    <client-channel>
        <name>example_Client_1</name>
        <mode>R</mode>
        <ip>5000</port>
        <port>5000</port>
        <channel-handler>exampleHandler</channel-handler>
        <keep-connection>false</keep-connection>
        <reconnect-count>0</reconnect-count>
        <reconnect-period>300000</reconnect-period>
    </client-channel>
</channel-config>

ChannelEventManager.endEvent(UserContext userContext)