/ ___ ___ (___ | )| )|___ | ) |__/ |__/ __/ | / | A Realtime Ruby web application toolkit
What is Push?
How is it different from socket.io?
socket.io attempts to store connection state per node instance. Push makes no attempt to store connection state.
Also, socket.io attempts to abstract a low-latency full-duplex port. Push assumes that its impossible to simulate this in older web browsers that don't support WebSockets. As such, Push focuses on low-latency server-to-client connections and encourages the use of HTTP transports for client-to-server communications.
Finally, push attempts to solve data consistency issues and authentication by encourage the use of proxying to the web application.
First, you'll need to install RabbitMQ. In the future, Push may support multiple backends, but for now we use RabbitMQ. Fire up that daemon and we'll setup the server.
The consumer is the web server that your client connects to for real-time updates. Create a config.ru file with the following:
require 'rubygems' require 'push' run Push::Transport::Dispatcher.new do |config| config.timeout = 20 # Extract the consumer ID from the HTTP session. This could be a cookie # query param, or whatever. config.consumer = Proc.new do |env| Push::Consumer.new(env['HTTP_CONSUMER_ID']) end # Use the /url/path for the queue channel. You could change this to a query # param, or whatever config.channel = Proc.new do |env| env['PATH_INFO'] end end
Now run the config.ru file in a server that supports async Rack callbacks (like thin or rainbows)
thin -R config.ru -p 4000 start
Lets test the producer! Open two terminal windows. In one window, curl the consumer server:
Then run the following script in another terminal:
require 'rubygems' require 'push' Push::Producer.new.publish('hi there!').to('/greetings')
In your browser be sure to include these files, in this specific order:
Then in your browser create a new Push Client object like so:
# Handlers onMessage = (json) -> # Handle a message pushed from the server! onConnected = -> onDisconnected = -> onError = -> urls = websocket: 'http://some_websocket_url.com' longpoll: 'http://some_longpoll_url.com' # Misc options for transports options = timeout: 5000 # URL params params = sid: 123 # Chained initializer new Push.Client() .url(urls) .params(params) .message(onMessage) .options(options) .connected(onConnected) .disconnected(onDisconnected) .connect()
Viola! The curl script will return 'hi there!'
Now you're on your way to building real-time web applications.