❯ ruby chat_server.rb
❯ ls chat_server.rb
chat_server.rb
❯ docker run -v $(pwd):/app -p 8080:8080 -it wakaba260/ruby-ractor-dev ruby /app/chat_server.rb
❯ ls chat_server.rb
chat_server.rb
❯ docker run -v (pwd):/app -p 8080:8080 -it wakaba260/ruby-ractor-dev ruby /app/chat_server.rb
| require "socket" | |
| class ChatServer | |
| def initialize(port) | |
| @port = port | |
| @connections = [] | |
| end | |
| def start() | |
| socket = TCPServer.open(@port) | |
| addr = socket.addr() | |
| addr.shift() | |
| puts "server is on #{addr.join(':')}" | |
| acceptor = create_acceptor() | |
| puts "acceptor created: #{acceptor.inspect}" | |
| acceptor.send(socket, move: true) | |
| periodic_timer = create_periodic_timer() | |
| puts "periodic_timer created: #{periodic_timer.inspect}" | |
| loop do | |
| r, obj = Ractor.select(periodic_timer, acceptor) | |
| case r | |
| when acceptor | |
| puts "Acceptor: #{obj}" | |
| case obj | |
| when Ractor | |
| @connections << obj | |
| when String | |
| @connections.select! { |c| c.send(obj) rescue nil } | |
| else | |
| puts "warn: ignored event r=#{r}, obj=#{obj}" | |
| end | |
| when periodic_timer | |
| puts "PeriodicTimer" | |
| time = Time.now | |
| @connections.select! { |c| c.send(time) rescue nil} | |
| puts time | |
| puts `vmstat` | |
| puts "connections count: #{@connections.count}" | |
| end | |
| end | |
| end | |
| def create_periodic_timer() | |
| Ractor.new do | |
| loop do | |
| Ractor.yield(nil) | |
| sleep(60) | |
| end | |
| end | |
| end | |
| def create_acceptor() | |
| Ractor.new do | |
| tcp_server = Ractor.recv() | |
| loop do | |
| accept = tcp_server.accept | |
| request = accept.readpartial(4096) | |
| verb, path, _ = *request.split("\r\n").first.split(" ") | |
| case verb | |
| when "GET" | |
| if(path == "/") | |
| accept.print("HTTP/1.1 200 OK\r\nContent-Type: text/html; charset=UTF-8\r\n\r\n") | |
| accept.print(<<__HTML__) | |
| <!DOCTYPE html> | |
| <html> | |
| <head><meta charset="utf-8"></head> | |
| <body> | |
| <form> | |
| <input type="text" name="data"> | |
| <input type="submit" value="send"> | |
| </form> | |
| <div id="messages"></div> | |
| <script> | |
| var source = new EventSource("/rooms/lobby"); // URL は / 以外ならなんでもいいけど将来にそなえてこうしてる | |
| source.onmessage = function(event) { | |
| document.getElementById("messages").innerHTML += event.data + "<br>"; | |
| }; | |
| var formElement = document.querySelector("form"); | |
| formElement.addEventListener('submit', function(event) { | |
| event.preventDefault(); | |
| fetch("/rooms/lobby", { | |
| method: "POST", | |
| body: new FormData(formElement) | |
| }); | |
| }); | |
| </script> | |
| </body> | |
| </html> | |
| __HTML__ | |
| accept.flush() | |
| accept.close() | |
| else | |
| r = Ractor.new do | |
| c = Ractor.recv() | |
| c.print("HTTP/1.1 200 OK\r\nCache-Control: no-cache\r\nContent-Type: text/event-stream\r\n\r\n") | |
| c.flush() | |
| loop do | |
| data = Ractor.recv() | |
| c.print("data: #{data}\r\n\r\n") | |
| c.flush() | |
| end | |
| end | |
| Ractor.yield(r) | |
| r.send(accept, move: true) | |
| end | |
| when "POST" | |
| accept.print("HTTP/1.1 202 Accepted\r\n") | |
| accept.close() | |
| body = request.split("\r\n\r\n").last.split("\r\n").first | |
| Ractor.yield(body) | |
| else | |
| puts "warn: ignored request verb=#{verb}, path=#{path}" | |
| end | |
| end | |
| end | |
| end | |
| end | |
| ChatServer.new(8080).start() |
Thanks!
Indeed, it needs $ prefix for bash or zsh.
I update README as you mentioned ❤️
typo in the
pwdcommand, (was missing$). Worked with:curl -O -L https://gist.githubusercontent.com/niku/c19da11edf0b97470af27844b44d12fa/raw/91afc1b01dd5d7083965d7a718e3f1c09cafb7b0/chat_server.rb docker run -v $(pwd):/app -p 8080:8080 -it wakaba260/ruby-ractor-dev ruby /app/chat_server.rb