ruby-list

さらにシンプルにしました。

listen ウィンドウ用の Queue の使用をやめる事により、接続待ちのメインス
レッド以外のスレッドはすぐに消えて行くようになったので、効率もアップし
ました。 


#!/usr/local/bin/ruby
#
# simple_chat_server.rb
# Wakou Aoyama <pxn11625@niftyserve.or.jp>

require 'socket'
require 'thread'
require 'kconv'
require 'cgi-lib'

CR  = "\015"
LF  = "\012"
EOL = CR + LF

def add_http_header(content, option = '') # ===== add HTTP header
   'HTTP/1.0 200 OK' + EOL +
  ('Pragma: no-cache' + EOL if 'no-cache' == option) +
  ('Content-length: ' + content.length + EOL if not 'no-length' == option) +
   'Content-type: text/html' + EOL + EOL +
    content
end

def send_for_all_members(message) # ===== send message
  $members.each_value do |listener| # delivery for each listener
    begin
      listener['listen_window'] << message # delivery the message
    rescue # if listener was logouted
      handle = listener['handle']
      $members.delete(listener['no'])
      send_for_all_members( '(' + handle + " is logout.)<BR>\n" )
    end
  end
end

def talk_window(sock, my) # ===== talk window (post message)
  query = CGI.new(sock)
  if /\/HA (.+)/i =~ query.inputs['input'] # change handle
    send_for_all_members(
      '(change handle. "' + my['handle'] + '" --&gt; "' +
      Kconv.toeuc($1) + "\")<BR>\n" )
    my['handle'] = Kconv.toeuc($1)
  elsif query.inputs.include?('input') and '' != query.inputs['input']
    send_for_all_members(my['handle'] + ' &gt; ' +
      Kconv.toeuc( (query.inputs['input'] or '') ) + "<BR>\n" )
  end

  sock << add_http_header(
    %|<BODY BGCOLOR="white">
      <FORM METHOD="post" ACTION="/talk#{my['no']}.html" NAME="input">
        <B>#{my['handle']} &gt; </B>
        <INPUT TYPE="text" NAME="input" SIZE="60">
        <INPUT TYPE="submit" VALUE="send">
      </FORM>|.gsub(/^      /, ''))
  sock.shutdown(2)
end

def listen_window(sock, my) # ===== listen window
  my['listen_window'] = sock
  sock << add_http_header(
    %|<BODY BGCOLOR="white">
      <H1>Welcome!<BR>simple chat server.</H1>
      <P><B>Powerd by
      <A HREF="http://www.netlab.co.jp/ruby/jp/">
      Ruby</A>.</B></P>
      <P>change handle. input like this.<BR>
      <TT>/HA handle</TT></P>|.gsub(/^      /, ''), 'no-length')
  send_for_all_members( '(' + my['handle'] + " is login.)<BR>\n" )
end

def new_access(sock, my) # ===== new access
  sock << add_http_header(
    %|<TITLE>CHAT</TITLE>
      <FRAMESET ROWS="*, 60">
        <FRAME SRC="/listen#{my['no']}.html">
        <FRAME SRC="/talk#{my['no']}.html">
      </FRAMESET>|.gsub(/^      /, ''), 'no-cache')
  sock.shutdown(2)
end

def session(sock)
  head = ''
  head += sock.read(1) while /#{EOL}#{EOL}|#{LF}#{LF}|#{CR}#{CR}/n !~ head

  case head # analyze http header
  when /^GET\s+([^?\s]+)\??([^\s]*)/
    ENV['REQUEST_METHOD'] = 'GET'
    file_name = $1
    ENV['QUERY_STRING'] = ($2 or '').to_s
  when /^POST\s+([^\s]+)/
    ENV['REQUEST_METHOD'] = 'POST'
    file_name = $1
    ENV['CONTENT_LENGTH'] = head.scan(/^Content-length:\s*(\d+)/i)[0].to_s
  end

  case file_name
  when %r|^/$|                 # ===== new access
    $serial_no += 1
    $members[$serial_no] = { 'no'     => $serial_no,
                             'handle' => 'No.' + $serial_no.to_s}
    new_access(sock, $members[$serial_no])
  when %r|^/talk(\d+).html$|   # ===== talk window (post message)
    talk_window(sock, $members[$1.to_i])
  when %r|^/listen(\d+).html$| # ===== listen window
    listen_window(sock, $members[$1.to_i])
  else                         # ===== file not found
    sock << add_http_header('<H1>file not found</H1>')
    sock.shutdown(2)
  end
