Как сделать http-запросы к tcp-серверу? - PullRequest
4 голосов
/ 16 марта 2012

Я хочу создать TCP-сервер, который будет прослушивать порт 443, чтобы он мог получать HTTP-запросы и отправлять обратно.

Сейчас я использую Apache & PHP, чтобы сделать это обычным способом, ноМожно ли сделать это без веб-сервера?

Например, я создал традиционное приложение клиент / сервер TCP / IP в C # .NET.Можно ли использовать эту реализацию для обработки HTTP-запросов вместо использования веб-сервера?

Ответы [ 2 ]

3 голосов
/ 16 марта 2012

На самом низком уровне вы можете сделать это с помощью класса HTTP Listener.

http://geekswithblogs.net/Nitin/archive/2008/06/22/using-the-http-listener-class.aspx

Однажды я написал что-то похожее на универсальный проект, поэтому я могу искать код, если у вас есть какие-то конкретные вопросы.

Если вы хотите подняться выше, вы можете заглянуть в веб-сервисы.

Вот часть моего кода ... посмотрим, что вы можете с ним сделать. :

IPAddress address = IPAddress.Parse("127.0.0.1");
        IPEndPoint port = new IPEndPoint(address, 9999); //port 9999

        TcpListener listener = new TcpListener(port);

        listener.Start();

        Console.WriteLine("--Server loaded--");

        while (true) //loop forever
        {

            Console.WriteLine("Waiting for New Client");
            Socket sock = listener.AcceptSocket();
            byte[] buffer = new byte[32];

            string incomingMessage="";

            //read:
            while (sock.Available > 0)
            {
                int gotBytes = sock.Receive(buffer);
                incomingMessage += Encoding.ASCII.GetString(buffer, 0, gotBytes);

            }

            //debugging:
            //Console.WriteLine(incomingMessage);

            //Now check whether its a GET or a POST

            if (incomingMessage.ToUpper().Contains("POST") && incomingMessage.ToUpper().Contains("/DOSEARCH")) //a search has been asked for
            {

                Console.WriteLine("Query Has Been Received");

                //extracting the post data

                string htmlPostData = incomingMessage.Substring(incomingMessage.IndexOf("songName"));

                string[] parameters = htmlPostData.Split('&');

                string[] inputs = new string[5];

                for (int i=0; i<parameters.Length; i++)
                {
                    inputs[i] = (parameters[i].Split('='))[1];
                    inputs[i] = inputs[i].Replace('+',' ');
                }

...

byte[] outbuffer = Encoding.ASCII.GetBytes(answerPage.ToString());
                sock.Send(outbuffer);

                Console.WriteLine("Results Sent");

                sock.Close();
1 голос
/ 17 марта 2012

Этот проект может помочь вам создать веб-сервер с нуля: MiniHttpd: библиотека веб-сервера HTTP , использующая чистый TCP / IP

Но вместо того, чтобы иметь дело со многими ненужными деталями, такими какРазбор заголовков, сжатие, аутентификация, ssl и т. д. Я бы использовал встроенный HttpListener класс.

Вот упрощенный (но работающий) многопоточный WebServer

void CreateWebServer()
{
    HttpListener listener = new HttpListener();
    listener.Prefixes.Add("http://*:8080/");
    listener.Start();

    new Thread(
        () =>
        {
            while (true)
            {
                HttpListenerContext ctx = listener.GetContext();
                ThreadPool.QueueUserWorkItem((_) => ProcessRequest(ctx));
            }
        }
    ).Start();
}

void ProcessRequest(HttpListenerContext ctx)
{
    string responseText = "Hello";
    byte[] buf = Encoding.UTF8.GetBytes(responseText);

    Console.WriteLine(ctx.Request.Url);

    ctx.Response.ContentEncoding = Encoding.UTF8;
    ctx.Response.ContentType = "text/html";
    ctx.Response.ContentLength64 = buf.Length;


    ctx.Response.OutputStream.Write(buf, 0, buf.Length);
    ctx.Response.Close();
}

РЕДАКТИРОВАТЬ

Я немного изменил сервер, чтобы он стал хостом RESTful WebService (MyService).Возвращает результат как Json .Вы можете назвать это как http://localhost:8080/?method=Calc&i=5&j=4 (я упустил много проверок ошибок для простоты)

public class MyService
{
    public Result Calc(int i, int j)
    {
        return new Result() { Addition = i + j, Multiplication = i * j };
    }
}

public class Result
{
    public int Addition { set; get; }
    public int Multiplication { set; get; }
}

void CreateWebServer()
{
    MyService service = new MyService();

    HttpListener listener = new HttpListener();
    listener.Prefixes.Add("http://*:8080/");
    listener.Start();

    new Thread(
        () =>
        {
            while (true)
            {
                HttpListenerContext ctx = listener.GetContext();
                ThreadPool.QueueUserWorkItem((_) => ProcessRequest(ctx,service));
            }

        }
    ).Start();
}

void ProcessRequest(HttpListenerContext ctx,MyService service)
{
    try
    {
        string responseText = Execute(ctx, service);

        byte[] buf = Encoding.UTF8.GetBytes(responseText);

        ctx.Response.ContentEncoding = Encoding.UTF8;
        ctx.Response.ContentType = "application/json";
        ctx.Response.ContentLength64 = buf.Length;


        ctx.Response.OutputStream.Write(buf, 0, buf.Length);
    }
    catch
    {
        ctx.Response.StatusCode = (int) HttpStatusCode.NotFound;
    }

    ctx.Response.Close();
}

string Execute(HttpListenerContext ctx, MyService service)
{
    System.Collections.Specialized.NameValueCollection nv = HttpUtility.ParseQueryString(ctx.Request.Url.Query);

    MethodInfo mi = service.GetType().GetMethod(nv["method"]);
    object[] parameters =  mi.GetParameters()
                             .Select(pi => Convert.ChangeType(nv[pi.Name], pi.ParameterType))
                             .ToArray();

    return JsonConvert.SerializeObject(mi.Invoke(service, parameters));
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...