rendered paste bodyusing System;
using System.IO;
using System.Net.Sockets;
using System.Text;
using System.Collections;
using System.Threading;
public class DataEventArgs : EventArgs
{
public string data;
public DataEventArgs(string data)
{
this.data = data;
}
}
public delegate void DataReceivedHandler(object sender, DataEventArgs ce);
public class SynchronousSocketListener {
public event DataReceivedHandler ReceiveData;
private const int portNum = 10116 ;
private static ArrayList ClientSockets ;
private static bool ContinueReclaim = true;
private static Thread ThreadReclaim ;
public void Broadcast(string data)
{
foreach ( Object Client in ClientSockets ) {
( (ClientHandler) Client ).Send(data) ;
}
}
private void ClientHandler_RecData(object sender, DataEventArgs e) //EVENT DELT WITH HERE
{
if(ReceiveData != null)
{
ReceiveData(sender, e); //'RE-THROW' EVENT HERE
}
else
{
Console.WriteLine("Failed"); //ALWAYS HAPPENS
}
//((ClientHandler)sender).Send(e.data);
//Broadcast(e.data);
}
public void StartListening() {
ClientSockets = new ArrayList() ;
ThreadReclaim = new Thread( new ThreadStart(Reclaim) );
ThreadReclaim.Start() ;
TcpListener listener = new TcpListener(portNum);
try {
listener.Start();
int TestingCycle = 3 ; //number of supported connections
int ClientNbr = 0 ;
// Start listening for connections.
Console.WriteLine("Waiting for a connection...");
while ( TestingCycle > 0 ) {
TcpClient handler = listener.AcceptTcpClient();
if ( handler != null) {
Console.WriteLine("Client#{0} accepted!", ++ClientNbr) ;
// An incoming connection needs to be processed.
lock( ClientSockets.SyncRoot ) {
int i = ClientSockets.Add( new ClientHandler(handler) ) ;
((ClientHandler) ClientSockets[i]).Start() ;
((ClientHandler)ClientSockets[i]).ReceivedData += new DataReceivedHandler(ClientHandler_RecData);
}
--TestingCycle ; //remove for infinate connections (yes we want to do this
}
else
break;
}
listener.Stop();
ContinueReclaim = false ;
ThreadReclaim.Join() ;
foreach ( Object Client in ClientSockets ) {
( (ClientHandler) Client ).Stop() ;
}
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
Console.WriteLine("\nHit enter to continue...");
Console.Read();
}
private static void Reclaim() {
while (ContinueReclaim) {
lock( ClientSockets.SyncRoot ) {
for ( int x = ClientSockets.Count-1 ; x >= 0 ; x-- ) {
Object Client = ClientSockets[x] ;
if ( !( ( ClientHandler ) Client ).Alive ) {
ClientSockets.Remove( Client ) ;
Console.WriteLine("A client left") ;
}
}
}
Thread.Sleep(200) ;
}
}
// public static int Main(String[] args) {
// StartListening();
// return 0;
// }
}
class ClientHandler {
public event DataReceivedHandler ReceivedData;
TcpClient ClientSocket ;
bool ContinueProcess = false ;
Thread ClientThread ;
public ClientHandler (TcpClient ClientSocket) {
this.ClientSocket = ClientSocket ;
}
public void Start() {
ContinueProcess = true ;
ClientThread = new Thread ( new ThreadStart(Process) ) ;
ClientThread.Start() ;
}
public void Send(string data)
{
if ( ClientSocket != null ) {
NetworkStream networkStream = ClientSocket.GetStream();
ClientSocket.ReceiveTimeout = 100 ; // 1000 miliseconds
byte[] sendBytes = Encoding.ASCII.GetBytes(data);
networkStream.Write(sendBytes, 0, sendBytes.Length);
}
}
private void Process() {
// Incoming data from the client.
string data = null;
// Data buffer for incoming data.
byte[] bytes;
if ( ClientSocket != null ) {
NetworkStream networkStream = ClientSocket.GetStream();
ClientSocket.ReceiveTimeout = 100 ; // 1000 miliseconds
while ( ContinueProcess ) {
bytes = new byte[ClientSocket.ReceiveBufferSize];
try {
int BytesRead = networkStream.Read(bytes, 0, (int) ClientSocket.ReceiveBufferSize);
if ( BytesRead > 0 ) {
data = Encoding.ASCII.GetString(bytes, 0, BytesRead);
// Show the data on the console.
//Console.WriteLine( "Text received : {0}", data);
DataEventArgs dea = new DataEventArgs(data);
if(ReceivedData != null)
{
ReceivedData(this, dea);
//INITIAL EVENT FIRED HERE
}
// Echo the data back to the client.
// byte[] sendBytes = Encoding.ASCII.GetBytes(data);
// networkStream.Write(sendBytes, 0, sendBytes.Length);
if ( data == "quit" ) break ;
}
}
catch ( IOException ) { } // Timeout
catch ( SocketException ) {
Console.WriteLine( "Conection is broken!");
break ;
}
Thread.Sleep(200) ;
} // while ( ContinueProcess )
networkStream.Close() ;
ClientSocket.Close();
}
} // Process()
public void Stop() {
ContinueProcess = false ;
if ( ClientThread != null && ClientThread.IsAlive )
ClientThread.Join() ;
}
public bool Alive {
get {
return ( ClientThread != null && ClientThread.IsAlive );
}
}
} // class ClientHandler
FOLLOWING CODE IS USED TO SET THIS ALL UP
SynchronousSocketListener listener = new SynchronousSocketListener();
listener.StartListening();
listener.ReceiveData += new DataReceivedHandler(listener_data);
And the relevent method (listener_data) is also declared