end

PORT = ARGV.shift || 8080
$serial_no = 0
$members = {}

port = TCPserver.open(PORT)
trap('PIPE', 'IGNORE')
STDERR.print (Time.now, "\tserver is on #{port.addr[1]}\n")

while TRUE
  sock = port.accept # stand by for accept

  Thread.start do # divide the work
    session(sock)
  end
end


青山 和光 Wakou Aoyama <pxn11625@niftyserve.or.jp>

Thread

Prev Next

In This Thread

Prev Next

[#6858] monitor.rb and ftplib.rb — shugo@... (Shugo Maeda)

[#6859] register calc (call for scripts) — TEI meiki <tei@...>

[#6860] inspect (mb string) — 青山 和光 <PXN11625@...>

[#6861] Re: http_get.rb — 青山 和光 <PXN11625@...>

[#6862] Re: http_get.rb — 青山 和光 <PXN11625@...>

[#6863] Re: http_get.rb — 青山 和光 <PXN11625@...>

[#6889] lib/date.rb — Tadayoshi Funaba <tadf@...>

[#6890] date class — Tadayoshi Funaba <tadf@...>

[#6893] Re: http_get.rb — 青山 和光 <PXN11625@...>

[#6905] Email your AD to 57 MILLION People ONLY $99 — 29818412@...

[#6906] ruby's Icon ? — 藤本尚邦 / FUJIMOTO Hisakuni <hisa@...>

[#6915] Re: inspect (mb string) — 青山 和光 <PXN11625@...>

[#6916] Re: http_get.rb — 青山 和光 <PXN11625@...>

[#6917] Re: inspect (mb string) — 青山 和光 <PXN11625@...>

[#6918] manual 1.18b index — WATANABE Tetsuya <tetsu@...>

[#6920] Re: call for scripts — sakamoto@... (Sadayuki Sakamoto)

[#6929] Expect lib for ruby — nosuzuki@... (Norio Suzuki)

[#6938] Re: ruby's Icon ? — 助田 雅紀 <masaki.suketa@...>

[#6954] Re: ruby's Icon ? — nosuzuki@... (Norio Suzuki)

[#6956] Re: ruby's Icon ? — takehiro.kubo@... (KUBO Takehiro)

[#6958] Re: inspect (mb string) — 青山 和光 <PXN11625@...>

[#6968] Re: ruby's Icon ? — 助田 雅紀 <masaki.suketa@...>

[#6975] Re: coerce — toyofuku@...

[#6978] win32 版 ruby の getc について — ARIMA Yasuhiro <fit0298@...>

[#6983] ext POSIX.setsid — WATANABE Tetsuya <tetsu@...>

[#6999] RE: [ruby-list:6994] Re: Curses and Slang Module (was Re: win32版ruby の getc について) — 助田 雅紀 <masaki.suketa@...>

[#7003] Ruby for MacOS, BeOS — 藤本尚邦 / FUJIMOTO Hisakuni <hisa@...>

[#7004] gtk 0.99.4 and gtk module — Noritsugu Nakamura <nnakamur@...>

[#7008] builtin class inherit — TEI meiki <tei@...>

[#7009] netscape remote script — Noritsugu Nakamura <nnakamur@...>

[#7013] modulo — toyofuku@...

[#7021] unary +/- — Tadayoshi Funaba <tadf@...>

[#7022] スレッドの終了待ち — densuke@...2.so-net.or.jp

[#7023] infinity — Tadayoshi Funaba <tadf@...>

[#7035] Re: modulo — toyofuku@...

[#7067] rfc822.rb — akira yamada / やまだあきら <akira@...>

[#7083] about rbc — Kazuhisa YANAGAWA <katze@...>

[#7094] Re: ruby-beginners — matz@... (Yukihiro Matsumoto)

[#7097] bltlib module — Noritsugu Nakamura <nnakamur@...>

[#7098] rbc and readline — keiju@... (Keiju ISHITSUKA)

[#7105] postgres-6.3 and postgres-module — Eiji-usagi-MATSUmoto <ematsu@...>

[#7107] calender-html.rb (Re: call for scripts) — Shin-ichiro HARA <sinara@...>

[#7111] How to simulate Perl's DATA file handle — OZAWA Sakuro <crouton@...>

[#7118] Re: rfc822.rb — 青山 和光 <PXN11625@...>

[#7119] Re: inspect (mb string) — 青山 和光 <PXN11625@...>

[#7120] Re: Ruby for MacOS, BeOS — 青山 和光 <PXN11625@...>

[#7121] simple_chat_server.rb — 青山 和光 <PXN11625@...>

[#7125] Re: CGI#include? — 青山 和光 <PXN11625@...>

[#7126] do end or {} — Eiji-usagi-MATSUmoto <ematsu@...>

[#7128] fixed man pages — Kazuhisa YANAGAWA <katze@...>

[#7145] gsub — WATANABE Tetsuya <tetsu@...>

[#7147] each_char — TEI meiki <tei@...>

[#7153] please apply me — SHUDOH Kazuyuki <shudoh@...>

[#7155] undefined class switch — keiju@... (Keiju ISHITSUKA)

[#7160] [Bug] 10e0.9 — keiju@... (Keiju ISHITSUKA)

[#7166] bit — matz@... (Yukihiro Matsumoto)

[#7173] ASCII 98/4 — WATANABE Tetsuya <tetsu@...>

[#7174] join in — takas-su@... (Takashi Sugimura)

[#7175] Re: CGI#include? — 青山 和光 <PXN11625@...>

[#7177] Re: [ruby-dev:1845] [ANNOUNCE] grepsvr.rb — Shin-ichiro HARA <sinara@...>

[#7180] chomp! — Kazunori NISHI <kazunori@...>

[#7183] Numeric — toyofuku@...

[#7186] Re: Numeric — toyofuku@...

[#7192] I hope join. — Takashi Shimizu <simtak@...>

[#7200] delegation of TCPsocket — TAKEUCHI Kahori (竹内かほり) <take-k@...>

[#7208] for in bsh — matz@... (Yukihiro Matsumoto)

[#7221] test — matz@... (Yukihiro Matsumoto)

[#7222] jcode.rb — NAGAI Hidetoshi <nagai@...>

[#7229] Re: call for scripts — Yasunari Momoi <conan@...>

[#7232] final.rb error? — tateishi@...

[#7234] final.rb error? 2 — tateishi@...

[#7238] Forward: 自己再生プログラム — matz@... (Yukihiro Matsumoto)

[#7244] [Q] test file1 -nt file2 — matz@... (Yukihiro Matsumoto)

[#7253] tk version — gotoken@... (GOTO Kentaro)

[#7257] TkScale.new(parent){to -0.1} — gotoken@... (GOTO Kentaro)

[#7259] Socket#shutdown — keiju@... (Keiju ISHITSUKA)

[#7261] — Sinichiro Dezawa <dezawa@...>

[#7282] ruby ftp mirror to my disk — Noritsugu Nakamura <nnakamur@...>

[#7284] base64.rb — jkuro@... (Kuroda Jun)

[#7285] Re: modulo — Toyofuku <toyofuku@...>

[#6860] inspect (mb string) — 青山　和光 <PXN11625@...>

[#6861] Re: http_get.rb — 青山　和光 <PXN11625@...>

[#6862] Re: http_get.rb — 青山　和光 <PXN11625@...>

[#6863] Re: http_get.rb — 青山　和光 <PXN11625@...>

[#6893] Re: http_get.rb — 青山　和光 <PXN11625@...>

[#6915] Re: inspect (mb string) — 青山　和光 <PXN11625@...>

[#6916] Re: http_get.rb — 青山　和光 <PXN11625@...>

[#6917] Re: inspect (mb string) — 青山　和光 <PXN11625@...>

[#6938] Re: ruby's Icon ? — 助田　雅紀 <masaki.suketa@...>

[#6958] Re: inspect (mb string) — 青山　和光 <PXN11625@...>

[#6968] Re: ruby's Icon ? — 助田　雅紀 <masaki.suketa@...>

[#6999] RE: [ruby-list:6994] Re: Curses and Slang Module (was Re: win32版ruby の getc について) — 助田　雅紀 <masaki.suketa@...>

[#7118] Re: rfc822.rb — 青山　和光 <PXN11625@...>

[#7119] Re: inspect (mb string) — 青山　和光 <PXN11625@...>

[#7120] Re: Ruby for MacOS, BeOS — 青山　和光 <PXN11625@...>

[#7121] simple_chat_server.rb — 青山　和光 <PXN11625@...>

[#7125] Re: CGI#include? — 青山　和光 <PXN11625@...>

[#7175] Re: CGI#include? — 青山　和光 <PXN11625@...>