ytnk531/fiber_server.rb Secret

## fiber_server.rb
require 'socket'
require 'nio'

module FiberServer
  #:nodec:
  class Server
    def initialize
      @selector = NIO::Selector.new
      @fibers = {}
    end

    def run
      @srv = TCPServer.new 13_000
      @selector.register @srv, :r

      loop do
        @selector.select do |m|
          case m.io
          when @srv
            accept m.io
          else
            communicate m.io
          end
        end
      end
    end

    def accept(io)
      socket = io.accept_nonblock
      @fibers[socket] = communication_fiber
      @selector.register socket, :r
    end

    def communicate(io)
      f = @fibers[io]
      @selector.deregister io
      f.resume io
    end

    def communication_fiber
      Fiber.new do |io|
        message = io.read_nonblock 5000
        @selector.register io, :w
        Fiber.yield

        io.write_nonblock response(message)
        io.close
        @fibers.delete io
      end
    end

    def response(message)
      <<~RESP
        HTTP/1.1 200 OK

        <html>
        <body>
        <h1>こんにちは 世界</h1>
        <p>HTTPを使って通信するサーバーを作ったよ。</p>
        <p>#{message}</p>
        </body>
        </html>
      RESP
    end
  end
end

s = FiberServer::Server.new
s.run
	require 'socket'
	require 'nio'

	module FiberServer
	#:nodec:
	class Server
	def initialize
	@selector = NIO::Selector.new
	@fibers = {}
	end

	def run
	@srv = TCPServer.new 13_000
	@selector.register @srv, :r

	loop do
	@selector.select do \|m\|
	case m.io
	when @srv
	accept m.io
	else
	communicate m.io
	end
	end
	end
	end

	def accept(io)
	socket = io.accept_nonblock
	@fibers[socket] = communication_fiber
	@selector.register socket, :r
	end

	def communicate(io)
	f = @fibers[io]
	@selector.deregister io
	f.resume io
	end

	def communication_fiber
	Fiber.new do \|io\|
	message = io.read_nonblock 5000
	@selector.register io, :w
	Fiber.yield

	io.write_nonblock response(message)
	io.close
	@fibers.delete io
	end
	end

	def response(message)
	<<~RESP
	HTTP/1.1 200 OK

	<html>
	<body>
	<h1>こんにちは世界</h1>
	<p>HTTPを使って通信するサーバーを作ったよ。</p>
	<p>#{message}</p>
	</body>
	</html>
	RESP
	end
	end
	end

	s = FiberServer::Server.new
	s.run