StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POSeparate threads for input and output in Java TCP Server
primarykey
Id
5440317
data
AcceptedAnswerId
5440538
AnswerCount
1
ClosedDate
CommentCount
0
CommunityOwnedDate
CreationDate
2011-03-26T04:06:37.417
FavoriteCount
0
LastActivityDate
2011-03-26T06:02:34.657
LastEditDate
LastEditorUserId
0
OwnerUserId
677680
ParentId
0
PostTypeId
1
Score
0
ViewCount
2235
LastEditorDisplayName
text
Body
I've been tasked with writing a tcp server and client in Java. I'm having some trouble working out the general structure of my server. The server must accept multiple connections but there is no request response protocol. Once a connection is made, the client can send data to the server, and the server can send data to the client. Given this, I decided it would be a good idea for each connection to have seperate input and output threads. I've looked through lots of examples but most are quite simple and don't have separate threads for input and output. I'd greatly appreciate any help or advice. So far, my the tcp server has a listening thread which listens for client connections. Once a connection is made, I create an input thread and an output thread for that connection. In TCPServer <pre><code>while (true) { SocketChannel clientChannel = m_serverChannel.accept(); new Thread(new ReadWorker(clientChannel)).start(); new Thread(new WriteWorker(clientChannel)).start(); } </code></pre> How should I pass the data to be sent to the output threads? My initial thoughts were to have the output threads listen on a queue of pending data, sending the data as it becomes available. In TCPServer <pre><code>ConcurrentHashMap<SocketChannel, LinkedBlockingQueue<ByteBuffer>> pendingWrites = new ConcurrentHashMap<SocketChannel, LinkedBlockingQueue<ByteBuffer>>(); void broadcast(ByteBuffer buffer) { synchronized(pendingWrites) { Iterator it = pendingWrites.entrySet().iterator(); while (it.hasNext()) { Map.Entry pairs = (Map.Entry)it.next(); ((LinkedBlockingQueue<ByteBuffer>) pairs.getValue()).put(buffer); } } </code></pre> In WriteWorker <pre><code>pendingWrites.get(socketChannel).take() // send the data </code></pre> Is this a reasonable solution? The other problem I'm having is if one worker fails due to client disconnection, how can I communicate this to the other thread? If there is a failure in one thread, I'd like to terminate the other. Thanks
Tags
<java><multithreading><tcp><client>
Title
Separate threads for input and output in Java TCP Server
singulars
PostAcceptedAnswerId
1. PO
 singulars
 PostTypePostTypeId
 PTAnswer
PostParentId
1. This table or related slice is empty.
PostTypePostTypeId
1. PTQuestion
UserLastEditorUserId
1. This table or related slice is empty.
UserOwnerUserId
1. USStirls
plurals
PostLinksPostIdRelatedPostId
1. PL
 singulars
 LinkTypeLinkTypeId
 LTLinked
PostLinksRelatedPostIdPostId
1. This table or related slice is empty.
PostsAcceptedAnswerId
1. This table or related slice is empty.
PostsParentIdCreationDate
1. PO
 singulars
 PostTypePostTypeId
 PTAnswer
VotesPostIdCreationDate
1. This table or related slice is empty.
CommentsPostId
1. This table or related slice is empty.

Querying!

Guidance

A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.