xsocket-develop Mailing List for xsocket (Page 16)

SourceForge Headquarters 1320 Columbia Street Suite 310 San Diego, CA 92101 +1 (858) 422-6466

Hi Jeff,

by implementing the onConnect and onDisconnect method you are able to manage
the open connections. See enclosed example. Does this answer your question?

Gregor

private static final class Test implements IDataHandler, IConnectHandler,
IDisconnectHandler {

    private final HashMap<String, INonBlockingConnection> openConnections =
new HashMap<String,INonBlockingConnection>();

    public boolean onConnect(INonBlockingConnection connection) throws
IOException, BufferUnderflowException, MaxReadSizeExceededException {
        connection.setIdleTimeoutMillis(30 * 60 * 1000); // if not data is
be received within 30 min, the connection will be closed

        synchronized (openConnections) {
            openConnections.put(connection.getId(), connection);
        }
        return true;
    }

    public boolean onDisconnect(INonBlockingConnection connection) throws
IOException {
        synchronized (openConnections) {
            openConnections.remove(connection.getId());
        }
        return true;
    }

    public boolean onData(INonBlockingConnection connection) throws
IOException, BufferUnderflowException, MaxReadSizeExceededException {

         …
        data = connection.read...
        ...
        send(…);

        return true;
    }

    // will be called concurrently
    private void send(Object message) {

        HashMap<String, INonBlockingConnection> openConnectionsCopy = null;
        synchronized (openConnections) {
            openConnectionsCopy = (HashMap<String, INonBlockingConnection>)
openConnections.clone();
        }

        for (INonBlockingConnection connection :
openConnectionsCopy.values()) {
            try {
                synchronized (connection) {  // connection methods are not
threadsafe
                    connection.write...
                    ...
                }
            } catch (IOException ioe) {
                synchronized (openConnections) {
                    openConnections.remove(connection.getId());
                }
            }
        }
    }
}

Hi Jeff,

by implementing the onConnect and onDisconnect method you are able to manage
the open connections. See enclosed example. Does this answers your question?

Gregor

    private static final class Test implements IDataHandler,
IConnectHandler, IDisconnectHandler {

        private final HashMap<String, INonBlockingConnection>
openConnections = new HashMap<String, INonBlockingConnection>();

        public boolean onConnect(INonBlockingConnection connection) throws
IOException, BufferUnderflowException, MaxReadSizeExceededException {
            connection.setIdleTimeoutMillis(30 * 60 * 1000); // if not data
is be received within 30 min, the connection will be closed

            synchronized (openConnections) {
                openConnections.put(connection.getId(), connection);
            }
            return true;
        }

        public boolean onDisconnect(INonBlockingConnection connection)
throws IOException {
            synchronized (openConnections) {
                openConnections.remove(connection.getId());
            }
            return true;
        }

        public boolean onData(INonBlockingConnection connection) throws
IOException, BufferUnderflowException, MaxReadSizeExceededException {

            …
            data = connection.read...
            ...
            send(…);

            return true;
        }

        // will be called concurrently
        private void send(Object message) {

            HashMap<String, INonBlockingConnection> openConnectionsCopy =
null;
            synchronized (openConnections) {
                openConnectionsCopy = (HashMap<String,
INonBlockingConnection>) openConnections.clone();
            }

            for (INonBlockingConnection connection :
openConnectionsCopy.values()) {
                try {
                    synchronized (connection) {  // connection methods are
not threadsafe
                        connection.write...
                        ...
                    }
                } catch (IOException ioe) {
                    synchronized (openConnections) {
                        openConnections.remove(connection.getId());
                    }
                }
            }
        }
    }

2008/5/29 Jeff Crane <JC...@sp...>:

>  I read and implemented the answer to my first question. ConnectionUtil
> held the function and usage.
>
>
>
> Clientside:
>
>
>
> client = new NonBlockingConnection(…);
>
> ByteArrayOutputStream bos = new ByteArrayOutputStream();
>
> ObjectOutputStream out = new ObjectOutputStream(bos);
>
> out.writeObject(genericObj);
>
> out.writeObject(DELIMITER);
>
> client.write(bos.size());
>
> client.write(bos.toByteArray());
>
>
>
>
>
> Server Protocol Handler in onData(…)
>
> int length =
> ConnectionUtils.validateSufficientDatasizeByIntLengthField(connection);
>
> byte[] test = connection.readBytesByDelimiter(DELIMITER,length);
>
>
>
> ByteArrayInputStream bis = new ByteArrayInputStream(test);
>
> ObjectInputStream incomingObjstream = new ObjectInputStream(bis);
>
>
>
> Object incomingObj = null;
>
> try{
>
>             incomingObj = incomingObjstream.readObject();
>
> }
>
> catch(ClassNotFoundException e){e.printStackTrace();
>
> }
>
> incomingObjstream.close();
>
>
>
> 2. What is the standard practice to index open connections for sending? I
> use my protocol handler to read the object, handle the object, throw an
> event. If the server wants to disconnect or send a message, how do I do a
> lookup? I could do a singleton HashMap or pass a reference in the event
> thrown (which doesn't help if it's interacting with another connection) or
> am I missing something in the xSocket interfaces?
>
> -------------------------------------------------------------------------
> This SF.net email is sponsored by: Microsoft
> Defy all challenges. Microsoft(R) Visual Studio 2008.
> http://clk.atdmt.com/MRT/go/vse0120000070mrt/direct/01/
> _______________________________________________
> xSocket-develop mailing list
> xSo...@li...
> https://lists.sourceforge.net/lists/listinfo/xsocket-develop
>
>

2007	Jan	Feb	Mar	Apr	May	Jun	Jul	Aug	Sep (12)	Oct (9)	Nov (11)	Dec
2008	Jan (8)	Feb (9)	Mar (9)	Apr (22)	May (28)	Jun (17)	Jul (10)	Aug (19)	Sep (4)	Oct (14)	Nov (26)	Dec (25)
2009	Jan (13)	Feb (17)	Mar (12)	Apr (4)	May (16)	Jun (6)	Jul (10)	Aug (24)	Sep (6)	Oct (5)	Nov (13)	Dec (10)
2010	Jan (17)	Feb (21)	Mar (10)	Apr (8)	May (2)	Jun (14)	Jul (7)	Aug (10)	Sep (7)	Oct (3)	Nov	Dec (2)
2011	Jan (1)	Feb (5)	Mar (1)	Apr	May (5)	Jun	Jul (2)	Aug	Sep	Oct	Nov	Dec
2014	Jan	Feb	Mar	Apr	May	Jun	Jul	Aug	Sep (1)	Oct (3)	Nov	Dec
2015	Jan	Feb	Mar (1)	Apr	May	Jun	Jul	Aug	Sep	Oct	Nov (1)	Dec
2016	Jan	Feb	Mar	Apr	May (2)	Jun (3)	Jul	Aug (1)	Sep	Oct	Nov	Dec
2019	Jan	Feb	Mar	Apr	May	Jun	Jul	Aug (6)	Sep	Oct	Nov	Dec
2020	Jan	Feb	Mar	Apr	May	Jun	Jul	Aug	Sep	Oct	Nov	Dec (1)

xsocket-develop Mailing List for xsocket (Page 16)

xsocket-develop — xSocket Support Forum