とりあえず、現状で必要なのはgzip圧縮されたデータを受信して、展開したいだけ。 あっさりzlibライブラリで解決するかと思いきや、 zlibを読んだ感じでは、gzipはファイル化しなけりゃならないっぽい。 ファイル化とか面倒だと思ってgunzip -cに吸い込ませ…

vol.5のように時間がかかる処理があると待たされてしますので、 それを解決したコードが次のコードです。 require "socket" port = if ARGV[0] then ARGV[0] else 'echo' end gate = TCPServer.open(port) sockets = [gate, STDIN] clients = [] loop do r_s…

vol.4のプログラムはclientsにひとつずつ配信しています。 一瞬で終わるならいいのですが、ネットワークなんて遅延しまくりなので、 あまりよろしくありません。一度に配信処理をしたいものです。 試しに2秒遅延を入れてみると、こうなります。 require "soc…

スレッドなどでそれぞれ待ち受けるという手もありますが、 IOの入出力を待つ手段としては一般的ではないようです。 IOの動きを監視して待ち受け、動きがあったら場合分けをして 処理をするのが一般的なようです。 これをReactorパターンといいます。 IO.sele…

forkはダメです。forkは別プロセスを立ち上げるので、メモリの共有ができません。 なので、同じデータの一斉配信には向いていません。プロセス間通信とか仕組みが面倒です。 ちゃんと動かないプログラムをとりあえず書いてみました。 require "socket" port …

vol.1 のサーバだと、1対1の通信しかできません。これだとサーバ＆クライアント型の プログラムとは言い難いので、サーバ1台に対し、クライアント複数台で作ってみます。 require "socket" port = if ARGV[0] then ARGV[0] else 'echo' end gate = TCPServer…

これはRubyで作ったソケットサーバに接続してきたクライアントにデータを配信するための勉強上の知見です。 require "socket" port = if ARGV[0] then ARGV[0] else 'echo' end gate = TCPServer.open(port) sock = gate.accept gate.close while msg = STDI…