AbstractVirtualBoxClientHandler.java
3.59 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
package com.example.mina.client.base;
import com.example.mina.client.entity.AbstractClientMessage;
import com.example.mina.client.entity.Command;
import com.example.mina.server.base.AbstractHardwareDataBuffer;
import com.example.mina.server.util.LogUtils;
import lombok.Data;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import java.io.UnsupportedEncodingException;
import java.nio.charset.StandardCharsets;
@Data
public abstract class AbstractVirtualBoxClientHandler extends IoHandlerAdapter {
protected AbstractClientMessage clientMessage;
protected AbstractHardwareDataBuffer hardwareDataBuffer;
public AbstractVirtualBoxClientHandler(AbstractClientMessage clientMessage,
AbstractHardwareDataBuffer abstractHardwareDataBuffer) {
this.clientMessage = clientMessage;
this.hardwareDataBuffer = abstractHardwareDataBuffer;
}
@Override
public void exceptionCaught(IoSession session, Throwable throwable) {
System.out.println("客户端exceptionCaught被调用！");
throwable.printStackTrace();
}
@Override
public void messageReceived(IoSession session, Object message) {
handleCommandResponse(clientMessage.getCommands().get(1).getBytes(), (byte[]) message, ((byte[]) message).length);
System.out.println("客户端messageReceived被调用！");
System.out.println("client端接收信息：" + new String((byte[])message, StandardCharsets.UTF_8));
LogUtils.println("client端接收信息hex：",(byte[])message);
}
@Override
public void messageSent(IoSession session, Object message) {
System.out.println("客户端messageSent被调用！");
System.out.println("client端发送信息：" + new String((byte[])message, StandardCharsets.UTF_8));
LogUtils.println("client端发送信息hex：",(byte[])message);
}
@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) {
// for (int i = 0; i < clientMessage.getCommands().size(); i++) {
// handleOneCommand(i, session);
// }
// handleOneCommand(1, session);
System.out.println("客户端sessionOpened被调用！");
System.out.println("client端打开连接");
}
protected void handleOneCommand(int i, IoSession session) {
Command command = clientMessage.getCommands().get(i);
session.write(command.getBytes());
}
protected abstract boolean handleCommandResponse(byte[] cmd, byte[] response, int responseLen);
}