zerocaffe.in Blog of Uncaffeinated Experiences on Entrepreneurship and Everything Else

< ?xml version="1.0"?>
<mx :Application xmlns:mx="http://www.adobe.com/2006/mxml" creationComplete="init()">
	</mx><mx :Script>
		< ![CDATA[
			import flash.display.Sprite;
 
			import flash.net.XMLSocket;
			import flash.events.Event;
			import flash.events.DataEvent;
			import flash.events.IOErrorEvent;
			import mx.events.CloseEvent;
			import mx.controls.Alert;
 
			public var socket:XMLSocket = new XMLSocket();
			private var host:String     = "localhost";
			private var port:int        = 9999;
 
			public function init():void	{
				socket.connect(host, port);
 
				socket.addEventListener(DataEvent.DATA, onData);
				socket.addEventListener(Event.CONNECT, onConnect);
				socket.addEventListener(Event.CLOSE, onClose);
				socket.addEventListener(IOErrorEvent.IO_ERROR, onEvent);
			}
 
			private function onConnect(event:Event):void	{
				board.htmlText += "<i>Client: Connected to server" + "<br />";
			}
 
			private function ReconnectHandler(event:CloseEvent):void	{
				if (event.detail == Alert.YES)
					init();
			}
 
			private function onClose(event:Event):void	{
				board.htmlText += "<i>Disconnected from server</i>" + "<br />";
				Alert.show("Reconnect to the chat?", "Reconnect?", (Alert.YES | Alert.NO), this, ReconnectHandler);
			}
 
			private function onEvent(event:Event):void {
				board.htmlText += "Error" + "<br />";
				trace(event);
			}
 
			private function onData(event:DataEvent):void {
				board.htmlText += event.text;
			}
 
			private function sendMesg():void	{
				socket.send(username.text+ ': <font color="#' + cp.selectedColor.toString(16) + '">' + mesg.text + "</font>\n");
				mesg.text = "";
			}
 
		]]>
	</mx>
 
	<mx :Style>
		.marginstyle {
			paddingTop:12; 
			paddingBottom:12; 
			paddingLeft: 12; 
			paddingRight: 12;
		}
 
		.spacestyle {
			paddingTop:2; 
			paddingBottom:2; 
			paddingLeft: 2; 
			paddingRight: 2;
		}
	</mx>
 
	<mx :Panel title="chatterbox" styleName="marginstyle">
		<mx :TextArea editable="false" id="board" text="" height="400" width="600" color="#0000FF" styleName="spacestyle"/>
     </mx><mx :HBox>
			<mx :TextArea id="username" text="guest" height="20" width="50%"/>
			<mx :ColorPicker id="cp" height="20" width="20"/>    
		</mx>
		<mx :HBox>
			<mx :TextArea id="mesg" height="50" width="500" styleName="spacestyle"/>
			<mx :Button label="Send" click="sendMesg()"/>	
		</mx>

#!/usr/bin/ruby
require 'socket'
 
MSGS = {"init"    => "Server started. Waiting for connections...",
        "welcome" => "Welcome! type EXIT to quit",
        "byebye"  => "Disconnected from server"}
 
EOF     = "\000"
HOST		= "localhost"
PORT		= 9999
 
server	= TCPServer.new(HOST, PORT)
puts MSGS["init"] 
 
# array to store all the active connections
sessions = []
while (session = server.accept)
  # push the current session(socket) in the array
  sessions < < session
  # initialize a new thead for each connection
  Thread.new(session) do |local_session|
		local_session.puts "<i>#{MSGS["welcome"]}" + EOF
 
    # each time a client sends some data send it to all the connections
    while(true)
      data = local_session.gets
 
			if !data.nil?
				delim_pos = data.index(":")
				name      = data[0..delim_pos-1]
				data      = data[delim_pos+1..-1]
 
				if data[0] == EOF
					data = data[1..-1] 
				elsif data.chomp == "EXIT"
					sessions.delete(local_session)
					local_session.puts "<i>#{MSGS["byebye"]}</i>" + EOF
					local_session.close
 
					data = "<i>#{name} disconnected from the server</i>" + EOF
				end
			end
 
      sessions.each do |s| 
        begin
          s.puts "<b>#{name}</b>: #{data.chomp}" + EOF
        rescue Errno::ECONNRESET
          # an exception is raised, that means the connection to the client is broken
          sessions.delete(s)
        end
      end
    end
  end
end