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.lang.management.ManagementFactory;
23 import java.net.InetSocketAddress;
24 import java.util.concurrent.Executors;
25
26 import javax.management.MBeanServer;
27 import javax.management.ObjectName;
28
29 import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
30 import org.apache.mina.example.imagine.step1.codec.ImageCodecFactory;
31 import org.apache.mina.filter.codec.ProtocolCodecFilter;
32 import org.apache.mina.filter.executor.ExecutorFilter;
33 import org.apache.mina.integration.jmx.IoFilterMBean;
34 import org.apache.mina.integration.jmx.IoServiceMBean;
35 import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
36
37
38
39
40
41
42
43 public class ImageServer {
44 public static final int PORT = 33789;
45
46 public static void main(String[] args) throws Exception {
47
48
49 MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
50
51
52
53
54 ImageServerIoHandler handler = new ImageServerIoHandler( mBeanServer );
55
56
57 NioSocketAcceptor acceptor = new NioSocketAcceptor();
58
59
60
61 IoServiceMBean acceptorMBean = new IoServiceMBean( acceptor );
62
63
64 ObjectName acceptorName = new ObjectName( acceptor.getClass().getPackage().getName() +
65 ":type=acceptor,name=" + acceptor.getClass().getSimpleName());
66
67
68
69 mBeanServer.registerMBean( acceptorMBean, acceptorName );
70
71
72
73 ProtocolCodecFilter protocolFilter = new ProtocolCodecFilter(new ImageCodecFactory(false));
74
75
76
77 IoFilterMBean protocolFilterMBean = new IoFilterMBean( protocolFilter );
78
79
80 ObjectName protocolFilterName = new ObjectName( protocolFilter.getClass().getPackage().getName() +
81 ":type=protocolfilter,name=" + protocolFilter.getClass().getSimpleName() );
82
83
84
85 mBeanServer.registerMBean( protocolFilterMBean, protocolFilterName );
86
87
88 acceptor.getFilterChain().addLast("protocol", protocolFilter);
89
90
91 DefaultIoFilterChainBuilder filterChainBuilder = acceptor.getFilterChain();
92
93
94
95
96 filterChainBuilder.addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool()));
97
98
99 acceptor.setHandler(handler);
100
101
102
103 acceptor.bind(new InetSocketAddress(PORT));
104 System.out.println("Step 3 server is listenig at port " + PORT);
105 }
106 }