AbstractVirtualBoxClientHandler.java 2.67 KB
package com.example.mina.client.base;


import com.example.mina.client.entity.Command;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

import java.net.InetSocketAddress;
import java.nio.charset.Charset;

public abstract class AbstractVirtualBoxClientHandler extends IoHandlerAdapter {

    protected Command command;

    public AbstractVirtualBoxClientHandler(Command command) {
        this.command = command;
    }

    @Override
    public void exceptionCaught(IoSession session, Throwable throwable) {
        System.out.println("客户端exceptionCaught被调用!");
        throwable.printStackTrace();
    }

    @Override
    public void messageReceived(IoSession session, Object message) {
        System.out.println("客户端messageReceived被调用!");
        System.out.println("client端接收信息:" + message.toString());
    }

    @Override
    public void messageSent(IoSession session, Object message) {
        System.out.println("客户端messageSent被调用!");
        System.out.println("client端发送信息:" + message.toString());
    }

    @Override
    public void inputClosed(IoSession session) {
        System.out.println("客户端inputClosed被调用!");
        System.out.println("client端:" + session.getId() + " 关闭输入");
    }

    @Override
    public void sessionClosed(IoSession session) {
        System.out.println("客户端sessionClosed被调用!");
        System.out.println("client端与:" + session.getRemoteAddress().toString() + " 关闭连接");
        System.exit(0);
    }

    @Override
    public void sessionCreated(IoSession session) {
        System.out.println("客户端sessionCreated被调用!");
        System.out.println("client端与:" + session.getRemoteAddress().toString() + " 建立连接");
    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status) {
        System.out.println("客户端sessionIdle被调用!");
        System.out.println("client端闲置连接:会话 " + session.getId() + " 被触发 " + session.getIdleCount(status) + " 次");
    }

    @Override
    public void sessionOpened(IoSession session) {
        session.write(command.getBytes());
        System.out.println("客户端sessionOpened被调用!");
        System.out.println("client端打开连接");
    }

}