zdm/java-nio-server
Archived
3
Fork 0
Code Issues Pull Requests Releases 1 Activity

Added getters for SocketAcceptor and SocketProcessor to Server

Browse Source
This commit is contained in:
Kai S. K. Engelbart
2020-01-03 17:55:37 +02:00
parent ef44963f20
commit 35bce6dae7
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/jenkov/nioserver/Server.java
View File

@@ -13,7 +13,7 @@ import java.util.concurrent.ArrayBlockingQueue;
*/ */
public class Server { public class Server {
private SocketAcceptor socketAccepter; private SocketAcceptor socketAcceptor;
private SocketProcessor socketProcessor; private SocketProcessor socketProcessor;
private int tcpPort; private int tcpPort;
@@ -30,17 +30,21 @@ public class Server {
Queue<Socket> socketQueue = new ArrayBlockingQueue<>(1024); // TODO: move 1024 to ServerConfig Queue<Socket> socketQueue = new ArrayBlockingQueue<>(1024); // TODO: move 1024 to ServerConfig
socketAccepter = new SocketAcceptor(tcpPort, socketQueue); socketAcceptor = new SocketAcceptor(tcpPort, socketQueue);
MessageBuffer readBuffer = new MessageBuffer(); MessageBuffer readBuffer = new MessageBuffer();
MessageBuffer writeBuffer = new MessageBuffer(); MessageBuffer writeBuffer = new MessageBuffer();
socketProcessor = new SocketProcessor(socketQueue, readBuffer, writeBuffer, this.messageReaderFactory, this.messageProcessor); socketProcessor = new SocketProcessor(socketQueue, readBuffer, writeBuffer, this.messageReaderFactory, this.messageProcessor);
Thread accepterThread = new Thread(socketAccepter); Thread accepterThread = new Thread(socketAcceptor);
Thread processorThread = new Thread(socketProcessor); Thread processorThread = new Thread(socketProcessor);
accepterThread.start(); accepterThread.start();
processorThread.start(); processorThread.start();
} }
public SocketAcceptor getSocketAcceptor() { return socketAcceptor; }
public SocketProcessor getSocketProcessor() { return socketProcessor; }
} }