Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

How to use this library for static files hosting? #321

Open
Wowhere opened this issue Nov 9, 2024 · 3 comments
Open

How to use this library for static files hosting? #321

Wowhere opened this issue Nov 9, 2024 · 3 comments

Comments

@Wowhere
Copy link

Wowhere commented Nov 9, 2024

I want to host static files from specified folder, so when i open http://localhost (address of server) i get the static content without downloading so i can host html,css,js as it was some default nginx configuration. How to do it?

@stratdev3
Copy link

Hi,

Just see the HTTP Server example

 // Create a new HTTP server
var server = new HttpCacheServer(IPAddress.Any, port);
server.AddStaticContent(www, "/api");

// Start the server
Console.Write("Server starting...");
server.Start();

@Wowhere
Copy link
Author

Wowhere commented Nov 10, 2024

I use the folowing code but request is hang up.
UPD. Overriding OnReceivedRequest doesnt change anything (still hang up) so i commented this overriding.
изображение

using System;
using System.Collections.Concurrent;
using System.Net;
using System.Net.Sockets;
using System.Text;
using NetCoreServer;

namespace HttpServer
{
    class CommonCache
    {
        public static CommonCache GetInstance()
        {
            if (_instance == null)
                _instance = new CommonCache();
            return _instance;
        }

        public string GetAllCache()
        {
            var result = new StringBuilder();
            result.Append("[\n");
            foreach (var item in _cache)
            {
                result.Append("  {\n");
                result.AppendFormat($"    \"key\": \"{item.Key}\",\n");
                result.AppendFormat($"    \"value\": \"{item.Value}\",\n");
                result.Append("  },\n");
            }
            result.Append("]\n");
            return result.ToString();
        }

        public bool GetCacheValue(string key, out string value)
        {
            return _cache.TryGetValue(key, out value);
        }

        public void PutCacheValue(string key, string value)
        {
            _cache[key] = value;
        }

        public bool DeleteCacheValue(string key, out string value)
        {
            return _cache.TryRemove(key, out value);
        }

        private readonly ConcurrentDictionary<string, string> _cache = new ConcurrentDictionary<string, string>();
        private static CommonCache _instance;
    }

    class HttpCacheSession : HttpSession
    {
        public HttpCacheSession(NetCoreServer.HttpServer server) : base(server) { }

        //protected override void OnReceivedRequest(HttpRequest request)
        //{
        //    // Show HTTP request content
        //    Console.WriteLine(request);

        //    // Process HTTP request methods
        //    if (request.Method == "HEAD")
        //        SendResponseAsync(Response.MakeHeadResponse());
        //    else if (request.Method == "GET")
        //    {
        //        string key = request.Url;

        //        // Decode the key value
        //        key = Uri.UnescapeDataString(key);
        //        key = key.Replace("/api/cache", "", StringComparison.InvariantCultureIgnoreCase);
        //        key = key.Replace("?key=", "", StringComparison.InvariantCultureIgnoreCase);

        //        if (string.IsNullOrEmpty(key))
        //        {
        //            // Response with all cache values
        //            SendResponseAsync(Response.MakeGetResponse(CommonCache.GetInstance().GetAllCache(), "application/json; charset=UTF-8"));
        //        }
        //        // Get the cache value by the given key
        //        else if (CommonCache.GetInstance().GetCacheValue(key, out var value))
        //        {
        //            // Response with the cache value
        //            SendResponseAsync(Response.MakeGetResponse(value));
        //        }
        //        else
        //            SendResponseAsync(Response.MakeErrorResponse(404, "Required cache value was not found for the key: " + key));
        //    }
        //    else if ((request.Method == "POST") || (request.Method == "PUT"))
        //    {
        //        string key = request.Url;
        //        string value = request.Body;

        //        // Decode the key value
        //        key = Uri.UnescapeDataString(key);
        //        key = key.Replace("/api/cache", "", StringComparison.InvariantCultureIgnoreCase);
        //        key = key.Replace("?key=", "", StringComparison.InvariantCultureIgnoreCase);

        //        // Put the cache value
        //        CommonCache.GetInstance().PutCacheValue(key, value);

        //        // Response with the cache value
        //        SendResponseAsync(Response.MakeOkResponse());
        //    }
        //    else if (request.Method == "DELETE")
        //    {
        //        string key = request.Url;

        //        // Decode the key value
        //        key = Uri.UnescapeDataString(key);
        //        key = key.Replace("/api/cache", "", StringComparison.InvariantCultureIgnoreCase);
        //        key = key.Replace("?key=", "", StringComparison.InvariantCultureIgnoreCase);

        //        // Delete the cache value
        //        if (CommonCache.GetInstance().DeleteCacheValue(key, out var value))
        //        {
        //            // Response with the cache value
        //            SendResponseAsync(Response.MakeGetResponse(value));
        //        }
        //        else
        //            SendResponseAsync(Response.MakeErrorResponse(404, "Deleted cache value was not found for the key: " + key));
        //    }
        //    else if (request.Method == "OPTIONS")
        //        SendResponseAsync(Response.MakeOptionsResponse());
        //    else if (request.Method == "TRACE")
        //        SendResponseAsync(Response.MakeTraceResponse(request.Cache.Data));
        //    else
        //        SendResponseAsync(Response.MakeErrorResponse("Unsupported HTTP method: " + request.Method));
        //}

        protected override void OnReceivedRequestError(HttpRequest request, string error)
        {
            Console.WriteLine($"Request error: {error}");
        }

        protected override void OnError(SocketError error)
        {
            Console.WriteLine($"HTTP session caught an error: {error}");
        }
    }

    class HttpCacheServer : NetCoreServer.HttpServer
    {
        public HttpCacheServer(IPAddress address, int port) : base(address, port) { }

        protected override TcpSession CreateSession() { return new HttpCacheSession(this); }

        protected override void OnError(SocketError error)
        {
            Console.WriteLine($"HTTP session caught an error: {error}");
        }
    }

    class Program
    {
        static void Main(string[] args)
        {
            var server = new HttpCacheServer(IPAddress.Any, 8080);
            server.AddStaticContent("D:\\distr", "/api");

            // Start the server
            Console.Write("Server starting...");
            server.Start();
            for (; ; )
            {
                string line = Console.ReadLine();
                if (string.IsNullOrEmpty(line))
                    break;

                // Restart the server
                if (line == "!")
                {
                    Console.Write("Server restarting...");
                    server.Restart();
                    Console.WriteLine("Done!");
                }
            }
        }
    }
}

@WangYou77
Copy link

对于Http请求没有任何处理自然会 hang up

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants