FZambia

FZambia

FZambia

FZambia

package main

import (
	"fmt"
	"html/template"
	"io/ioutil"
	"log"
	"net/http"
	"strconv"
	"strings"

FZambia

class BaseSession(object):
    def _heartbeat(self):
        """Heartbeat callback"""
        if self.handler is not None:
            if self.server.settings.get('ws_ping_pong', False) and hasattr(self.handler, 'ping'):
                self.handler.ping(proto.HEARTBEAT)
            else:
                self.handler.send_pack(proto.HEARTBEAT)
        else:
            self.stop_heartbeat()

FZambia

import tornado.ioloop
import tornado.web
from centrifuge.node import create_centrifuge_application


class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.write("Hello, world")

FZambia

# coding: utf-8
try:
    from urllib.request import urlopen, Request
except ImportError:
    from urllib2 import urlopen, Request

try:
    from urllib import urlencode
except ImportError:
    # python 3

FZambia

upstream centrifuge {
    # Enumerate all the Tornado servers here
    #sticky;
    ip_hash;
    server 127.0.0.1:8000;
    #server 127.0.0.1:8001;
}

map $http_upgrade $connection_upgrade {
    default upgrade;

FZambia

GO 1.4

GOMAXPROCS=2

MacAir:benchmarks fz$ go run benchmark.go ws://localhost:8000/connection/websocket development secret 4000 1000 50
1440097030
max clients: 4000
increment: 1000

FZambia

Max open files:

http://docs.basho.com/riak/latest/ops/tuning/open-files-limit/

Available port range on Mac OS X:

Show:

sysctl net.inet.ip.portrange.first net.inet.ip.portrange.last