ZeroMQでSocket.IO関連のモジュールを作ってみた
ZeroMQでSocket.IO関連のモジュールを作ってみたSocket.IO MeetUpまず、本題に入る前に。 昨日のSocket.IO MeetUp に行って来たのですが、socket.ioの作者 Guillermo Rauch 氏から直々に、socket.ioを作るに至った背景や、今後のsocket.ioの関連の話、それと今話題の MQTT と Socket.IO を使った話を聞くことができて、楽しかったです。 “Web 上の EventEmitter” というようなプラットフォーム的な感じで今後盛り上がるといいですね。 :) モチベーションさて、本題。 ここ最近、 Socket.IO 1.0 のリリース東京Node学園13時限目での Socket.IO 1.0 に関する話そして今回のSocket.IO Meetupということで、いろいろと進化している Socket.IO に興味が
ZeroMQのJava実装のJeroMQを試す - bose999の試験管の中の話
ZeroMQ http://zguide.zeromq.org/page:all JeroMQ https://github.com/zeromq/jeromq ZeroMQはシンプルで高速なプロセス間通信を実現する C/C++のライブラリ。ライブラリのラッパーは対応言語が豊富。 キューは永続化はされない。メモリで処理されるので高速。 ライセンスはLGPL。 こちらのエントリが詳しい ØMQ(zeromq)について調査する。 JeroMQはZeroMQがC/C++で書かれてるのに対してJavaで書かれている。 libzmq 3.2.2に基づいた0.3.0-SNAPSHOTを今回は使用する。 ZeroMQと違いJava実装なのでJVMとjarがあれば動いてしまう手軽さが良い。 またパフォーマンスも頑張っている。ライセンスはLGPL。 では上記のような Client REQUEST <-> R
ZeroMQ: Disconnects are Good for You
written on June 26, 2012 ZeroMQ is a cool technology. It’s advertised as “better sockets” and I can get behind that idea for the most part. Unfortunately the high abstraction also makes it very easy to write applications that become unresponsive. That’s because ZeroMQ has an implicit state machine for a very common socket type that can get stuck in the wrong state if the peer disconnects. Hello Ze
ZMQ Perl バインディング - D-6 [相変わらず根無し]
ZMQ Perl バインディング 2012年3月26日 09:50 D | ブログ記事のURL | コメント(0) | トラックバック(0) ZeroMQ.pmをつい相続してしまってから本家libzmqの変更についていけず大分悩んだんだけど、ここのところ直してリクエストが多かったので一念発起してlibzmqのPerlバインディングを大幅リニューアルしました。まだ正式リリースは出してないので、何か文句を言うなら今のうち！英語での解説はこちら いままでlibzmqの直接バインディング、定数、Perlっぽいシンタックスシュガーのラッパーを全部同じディストリビューションにいれていたのをばらしました。これまでZeroMQ::Raw とされていたのは ZMQ::LibZMQ2 ならびに ZMQ::LibZMQ3 となりました。ZMQはこれらのバインディングをうまいことオブジェクト風味にするPPモジュー
RubyでMongrel2のハンドラを書いてみる : As Sloth As Possible
こないだ、と言っても2週間くらい前の話なんだけど、社内でZeroMQとMongrel2の勉強会をやった。Mongrelと言えば、俺がRails（たしか当時1.2くらいだったと思う）で仕事してた頃にアプリケーションサーバとして使ってたけど、最近だとThinとかPassengerとかUnicornとかの人気に押されてついぞ聞かなくなったアレだよなぁ、なんでPerlの会社の勉強会でMongrelなんだろう、と思ってたんだけど、Mongrel2はもはやRailsのアプリケーションサーバじゃなくて、通信にZeroMQなるものを使った汎用的なWebサーバになってたらしい。 大分野心的なプロジェクトではあるものの、今はZeroMQもMongrel2も「とりあえず出た」って感じらしく、今年一杯くらいは地雷原を突き進む気がある人だけ触るといいんじゃないかなという話だった。プロダクションで使うようなレベルにな
Realtime Analytics Using MongoDB, Python, Gevent, and ZeroMQ
Realtime Analytics Using MongoDB, Python, Gevent, and ZeroMQAI-enhanced description Zarkov is a real-time analytics platform that uses MongoDB, Python, Gevent, and ZeroMQ to aggregate and analyze event data. It handles high volumes of event ingestion and uses a lightweight map/reduce framework to incrementally calculate statistics. The system was developed at SourceForge.net to monitor user and pr
Gevent, ZeroMQ, WebSockets, and Flot FTW!
Blog about all things Python that intersect my work and hobbies As part of the work I've been doing on Zarkov I've had the opportunity to play around with a lot of cool technologies, among which are gevent, ZeroMQ, WebSockets, and Flot. It took a while to get to the point where I could actually get things done, but once I was there, things were incredibly simple. In this post I'll show you how to
ØMQ (ZeroMQ) 序論
あなたにとって重要なトピックや同僚の最新情報を入手しましょう最新の洞察とトレンドに関する最新情報を即座に受け取りましょう。 継続的な学習のために、無料のリソースに手軽にアクセスしましょうミニブック、トランスクリプト付き動画、およびトレーニング教材。 記事を保存して、いつでも読むことができます記事をブックマークして、準備ができたらいつでも読めます。
» Twitter Streaming をZeroMQで中継してみた。» Weblet
以前にソケットを使ってTwitterStreamingしていたものをphp-zmq を使ってZeroMQベースの中継にしてみた。 ソケットを自分で扱うときにはちょこっと工夫が必要だったのだが今回はソケット周りが非常にシンプルにまとまった。 ソケットを使っているときには、ツイートを受信するたびに、接続されている全てのソケットに順番にsocket_write()していたものを、下記のようにするだけでメッセージを不特定多数に対して発信させることができる。 $publisher = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_PUB); $publisher->bind("tcp://127.0.0.1:5555"); $publisher->send("hogehoge"); また受信は基本的にこんな感じ。（継続的にメッセージを受信するためにはこれを
ØMQ(zeromq)について調査する。
ØMQ(zeromq)について簡単に調査したのでメモ。元ネタはØMQ - The Guide。 概要 N-N通信を実現する、socket API風軽量メッセージングライブラリ。 自動的な再接続や、メッセージのキューイングを行ってくれる。 複数のメッセージングパターンと呼ばれるものを組み合わせることによって、柔軟なメッセージ配信を行うことができる。 ライブラリについて socket APIライクなC APIを持つ。以下socketは、zeromqのsocketを指す。 zeromqはコンテキストというものを通じて使う。1コンテキストに、I/Oスレッドが1つ割り当てられる。基本1プロセスに1コンテキストでOK。複数のcontextを持つことはできるし、その場合は同じ個数のI/Oスレッドが走る。 zeromqのsocketは、プロセス内通信(スレッド間通信など)、プロセス間通信、TCP、UDPマ
node.jsでZeroMQを使う - スコトプリゴニエフスク通信
空前のZeroMQ, node.jsブームの中、皆様いかがお過ごしでしょうか。ブームと言いつつもnode.jsに今日始めて触った僕が最初に試したのはZeroMQを使うこと。zeromq.nodeを使えば簡単に出来ますね。http://github.com/JustinTulloss/zeromq.nodeサーバー側をサンプルを参考に写経。 zmq = require('zeromq'); sys = require('sys'); ctxt = new zmq.Context(); socket = new zmq.Socket(ctxt, zmq.Socket.ZMQ_REP); socket.bind('tcp://127.0.0.1:5554', function(err) { if (err) { throw new Error(err); } socket.on('receive
ZeroMQ
Why ZeroMQ? ZeroMQ (also known as ØMQ, 0MQ, or zmq) looks like an embeddable networking library but acts like a concurrency framework. It gives you sockets that carry atomic messages across various transports like in-process, inter-process, TCP, and multicast. You can connect sockets N-to-N with patterns like fan-out, pub-sub, task distribution, and request-reply. It's fast enough to be the fabric
ZeroMQ: Modern & Fast Networking Stack - igvita.com
By Ilya Grigorik on September 03, 2010 Berkeley Sockets (BSD) are the de facto API for all network communication. With roots from the early 1980's, it is the original implementation of the TCP/IP suite, and arguably one of the most widely supported and critical components of any operating system today. BSD sockets that most of us are familiar with are peer-to-peer connections, which require explic
橋本商会
1VQ9がZeroMQで遊んでたので、俺も橋本商会 cvCalcOpticalFlowBMをZeroMQでpubしてみた。ZeroMQはなんか面倒な事を適当にやってくれるmessaging libraryで、色々な言語のバインディングが出ている。 ZeroMQのpubはセンサーのデータとかを垂れ流しにするのに都合がよさそう。 clientが何台いるかどうかを考えないで良いし、pub/subどちらが先に起動していても適当に接続処理をしてくれる。cookbookを見てるとmulticastやthread間通信にも使ってる。とりあえずセンサーデータ垂れ流しという用途に俺はよく使いそう。 ソースコードはgithubに置いた。 他にも単純なカウントアップのpub/sub両方をC++/C/Rubyで書いた（6種）のと、twitterのstream APIをZMQ_PUBで中継するのを作ってみた（解説：
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - zeromq/jeromq: JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
Django, ZeroMQ and Celery: multiprocessing gotcha
Distributed Systems with ZeroMQ and gevent | Hacker News
liris.org
はてなブログ | 無料ブログを作成しよう