Pub / Sub Architecture

Question

I am trying to write a pub / subsystem (client and server) where the client receives regular updates (for example, heartbeat, message management) and can issue a command to the server (subscribe to some source, ....).

What would be a good way to do this? I already have a server that implements threadpool to manage an incoming client connection.

I was wondering how to handle the fact that both sides of the connection can read or write data to NetworkStream. In addition, more of my clients will actually issue very few commands to the server (mainly to subscribe to some data, and then just get regular updates). I am trying to use a simple socket, tcpclient, tcplistner (I will see later about WCF)

thanks dave

Answer 1

Or something free, like pubsub using MSMQ and WCF.

http://dotnetslackers.com/CSharp/re-108306_Building_a_Pub_Sub_Message_Bus_with_WCF_and_MSMQ.aspx

Answer 2

Try NServiceBus , MassTransit or Rhino Service Bus

There are actually some good things about the three of them on SO ( nServiceBus, Rhino Service Bus, MassTransit - Video, Demo, Learning Resources )

Answer 3

NServiceBus, .