1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.mina.example.tennis;
21
22 import org.apache.mina.core.service.IoHandler;
23 import org.apache.mina.core.service.IoHandlerAdapter;
24 import org.apache.mina.core.session.IoSession;
25
26
27
28
29
30
31 public class TennisPlayer extends IoHandlerAdapter {
32 private static int nextId = 0;
33
34
35 private final int id = nextId++;
36
37 @Override
38 public void sessionOpened(IoSession session) {
39 System.out.println("Player-" + id + ": READY");
40 }
41
42 @Override
43 public void sessionClosed(IoSession session) {
44 System.out.println("Player-" + id + ": QUIT");
45 }
46
47 @Override
48 public void messageReceived(IoSession session, Object message) {
49 System.out.println("Player-" + id + ": RCVD " + message);
50
51 TennisBall ball = (TennisBall) message;
52
53
54 ball = ball.stroke();
55
56 if (ball.getTTL() > 0) {
57
58 session.write(ball);
59 } else {
60
61 System.out.println("Player-" + id + ": LOSE");
62 session.close(true);
63 }
64 }
65
66 @Override
67 public void messageSent(IoSession session, Object message) {
68 System.out.println("Player-" + id + ": SENT " + message);
69 }
70
71 @Override
72 public void exceptionCaught(IoSession session, Throwable cause) {
73 cause.printStackTrace();
74 session.close(true);
75 }
76 }