ServerManager.cs

using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Globalization;
using System.Net;
using System.Text;
using System.Threading;
using System.Web;
using Newtonsoft.Json.Linq;
using Org.BouncyCastle.Utilities;

namespace PAYMAP_BACKEND
{
 public class ServerManager
 {
 private static ServerManager _instance;

 public static bool IsModuleRunning = false;
 public static bool IsModuleHealthy = false;

 private WebServer webServerGeocode;
 private WebServer webServerZeroPay;
 
 private ServerManager()
 {
 
 }

 public static ServerManager GetInstance()
 {
 return _instance ?? (_instance = new ServerManager());
 }

 public void StartWebServer()
 {
 webServerGeocode = new WebServer(GeocodeResponse, "http://devx.kr:9991/geocode/");
 webServerGeocode.Run();
 webServerZeroPay = new WebServer(ZeroPayResponse, "http://devx.kr:9991/zeropay/");
 webServerZeroPay.Run();
 }

 public void StopWebServer()
 {
 webServerGeocode?.Stop();
 webServerZeroPay?.Stop();
 }
 
 public static string GeocodeResponse(HttpListenerRequest request)
 {
 NameValueCollection queryCollection = HttpUtility.ParseQueryString(request.Url.Query);
 string inputId = queryCollection.Get("id");
 if (inputId == null || inputId.Equals(String.Empty)) inputId = Constants.NAVER_SB_ID;
 string inputKey = queryCollection.Get("key");
 if (inputKey == null || inputKey.Equals(String.Empty)) inputKey = Constants.NAVER_SB_KEY;
 string[] inputAddressArray;
 string inputAddress = queryCollection.Get("address");
 if (inputAddress == null || inputAddress.Equals(String.Empty)) inputAddress = "";
 inputAddressArray = inputAddress.Split('|');
 string inputCoordinate = queryCollection.Get("coordinate");
 if (inputCoordinate == null || inputCoordinate.Equals(String.Empty)) inputCoordinate = "";

 string[] headerId;
 string[] headerKey;
 string[] headerAddress;
 string[] headerCoordinate;
 headerId = request.Headers.GetValues("id");
 if (headerId != null && headerId.Length > 0)
 {
 inputId = headerId[0];
 }
 headerKey = request.Headers.GetValues("key");
 if (headerKey != null && headerKey.Length > 0)
 {
 inputKey = headerKey[0];
 }
 headerAddress = request.Headers.GetValues("address");
 if (headerAddress != null && headerAddress.Length > 0)
 {
 inputAddressArray = headerAddress;
 }
 headerCoordinate = request.Headers.GetValues("coordinate");
 if (headerCoordinate != null && headerCoordinate.Length > 0)
 {
 inputCoordinate = headerCoordinate[0];
 }

 JArray naverGeocodeResultArray = new JArray();
 WebClient naverGeocodeClient = new WebClient {Encoding = Encoding.UTF8};
 naverGeocodeClient.Headers.Add("X-NCP-APIGW-API-KEY-ID", inputId);
 naverGeocodeClient.Headers.Add("X-NCP-APIGW-API-KEY", inputKey);

 for (int i = 0; i < inputAddressArray.Length; i ++)
 {
 string requestURL = $"https://naveropenapi.apigw.ntruss.com/map-geocode/v2/geocode?query={inputAddressArray[i]}&coordinate={inputCoordinate}";
 JObject resultObject = JObject.Parse(naverGeocodeClient.DownloadString(requestURL));
 naverGeocodeResultArray.Add(resultObject);
 }

 return naverGeocodeResultArray.ToString();
 }
 
 public static string ZeroPayResponse(HttpListenerRequest request)
 {
 NameValueCollection queryCollection = HttpUtility.ParseQueryString(request.Url.Query);
 string inputSido = queryCollection.Get("sido");
 if (inputSido == null || inputSido.Equals(String.Empty)) inputSido = "0";
 string inputSigungu = queryCollection.Get("sigungu");
 if (inputSigungu == null || inputSigungu.Equals(String.Empty)) inputSigungu = "0";
 string inputAddress = queryCollection.Get("address");
 string inputName = queryCollection.Get("name");
 string inputType = queryCollection.Get("type");
 string inputMax = queryCollection.Get("max");
 if (inputMax == null || inputMax.Equals(String.Empty)) inputMax = "1000";

 JArray zeroResult = DatabaseManager.GetInstance().SearchShop(int.Parse(inputSido), int.Parse(inputSigungu), inputAddress, inputName, inputType, int.Parse(inputMax));
 
 return zeroResult.ToString();
 }

 }
 
 public class WebServer
 {
 private readonly HttpListener _listener = new HttpListener();
 private readonly Func<HttpListenerRequest, string> _responderMethod;
 
 public WebServer(IReadOnlyCollection<string> prefixes, Func<HttpListenerRequest, string> method)
 {
 if (!HttpListener.IsSupported)
 {
 throw new NotSupportedException("Needs Windows XP SP2, Server 2003 or later.");
 }
 
 if (prefixes == null || prefixes.Count == 0)
 {
 throw new ArgumentException("URI prefixes are required");
 }
 
 if (method == null)
 {
 throw new ArgumentException("responder method required");
 }
 
 foreach (var s in prefixes)
 {
 _listener.Prefixes.Add(s);
 }
 
 _responderMethod = method;
 _listener.Start();
 }
 
 public WebServer(Func<HttpListenerRequest, string> method, params string[] prefixes)
 : this(prefixes, method)
 {
 }
 
 public void Run()
 {
 ThreadPool.QueueUserWorkItem(o =>
 {
 LogManager.NewLog(LogType.ServerManager, LogLevel.Info, "WebServer:Run", "WebServer Started");
 try
 {
 while (_listener.IsListening)
 {
 ThreadPool.QueueUserWorkItem(c =>
 {
 var ctx = c as HttpListenerContext;
 try
 {
 if (ctx == null)
 {
 return;
 }
 
 var rstr = _responderMethod(ctx.Request);
 var buf = Encoding.UTF8.GetBytes(rstr);
 ctx.Response.Headers["Access-Control-Allow-Origin"] = "*";
 ctx.Response.Headers["Access-Control-Allow-Headers"] = "Content-Type";
 ctx.Response.Headers["Access-Control-Allow-Methods"] = "GET,POST,PUT,DELETE,OPTIONS";
 ctx.Response.Headers["Access-Control-Allow-Credentials"] = "true";
 ctx.Response.Headers["Content-Type"] = "application/json; charset=utf-8";
 ctx.Response.ContentLength64 = buf.Length;
 ctx.Response.OutputStream.Write(buf, 0, buf.Length);
 ctx.Response.ContentEncoding = Encoding.UTF8;
 }
 catch
 {
 // ignored
 }
 finally
 {
 // always close the stream
 if (ctx != null)
 {
 ctx.Response.OutputStream.Close();
 }
 }
 }, _listener.GetContext());
 }
 }
 catch (Exception ex)
 {
 // ignored
 }
 });
 }
 
 public void Stop()
 {
 _listener.Stop();
 _listener.Close();
 }
 }
}