Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- using System;
- using System.Net;
- using System.Net.Sockets;
- using System.Text;
- using System.Threading;
- using System.IO;
- using System.Collections;
- using System.Collections.Generic;
- // State object for reading client data asynchronously
- public class StateObject
- {
- // Client socket.
- public Socket workSocket = null;
- // Size of receive buffer.
- public const int BufferSize = 1024;
- // Receive buffer.
- public byte[] buffer = new byte[BufferSize];
- // Received data string.
- public StringBuilder sb = new StringBuilder();
- public string command;
- public int userID;
- public int SystemID;
- public decimal xfrom;
- public decimal yfrom;
- public decimal xto;
- public decimal yto;
- public string UserName;
- public string ShipName;
- }
- public class AsynchronousSocketListener
- {
- public static ArrayList Clients = new ArrayList();
- // Thread signal.
- public static ManualResetEvent allDone = new ManualResetEvent(false);
- public AsynchronousSocketListener()
- {
- }
- public static bool IsConnected(Socket socket)
- {
- try
- {
- return !(socket.Poll(1, SelectMode.SelectRead) && socket.Available == 0);
- }
- catch (SocketException) { return false; }
- }
- public static void StartListening()
- {
- // Data buffer for incoming data.
- byte[] bytes = new Byte[1024];
- // Establish the local endpoint for the socket.
- // The DNS name of the computer
- // running the listener is "host.contoso.com".
- IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
- IPAddress ipAddress = ipHostInfo.AddressList[0];
- IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 4444);
- // Create a TCP/IP socket.
- Socket listener = new Socket(AddressFamily.InterNetwork,
- SocketType.Stream, ProtocolType.Tcp);
- // Bind the socket to the local endpoint and listen for incoming connections.
- try
- {
- listener.Bind(localEndPoint);
- listener.Listen(100);
- while (true)
- {
- // Set the event to nonsignaled state.
- allDone.Reset();
- // Start an asynchronous socket to listen for connections.
- //Console.WriteLine("Socket Server Started");
- listener.BeginAccept(new AsyncCallback(AcceptCallback),listener);
- // Wait until a connection is made before continuing.
- allDone.WaitOne();
- }
- }
- catch (Exception e)
- {
- Console.WriteLine(e.ToString());
- }
- Console.WriteLine("\nPress ENTER to continue...");
- Console.Read();
- }
- public static void AcceptCallback(IAsyncResult ar)
- {
- // Signal the main thread to continue.
- allDone.Set();
- // Get the socket that handles the client request.
- Socket listener = (Socket)ar.AsyncState;
- Socket handler = listener.EndAccept(ar);
- StateObject client = new StateObject();
- int i = Clients.Add(client);
- //Console.WriteLine("Client " + i.ToString() + " Connected" );
- client.workSocket = handler;
- handler.BeginReceive(client.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReadCallback), client);
- }
- public static void ReadCallback(IAsyncResult ar)
- {
- String content = String.Empty;
- // Retrieve the state object and the handler socket
- // from the asynchronous state object.
- StateObject state = (StateObject)ar.AsyncState;
- Socket handler = state.workSocket;
- // Read data from the client socket.
- int bytesRead = handler.EndReceive(ar);
- if (bytesRead > 0)
- {
- // There might be more data, so store the data received so far.
- state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
- // Check for end-of-file tag. If it is not there, read
- // more data.
- content = state.sb.ToString();
- if (content.IndexOf("<EOF>") > -1)
- {
- Console.WriteLine("Data Received : " + content.ToString());
- string[] Data;
- string Message = "";
- Data = content.Split('|');
- if (Data[0] == "0000")
- {
- state.userID = Convert.ToInt32(Data[1]);
- state.SystemID = Convert.ToInt32(Data[2]);
- state.xfrom = Convert.ToDecimal(Data[3]);
- state.yfrom = Convert.ToDecimal(Data[4]);
- state.xto = Convert.ToDecimal(Data[5]);
- state.yto = Convert.ToDecimal(Data[6]);
- state.UserName = Data[7];
- state.ShipName = Data[8];
- foreach (StateObject client in Clients)
- {
- if (client.SystemID == state.SystemID && client.userID != state.userID)
- {
- Message = "0001|" + state.userID.ToString() + "|" + state.xfrom.ToString() + "|" + state.yfrom.ToString() + "|" + state.xto.ToString() + "|" + state.yto.ToString() + "|" + state.UserName.ToString() + "|" + state.ShipName.ToString();
- Send(client.workSocket, Message);
- Console.WriteLine("Data Sent to : " + client.userID.ToString() + " Message : " + Message.ToString());
- Message = "0001|" + client.userID.ToString() + "|" + client.xfrom.ToString() + "|" + client.yfrom.ToString() + "|" + client.xto.ToString() + "|" + client.yto.ToString() + "|" + client.UserName.ToString() + "|" + client.ShipName.ToString();
- Send(state.workSocket, Message);
- Console.WriteLine("Data Sent to : " + state.userID.ToString() + " Message : " + Message.ToString());
- }
- }
- }
- // All the data has been read from the
- // client. Display it on the console.
- // Console.WriteLine("Read {0} bytes from socket. \n Data : {1}", content.Length, content);
- // Echo the data back to the client.
- //handler.Close();
- }
- else
- {
- // Not all data received. Get more.
- handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
- new AsyncCallback(ReadCallback), state);
- }
- }
- }
- private static void Send(Socket handler, string data)
- {
- try
- {
- // Convert the string data to byte data using ASCII encoding.
- byte[] byteData = Encoding.ASCII.GetBytes(data);
- // Begin sending the data to the remote device.
- handler.BeginSend(byteData, 0, byteData.Length, 0,new AsyncCallback(SendCallback), handler);
- }
- catch (Exception e)
- {
- Console.WriteLine("Couldn't Send Data to Socket");
- }
- }
- private static void SendCallback(IAsyncResult ar)
- {
- try
- {
- // Retrieve the socket from the state object.
- Socket handler = (Socket)ar.AsyncState;
- // Complete sending the data to the remote device.
- int bytesSent = handler.EndSend(ar);
- //Console.WriteLine("Sent {0} bytes to client.", bytesSent);
- }
- catch (Exception e)
- {
- Console.WriteLine(e.ToString());
- }
- }
- #region policyserver
- private static TcpListener tcl;
- //Generate policy
- private static string response = "<?xml version=\"1.0\"?> "+
- "<!DOCTYPE cross-domain-policy SYSTEM "+
- " \"http://www.macromedia.com/xml/dtds/cross-domain-policy.dtd\"> "+
- "<cross-domain-policy>"+
- " <allow-access-from domain=\"*\" to-ports=\"4444\"/>"+
- "</cross-domain-policy>\0";
- private static void AcceptCallback1(IAsyncResult ar)
- {
- try
- {
- TcpListener listener = null;
- Socket client = null;
- listener = (TcpListener)ar.AsyncState;
- client = listener.EndAcceptSocket(ar);
- NetworkStream ns = new NetworkStream(client);
- StreamReader sr = new StreamReader(ns);
- StreamWriter sw = new StreamWriter(ns);
- Console.WriteLine("Sent Policy File...");
- sr.Read();
- //Send policy
- sw.Write(response);
- sw.Flush();
- ns.Flush();
- //Cleanup
- sw.Close();
- sr.Close();
- ns.Close();
- client.Close();
- //Do it again!
- tcl.BeginAcceptSocket(new AsyncCallback(AcceptCallback1), tcl);
- }
- catch (Exception e)
- {
- Console.WriteLine(e.Message);
- return;
- }
- }
- static void RunPolicyServer()
- {
- Console.WriteLine("Policy Server Running");
- tcl = new TcpListener(IPAddress.Any, 843);
- tcl.Start();
- tcl.BeginAcceptSocket(new AsyncCallback(AcceptCallback1), tcl);
- //Console.ReadLine();
- }
- #endregion
- public static int Main(String[] args)
- {
- Thread PolicyServer = new Thread(RunPolicyServer);
- PolicyServer.Start();
- StartListening();
- return 0;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement