1 package be
.nikiroo
.utils
.serial
.server
;
3 import java
.io
.IOException
;
4 import java
.net
.Socket
;
5 import java
.net
.UnknownHostException
;
8 * This class implements a simple server that can listen for connections and
9 * send/receive objects.
11 * Note: this {@link ServerObject} has to be discarded after use (cannot be
16 abstract public class ServerObject
extends Server
{
18 * Create a new server that will start listening on the network when
19 * {@link ServerObject#start()} is called.
22 * the port to listen on, or 0 to assign any unallocated port
23 * found (which can later on be queried via
24 * {@link ServerObject#getPort()}
26 * an optional key to encrypt all the communications (if NULL,
27 * everything will be sent in clear text)
30 * in case of I/O error
31 * @throws UnknownHostException
32 * if the IP address of the host could not be determined
33 * @throws IllegalArgumentException
34 * if the port parameter is outside the specified range of valid
35 * port values, which is between 0 and 65535, inclusive
37 public ServerObject(int port
, String key
) throws IOException
{
42 * Create a new server that will start listening on the network when
43 * {@link ServerObject#start()} is called.
46 * the server name (only used for debug info and traces)
48 * the port to listen on
50 * an optional key to encrypt all the communications (if NULL,
51 * everything will be sent in clear text)
54 * in case of I/O error
55 * @throws UnknownHostException
56 * if the IP address of the host could not be determined
57 * @throws IllegalArgumentException
58 * if the port parameter is outside the specified range of valid
59 * port values, which is between 0 and 65535, inclusive
61 public ServerObject(String name
, int port
, String key
) throws IOException
{
62 super(name
, port
, key
);
66 protected ConnectActionServer
createConnectActionServer(Socket s
) {
67 return new ConnectActionServerObject(s
, key
) {
69 public void action() throws Exception
{
71 for (Object data
= rec(); true; data
= rec()) {
74 rep
= onRequest(this, data
);
78 } catch (Exception e
) {
84 } catch (NullPointerException e
) {
85 // Client has no data any more, we quit
90 protected void onError(Exception e
) {
91 ServerObject
.this.onError(e
);
97 * This is the method that is called on each client request.
99 * You are expected to react to it and return an answer (which can be NULL).
104 * the data sent by the client (which can be NULL)
106 * @return the answer to return to the client (which can be NULL)
109 * in case of an exception, the error will only be logged
111 abstract protected Object
onRequest(ConnectActionServerObject action
,
112 Object data
) throws Exception
;