diff options
author | 2016-06-24 15:06:58 +0300 | |
---|---|---|
committer | 2016-06-24 15:06:58 +0300 | |
commit | 095dee1388919eac7d3a3fa6fc93767f82c16365 (patch) | |
tree | 094ecad722a7a99ecbbabfb370fbdf51d80e8f11 /src/main/java/com/juick/jabber/ws/WSConnections.java | |
parent | 27e6c9c5edb2642c31735fcb0effb9acd82bd4af (diff) |
spring-jdbc
Diffstat (limited to 'src/main/java/com/juick/jabber/ws/WSConnections.java')
-rw-r--r-- | src/main/java/com/juick/jabber/ws/WSConnections.java | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/src/main/java/com/juick/jabber/ws/WSConnections.java b/src/main/java/com/juick/jabber/ws/WSConnections.java deleted file mode 100644 index 15fbe4e8..00000000 --- a/src/main/java/com/juick/jabber/ws/WSConnections.java +++ /dev/null @@ -1,44 +0,0 @@ -package com.juick.jabber.ws; - -import java.net.InetSocketAddress; -import java.nio.channels.SelectionKey; -import java.nio.channels.Selector; -import java.nio.channels.ServerSocketChannel; -import java.nio.channels.SocketChannel; -import java.util.Iterator; - -/** - * - * @author ugnich - */ -public class WSConnections implements Runnable { - - Selector sel; - - @Override - public void run() { - try { - sel = Selector.open(); - ServerSocketChannel listensock = ServerSocketChannel.open(); - listensock.configureBlocking(false); - listensock.socket().bind(new InetSocketAddress(8081)); - listensock.register(sel, SelectionKey.OP_ACCEPT); - - while (true) { - sel.select(); - Iterator<SelectionKey> it = sel.selectedKeys().iterator(); - while (it.hasNext()) { - SelectionKey selKey = it.next(); - it.remove(); - ServerSocketChannel ssChannel = (ServerSocketChannel) selKey.channel(); - SocketChannel sChannel = ssChannel.accept(); - sChannel.configureBlocking(false); - sChannel.register(sel, SelectionKey.OP_READ); - System.out.println(sChannel.socket().getRemoteSocketAddress().toString() + " ACCEPTED"); - } - } - } catch (Exception e) { - System.err.println("WSConnections: " + e); - } - } -} |