Skip to content
master
Go to file
Code
This branch is 5 commits behind NetMQ:master.

Latest commit

 

Git stats

Files

Permalink
Failed to load latest commit information.
Type
Name
Latest commit message
Commit time
src
 
 
 
 
 
 
 
 

README.md

NetMQ.WebSockets

NetMQ WebSockets is an extension to NetMQ, implemented using Stream socket type and providing a NetMQ like interface.

NetMQ and ZeroMQ don't support pluggable transport, therefore the library provides its own socket object which is very similar to the NetMQ socket object.

Hopefully in the near future the library will be integrated into NetMQ as another transport.

Currently only the router and publisher patterns are implemented and you can only bind the socket.

You are probably asking yourselves, "If I can only bind the socket, then how can one connect to the socket?" That's where JSMQ comes into play. JSMQ is ZeroMQ/NetMQ javascript client which connect and talk to the NetMQ.WebSockets, over WebSockets off course.

To install NetMQ.WebSockets, search for it on nuget and make sure to choose "Include Prerelease".

To install JSMQ you can dowload the JSMQ.JS file from JSMQ github page or from nuget as well, just search JSMQ.

This is early beta and not ready for production use, but don't let that stop you from trying it out, giving feedback, or even better sending a pull request.

Without further adieu, following is a small chat example:

using (NetMQContext context = NetMQContext.Create())
{
    using (WSRouter router = context.CreateWSRouter())
    using (WSPublisher publisher = context.CreateWSPublisher())
    {
        router.Bind("ws://localhost:80");                    
        publisher.Bind("ws://localhost:81");

        router.ReceiveReady += (sender, eventArgs) =>
        {
            byte[] identity = eventArgs.WSSocket.Receive();
            string message = eventArgs.WSSocket.ReceiveString();

            // let the webbrowser know we got the message
            eventArgs.WSSocket.SendMore(identity).Send("OK");

            // the topic is "chat" and than we send the message
            publisher.SendMore("chat").Send(message);
        };
            
        Poller poller = new Poller();
        poller.AddSocket(router);

        poller.Start();

    }
}

For JSMQ example please visit the JSMQ github page.

About

WebSockets extension to NetMQ

Resources

License

Releases

No releases published

Packages

No packages published

Languages

You can’t perform that action at this time.