AbstractVirtualBoxClientHandler.java
3.9 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
95
96
97
98
99
100
101
102
103
104
105
106
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.nio.charset.StandardCharsets;
/**
* @author dy
*/
@Data
public abstract class AbstractVirtualBoxClientHandler<RECEIVE extends BaseReceiveMessage>
extends IoHandlerAdapter {
protected AbstractClientMessage clientMessage;
protected AbstractHardwareDataBuffer hardwareDataBuffer;
private SendMessage sendMessage = new SendMessage();
private BaseReceiveMessage receiveMessage;
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) {
if (message instanceof BaseReceiveMessage) {
receiveMessage = (RECEIVE) message;
}
handleCommandResponse(sendMessage, receiveMessage);
System.out.println("客户端messageReceived被调用!");
System.out.println("client端接收信息:" + new String(receiveMessage.getReceiveMessage(), StandardCharsets.UTF_8));
LogUtils.println("client端接收信息hex:" , receiveMessage.getReceiveMessage());
}
@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);
this.sendMessage = SendMessage.builder().sendMessage((byte[]) message).build();
}
@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(SendMessage sendMessage, BaseReceiveMessage receiveMessage);
}