Complex Ruby Web Service

• Tweet
• 

        Complex ruby service

This server reads a line of input from a client, reverses the line and sends it back. If the client sends the string "quit" it disconnects. 
Server

require 'socket'
server = TCPServer.open(2000) 			# Listen on port 2000
sockets = [server] 						# An array of sockets we'll monitor
log = STDOUT 							# Send log messages to standard out
while true 								# Servers loop forever
	ready = select(sockets) 				# Wait for a socket to be ready
	readable = ready[0] 					# These sockets are readable
	readable.each do |socket| 				# Loop through readable sockets
		if socket == server 				# If the server socket is ready
			client = server.accept 		# Accept a new client
			sockets << client 			# Add it to the set of sockets
										# Tell the client what and where it has connected.
			client.puts "Reversal service v0.01 running on #{Socket.gethostname}"
										# And log the fact that the client connected
			log.puts "Accepted connection from #{client.peeraddr[2]}"
		else 							# Otherwise, a client is ready
			input = socket.gets 			# Read input from the client
										# If no input, the client has disconnected
			if !input
				log.puts "Client on #{socket.peeraddr[2]} disconnected."
				sockets.delete(socket) 	# Stop monitoring this socket
				socket.close 			# Close it
				next					# And go on to the next
			end
			input.chop! 					# Trim client's input
			if (input == "quit") 			# If the client asks to quit
				socket.puts("Bye!"); 		# Say goodbye
				log.puts "Closing connection to #{socket.peeraddr[2]}"
				sockets.delete(socket) 	# Stop monitoring the socket
				socket.close 			# Terminate the session
			else 						# Otherwise, client is not quitting
				socket.puts(input.reverse) # So reverse input and send it back
			end
		end
	end
end

Client

require 'socket'

host = 'localhost'
port = 2000
begin
										# Give the user some feedback while connecting.
	STDOUT.print "Connecting..." 			# Say what we're doing
	STDOUT.flush 						# Make it visible right away
	s = TCPSocket.open(host, port) 		# Connect
	STDOUT.puts "done" 					# And say we did it
										# Now display information about the connection.
	local, peer = s.addr, s.peeraddr
	STDOUT.print "Connected to #{peer[2]}:#{peer[1]}"
	STDOUT.puts " using local port #{local[1]}"
										# Wait just a bit, to see if the server sends any initial message.
	begin
		sleep(0.5) 						# Wait half a second
		msg = s.read_nonblock(4096) 		# Read whatever is ready
		STDOUT.puts msg.chop 			# And display it
	rescue SystemCallError
										# If nothing was ready to read, just ignore the exception.
	end
										# Now begin a loop of client/server interaction.
	loop do
		STDOUT.print '> ' 					# Display prompt for local input
		STDOUT.flush 					# Make sure the prompt is visible
		local = STDIN.gets 				# Read line from the console
	break if !local 						# Quit if no input from console
		s.puts(local) 						# Send the line to the server
		s.flush 							# Force it out
										# Read the server's response and print out.
										# The server may send more than one line, so use readpartial
										# to read whatever it sends (as long as it all arrives in one chunk).
		response = s.readpartial(4096) 		# Read server's response
		puts(response.chop) 				# Display response to user
	end
rescue 									# If anything goes wrong
	puts $! 								# Display the exception to the user
ensure 									# And no matter what happens
	s.close if s 							# Don't forget to close the socket
end

Tags:
• Ruby
• socket
• web service