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.imagine.step3.server;
21
22 import java.awt.Color;
23 import java.awt.Font;
24 import java.awt.Graphics;
25 import java.awt.image.BufferedImage;
26
27 import javax.management.MBeanServer;
28 import javax.management.ObjectName;
29
30 import org.apache.mina.core.service.IoHandlerAdapter;
31 import org.apache.mina.core.session.IoSession;
32 import org.apache.mina.example.imagine.step1.ImageRequest;
33 import org.apache.mina.example.imagine.step1.ImageResponse;
34 import org.apache.mina.integration.jmx.IoSessionMBean;
35 import org.slf4j.Logger;
36 import org.slf4j.LoggerFactory;
37
38
39
40
41
42
43
44 public class ImageServerIoHandler extends IoHandlerAdapter {
45
46 private final static String characters = "mina rocks abcdefghijklmnopqrstuvwxyz0123456789";
47
48 public static final String INDEX_KEY = ImageServerIoHandler.class.getName() + ".INDEX";
49
50 private static Logger LOGGER = LoggerFactory.getLogger(ImageServerIoHandler.class);
51
52 private MBeanServer mBeanServer;
53
54
55
56
57
58
59
60
61
62 public ImageServerIoHandler( MBeanServer mBeanServer ) {
63 this.mBeanServer = mBeanServer;
64 }
65
66
67
68
69
70
71
72 public void sessionCreated( IoSession session ) throws Exception
73 {
74
75
76 IoSessionMBean sessionMBean = new IoSessionMBean( session );
77
78
79 ObjectName sessionName = new ObjectName( session.getClass().getPackage().getName() +
80 ":type=session,name=" + session.getClass().getSimpleName() + "-" + session.getId());
81
82
83
84 mBeanServer.registerMBean( sessionMBean, sessionName );
85 }
86
87
88
89
90
91
92 public void sessionOpened(IoSession session) throws Exception {
93
94
95
96 session.setAttribute(INDEX_KEY, 0);
97 }
98
99
100
101
102
103
104
105 public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
106 LOGGER.warn(cause.getMessage(), cause);
107 }
108
109
110
111
112
113
114 public void messageReceived(IoSession session, Object message) throws Exception {
115 ImageRequest request = (ImageRequest) message;
116 String text1 = generateString(session, request.getNumberOfCharacters());
117 String text2 = generateString(session, request.getNumberOfCharacters());
118 BufferedImage image1 = createImage(request, text1);
119 BufferedImage image2 = createImage(request, text2);
120 ImageResponse response = new ImageResponse(image1, image2);
121 session.write(response);
122 }
123
124
125
126
127
128
129
130
131
132
133
134 private BufferedImage createImage(ImageRequest request, String text) {
135 BufferedImage image = new BufferedImage(request.getWidth(), request.getHeight(), BufferedImage.TYPE_BYTE_INDEXED);
136 Graphics graphics = image.createGraphics();
137 graphics.setColor(Color.YELLOW);
138 graphics.fillRect(0, 0, image.getWidth(), image.getHeight());
139 Font serif = new Font("serif", Font.PLAIN, 30);
140 graphics.setFont(serif);
141 graphics.setColor(Color.BLUE);
142 graphics.drawString(text, 10, 50);
143 return image;
144 }
145
146
147
148
149
150
151
152
153
154
155
156
157
158 private String generateString(IoSession session, int length) {
159 Integer index = (Integer) session.getAttribute(INDEX_KEY);
160 StringBuilder buffer = new StringBuilder(length);
161 while (buffer.length() < length) {
162 buffer.append(characters.charAt(index));
163 index++;
164 if (index >= characters.length()) {
165 index = 0;
166 }
167 }
168 session.setAttribute(INDEX_KEY, index);
169 return buffer.toString();
170 }
171
172 }