关键词搜索

源码搜索 ×
×

C# 开启HTTP监听服务与线程数量控制

发布2018-07-14浏览2302次

详情内容

如何开IP和端口的HTTP监听这里就是按照实现这种方式来加以说明，另外线程不要再循环里面不停的new Thread()这样很耗性能。

开启HTTP服务监听
  1.         /// <summary>
  2.         /// 启动HttpService监听
  3.         /// </summary>
  4.         /// <param name="MyTask"></param>
  5.         /// <returns></returns>
  6.         public bool Start(Task MyTask)
  7.         {
  8.             this.MyTask = MyTask;
  9.             if (!HttpListener.IsSupported)
  10.             {
  11.                 SQ.Base.ErrorLog.WriteLog4("GovernmentHttpService::Start() HttpListener not support !", SQ.Base.LOGTYPE.ERRORD);
  12.                 return false;
  13.             }
  14.             if (m_http_thread != null)
  15.                 return true;
  16.  
  17.             string http_url = "http://" + MyTask.Config.GovWebIp + ":" + MyTask.Config.GovPort + "/";
  18.             try
  19.             {
  20.                 m_http_listener.AuthenticationSchemes = AuthenticationSchemes.Anonymous;
  21.                 m_http_listener.Prefixes.Add(http_url);
  22.                 m_http_listener.Start();
  23.  
  24.                 m_http_thread = new Thread(HttpServiceThd);
  25.                 m_http_thread.Name = "HttpServiceThd";
  26.                 m_http_thread.IsBackground = true;
  27.                 m_http_thread.Start();
  28.  
  29.                 m_service_thread = new Thread(ServiceThd);
  30.                 m_service_thread.Name = "ServiceThd";
  31.                 m_service_thread.IsBackground = true;
  32.                 m_service_thread.Start();
  33.             }
  34.             catch (Exception ex)
  35.             {
  36.                 SQ.Base.ErrorLog.WriteLog4Ex("GovernmentHttpService::Start " + http_url + " ", ex);
  37.             }
  38.  
  39.             return false;
  40.         }
  41.  
  42.  
  43.  
  44.  
  45.         /// <summary>
  46.         /// 线程处理http请求方法
  47.         /// </summary>
  48.         protected virtual void HttpServiceThd()
  49.         {
  50.             while (true)
  51.             {
  52.                 try
  53.                 {
  54.                     HttpListenerContext context = m_http_listener.GetContext();
  55.  
  56.                     HttpListenerRequest request = context.Request;
  57.                     HttpListenerResponse response = context.Response;
  58.  
  59.                     var param = request.Url.ToString();
  60.  
  61.                     // 解码ASCII参数
  62.                     // param = HttpDataParser.ASCII2Str(param);
  63.  
  64.                     // 解码UTF8参数
  65.                     param = Encoding.UTF8.GetString(Encoding.Default.GetBytes(param.ToString()));
  66.  
  67.                     Log.WriteLog4("上级平台请求:>>>>>>>>>>>>>>>" + param);
  68.  
  69.                     int index = param.LastIndexOf("/");
  70.                     param = param.Substring(index, param.Length - index);
  71.  
  72.                     // 替换"/"
  73.                     param = param.Replace("/", "");
  74.  
  75.                     // 预解析
  76.                     HttpDataParser.Validator preValidator = new HttpDataParser.Validator(MyTask);
  77.  
  78.                     if (preValidator.PreParse(param))
  79.                     {
  80.                         //验证通过之后调用接口复用或者建立连接传输流数据
  81.                         //validator.Sim,validator.Channel,validator.DataType;
  82.                         //redis key:车牌号码.车牌颜色.逻辑道通号.音视频标志
  83.                         //实时 real@json; 回放 back@json ;实时控制 realCtrl@json;
  84.                         HttpDataParser.Validator validator = HttpDataParser.Parse(MyTask, param);
  85.  
  86.                         bool status = validator.GetStatus();
  87.                         if (status)
  88.                         {
  89.                             Service service = new Service();
  90.                             service.Context = context;
  91.                             service.Validator = validator;
  92.                             string key = validator.PlateCode + "." + validator.PlateColor + "." + validator.Channel + "." + validator.DataType;
  93.                             dictionaryService.Add(key, service);
  94.                             dictionaryTime.Add(key, DateTime.Now);
  95.                         }
  96.                         else
  97.                         {
  98.                             // 未通过解析
  99.                             response.StatusCode = 300;
  100.                             response.Close();
  101.                         }
  102.                     }
  103.                     else
  104.                     {
  105.                         // 未通过预解析
  106.                         response.StatusCode = 300;
  107.                         response.Close();
  108.                     }
  109.                 }
  110.                 catch (Exception ex)
  111.                 {
  112.                     SQ.Base.ErrorLog.WriteLog4Ex("上级平台请求HTTP流服务->GovernmentHttpService:HttpServiceThd", ex);
  113.                 }
  114.             }
  115.         }

启动start方法即可。

控制线程数量

控制线程的数量可以有效提高系统性能，最简单的方式就是开启一个线程来处理一类业务，将自己的需要处理的加到一个集合中用线程去处理：

  1.                             Service service = new Service();
  2.                             service.Context = context;
  3.                             service.Validator = validator;
  4.                             string key = validator.PlateCode + "." + validator.PlateColor + "." + validator.Channel + "." + validator.DataType;
  5.                             dictionaryService.Add(key, service);
  6.                             dictionaryTime.Add(key, DateTime.Now);

执行业务处理：

  1.         class Service
  2.         {
  3.             public HttpListenerContext Context { set; get; }
  4.  
  5.             public HttpDataParser.Validator Validator { set; get; }
  6.  
  7.         }
  8.  
  9.         /// <summary>
  10.         /// 业务线程执行方法
  11.         /// </summary>
  12.         void ServiceThd()
  13.         {
  14.             while (true)
  15.             {
  16.                 try
  17.                 {
  18.                     TimeSpan timeSpan;
  19.                     foreach (var item in dictionaryService.ToList())
  20.                     {
  21.                         DateTime startTime;
  22.                         dictionaryTime.TryGetValue(item.Key, out startTime);
  23.                         timeSpan = DateTime.Now - startTime;
  24.                         if (timeSpan.Seconds < 5)
  25.                         {
  26.                             bool flag = ServiceProcess(item.Value.Context, item.Value.Validator);
  27.                             if (flag)
  28.                             {
  29.                                 dictionaryService.Remove(item.Key);
  30.                                 dictionaryTime.Remove(item.Key);
  31.                             }
  32.                         }
  33.                         else
  34.                         {
  35.                             dictionaryService.Remove(item.Key);
  36.                             dictionaryTime.Remove(item.Key);
  37.                         }
  38.                     }
  39.                     Thread.Sleep(1000);
  40.                 }
  41.                 catch (Exception ex)
  42.                 {
  43.                     SQ.Base.ErrorLog.WriteLog4Ex("上级平台业务处理线程执行GovernmentHttpService:ServiceThd",ex);
  44.                 }
  45.             }
  46.         }
  47.  
  48.         /// <summary>
  49.         /// 执行业务处理方法
  50.         /// </summary>
  51.         /// <param name="context"></param>
  52.         /// <param name="validator"></param>
  53.         bool ServiceProcess(HttpListenerContext context,HttpDataParser.Validator validator)
  54.         {
  55.             try
  56.             {
  57.                 string key = validator.PlateCode + "." + validator.PlateColor + "." + validator.Channel + "." + validator.DataType;
  58.  
  59.                 string result = HttpDataParser.GetRedisData(key);
  60.  
  61.                 if (!string.IsNullOrEmpty(result) && result.Contains("@"))
  62.                 {
  63.                     SQ.Base.Log.WriteLog4("上级平台业务处理Get data from redis:result=" + result);
  64.                     string[] strs = result.Split('@');
  65.  
  66.                     var type = strs[0];
  67.                     var json = strs[1];
  68.  
  69.                     if ("real".Equals(type))
  70.                     {
  71.                         // 实时视频
  72.                         JTSDownRealVideoRequest jtSDownRealVideoRequest = json.ParseJSON<JTSDownRealVideoRequest>();
  73.                         GovernmentWebClientManage.AcceptRealConnect(context, key, validator.Sim, (byte)validator.Channel, (byte)validator.DataType);
  74.                         return true;
  75.                     }
  76.                     else if ("back".Equals(type))
  77.                     {
  78.                         // 回放视频
  79.                         JTRTDownPlayBackMsgStartUp jtRTDownPlayBackMsgStartUp = json.ParseJSON<JTRTDownPlayBackMsgStartUp>();
  80.                         GovernmentWebClientManage.AcceptBackConnect(context, key, validator.Sim, (byte)validator.Channel, jtRTDownPlayBackMsgStartUp.PLAYBACK_STARTTIME.UNIXtoDateTime(), (long)jtRTDownPlayBackMsgStartUp.PLAYBACK_ENDTIME, (AudioVideoFlag)validator.DataType);
  81.                         return true;
  82.                     }
  83.                 }
  84.                 else
  85.                 {
  86.                     SQ.Base.Log.WriteLog4("上级平台业务处理Get data from redis:result="+result);
  87.                 }
  88.             }
  89.             catch (Exception ex)
  90.             {
  91.                 SQ.Base.ErrorLog.WriteLog4Ex("上级平台业务处理ServiceProcess read data from redis:", ex);
  92.             }
  93.             return false;
  94.         }

这里我们应该注意到，我们会启动这个线程，前面HTTP服务启动中有，代码如下：

  1.                 m_service_thread = new Thread(ServiceThd);
  2.                 m_service_thread.Name = "ServiceThd";
  3.                 m_service_thread.IsBackground = true;
  4.                 m_service_thread.Start();
注意：代码的规范性和简洁，才能保证优质的服务。

 要记得操作List和Dictionary加锁，以下是示例代码：

  1. using JT1078Server.Client.GovWebClient;
  2. using JX;
  3. using SQ.Base;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Net;
  8. using System.Text;
  9. using System.Text.RegularExpressions;
  10. using System.Threading;
  11. using System.Threading.Tasks;
  12.  
  13. namespace JT1078Server.Client.GovWeb
  14. {
  15.     /// <summary>
  16.     /// 上级政府平台HTTP请求流监听服务
  17.     /// </summary>
  18.     public class GovernmentHttpService
  19.     {
  20.         private HttpListener m_http_listener = new HttpListener();
  21.  
  22.         private Thread m_http_thread = null;
  23.  
  24.         private Thread m_service_thread = null;
  25.  
  26.         private Dictionary<string, DateTime> dictionaryTime = new Dictionary<string, DateTime>();
  27.  
  28.         private Dictionary<string, Service> dictionaryService = new Dictionary<string, Service>();
  29.  
  30.         Task MyTask=null;
  31.  
  32.         object obj = new object();
  33.  
  34.         /// <summary>
  35.         /// 启动HttpService监听
  36.         /// </summary>
  37.         /// <param name="MyTask"></param>
  38.         /// <returns></returns>
  39.         public bool Start(Task MyTask)
  40.         {
  41.             this.MyTask = MyTask;
  42.             if (!HttpListener.IsSupported)
  43.             {
  44.                 SQ.Base.ErrorLog.WriteLog4("GovernmentHttpService::Start() HttpListener not support !", SQ.Base.LOGTYPE.ERRORD);
  45.                 return false;
  46.             }
  47.             if (m_http_thread != null)
  48.                 return true;
  49.  
  50.             string http_url = "http://" + MyTask.Config.GovWebIp + ":" + MyTask.Config.GovPort + "/";
  51.             try
  52.             {
  53.                 m_http_listener.AuthenticationSchemes = AuthenticationSchemes.Anonymous;
  54.                 m_http_listener.Prefixes.Add(http_url);
  55.                 m_http_listener.Start();
  56.  
  57.                 m_http_thread = new Thread(HttpServiceThd);
  58.                 m_http_thread.Name = "HttpServiceThd";
  59.                 m_http_thread.IsBackground = true;
  60.                 m_http_thread.Start();
  61.  
  62.                 m_service_thread = new Thread(ServiceThd);
  63.                 m_service_thread.Name = "ServiceThd";
  64.                 m_service_thread.IsBackground = true;
  65.                 m_service_thread.Start();
  66.             }
  67.             catch (Exception ex)
  68.             {
  69.                 SQ.Base.ErrorLog.WriteLog4Ex("GovernmentHttpService::Start " + http_url + " ", ex);
  70.             }
  71.  
  72.             return false;
  73.         }
  74.  
  75.  
  76.  
  77.  
  78.         /// <summary>
  79.         /// 线程处理http请求方法
  80.         /// </summary>
  81.         protected virtual void HttpServiceThd()
  82.         {
  83.             while (true)
  84.             {
  85.                 try
  86.                 {
  87.                     HttpListenerContext context = m_http_listener.GetContext();
  88.  
  89.                     HttpListenerRequest request = context.Request;
  90.                     HttpListenerResponse response = context.Response;
  91.  
  92.                     var param = request.Url.ToString();
  93.                     Log.WriteLog4("上级平台原始请求:>>>>>>>>>>>>>>>" + param);
  94.                     param= System.Web.HttpUtility.UrlDecode(param, Encoding.UTF8);
  95.                     Log.WriteLog4("上级平台解码请求:>>>>>>>>>>>>>>>" + param);
  96.  
  97.                     // 解码ASCII参数
  98.                     // param = HttpDataParser.ASCII2Str(param);
  99.                     //if(true)
  100.                     //{
  101.                     //    GovernmentWebClientManage.AcceptRealConnect(context, "123", "013777882100", 1, 0);
  102.                     //}
  103.                     //continue;
  104.  
  105.                     // 解码ASCII参数
  106.                     // param = HttpDataParser.ASCII2Str(param);
  107.  
  108.                      解码UTF8参数
  109.                     //param = Encoding.UTF8.GetString(Encoding.Default.GetBytes(param.ToString()));
  110.                     
  111.  
  112.                     int index = param.LastIndexOf("/");
  113.                     param = param.Substring(index, param.Length - index);
  114.  
  115.                     // 替换"/"
  116.                     param = param.Replace("/", "");
  117.  
  118.                     // 预解析
  119.                     HttpDataParser.Validator preValidator = new HttpDataParser.Validator(MyTask);
  120.  
  121.                     if (preValidator.PreParse(param))
  122.                     {
  123.                         //验证通过之后调用接口复用或者建立连接传输流数据
  124.                         //validator.Sim,validator.Channel,validator.DataType;
  125.                         //redis key:车牌号码.车牌颜色.逻辑道通号.音视频标志
  126.                         //实时 real@json; 回放 back@json ;实时控制 realCtrl@json;
  127.                         HttpDataParser.Validator validator = HttpDataParser.Parse(MyTask, param);
  128.  
  129.                         bool status = validator.GetStatus();
  130.                         if (status)
  131.                         {
  132.                             Service service = new Service();
  133.                             service.Context = context;
  134.                             service.Validator = validator;
  135.                             string key = validator.PlateCode + "." + validator.PlateColor + "." + validator.Channel + "." + validator.DataType;
  136.                             // 添加到处理列表
  137.                             lock (obj)
  138.                             {
  139.                                 if (dictionaryService.ContainsKey(key))
  140.                                 {
  141.                                     dictionaryService[key] = service;
  142.                                     dictionaryTime[key] = DateTime.Now;
  143.                                 }
  144.                                 else
  145.                                 {
  146.                                     dictionaryService.Add(key, service);
  147.                                     dictionaryTime.Add(key, DateTime.Now);
  148.                                 }
  149.                             }
  150.                            
  151.                         }
  152.                         else
  153.                         {
  154.                             // 未通过解析
  155.                             response.StatusCode = 300;
  156.                             response.Close();
  157.                         }
  158.                     }
  159.                     else
  160.                     {
  161.                         // 未通过预解析
  162.                         response.StatusCode = 300;
  163.                         response.Close();
  164.                     }
  165.                 }
  166.                 catch (Exception ex)
  167.                 {
  168.                     SQ.Base.ErrorLog.WriteLog4Ex("上级平台请求HTTP流服务->GovernmentHttpService:HttpServiceThd", ex);
  169.                 }
  170.             }
  171.         }
  172.  
  173.         class Service
  174.         {
  175.             public HttpListenerContext Context { set; get; }
  176.  
  177.             public HttpDataParser.Validator Validator { set; get; }
  178.  
  179.         }
  180.  
  181.         /// <summary>
  182.         /// 业务线程执行方法
  183.         /// </summary>
  184.         void ServiceThd()
  185.         {
  186.             while (true)
  187.             {
  188.                 try
  189.                 {
  190.                     TimeSpan timeSpan;
  191.                     foreach (var item in dictionaryService.ToList())
  192.                     {
  193.                         DateTime startTime;
  194.                         dictionaryTime.TryGetValue(item.Key, out startTime);
  195.                         timeSpan = DateTime.Now - startTime;
  196.                         if (timeSpan.Seconds < 5)
  197.                         {
  198.                             bool flag = ServiceProcess(item.Value.Context, item.Value.Validator);
  199.                             if (flag)
  200.                             {
  201.                                 lock(obj)
  202.                                 {
  203.                                     dictionaryService.Remove(item.Key);
  204.                                     dictionaryTime.Remove(item.Key);
  205.                                 }
  206.                             }
  207.                         }
  208.                         else
  209.                         {
  210.                             lock(obj)
  211.                             {
  212.                                 dictionaryService.Remove(item.Key);
  213.                                 dictionaryTime.Remove(item.Key);
  214.                             }
  215.                         }
  216.                     }
  217.                     Thread.Sleep(1000);
  218.                 }
  219.                 catch (Exception ex)
  220.                 {
  221.                     SQ.Base.ErrorLog.WriteLog4Ex("上级平台业务处理线程执行GovernmentHttpService:ServiceThd",ex);
  222.                 }
  223.             }
  224.         }
  225.  
  226.         /// <summary>
  227.         /// 执行业务处理方法
  228.         /// </summary>
  229.         /// <param name="context"></param>
  230.         /// <param name="validator"></param>
  231.         bool ServiceProcess(HttpListenerContext context,HttpDataParser.Validator validator)
  232.         {
  233.             try
  234.             {
  235.                 string key = validator.PlateCode + "." + validator.PlateColor + "." + validator.Channel + "." + validator.DataType;
  236.  
  237.                 string result = HttpDataParser.GetRedisData(key);
  238.  
  239.                 if (!string.IsNullOrEmpty(result) && result.Contains("@"))
  240.                 {
  241.                     SQ.Base.Log.WriteLog4("上级平台业务处理Get data from redis:result=" + result);
  242.                     string[] strs = result.Split('@');
  243.  
  244.                     var type = strs[0];
  245.                     var json = strs[1];
  246.  
  247.                     if ("real".Equals(type))
  248.                     {
  249.                         // 实时视频
  250.                         JTSDownRealVideoRequest jtSDownRealVideoRequest = json.ParseJSON<JTSDownRealVideoRequest>();
  251.                         GovernmentWebClientManage.AcceptRealConnect(context, key, validator.Sim, (byte)validator.Channel, (byte)validator.DataType);
  252.                         return true;
  253.                     }
  254.                     else if ("back".Equals(type))
  255.                     {
  256.                         // 回放视频
  257.                         JTRTDownPlayBackMsgStartUp jtRTDownPlayBackMsgStartUp = json.ParseJSON<JTRTDownPlayBackMsgStartUp>();
  258.                         GovernmentWebClientManage.AcceptBackConnect(context, key, validator.Sim, (byte)validator.Channel, jtRTDownPlayBackMsgStartUp.PLAYBACK_STARTTIME.UNIXtoDateTime(), (long)jtRTDownPlayBackMsgStartUp.PLAYBACK_ENDTIME, (AudioVideoFlag)validator.DataType);
  259.                         return true;
  260.                     }
  261.                 }
  262.                 else
  263.                 {
  264.                     SQ.Base.Log.WriteLog4("上级平台业务处理Get data from redis:result="+result);
  265.                 }
  266.             }
  267.             catch (Exception ex)
  268.             {
  269.                 SQ.Base.ErrorLog.WriteLog4Ex("上级平台业务处理ServiceProcess read data from redis:", ex);
  270.             }
  271.             return false;
  272.         }
  273.     }
  274. }



相关技术文章

最新源码

下载排行榜
点击QQ咨询
开通会员
返回顶部
×
微信扫码支付 元
微信扫码支付
确定支付下载
请使用微信描二维码支付
×

提示信息

×

选择支付方式

  • 微信支付
  • 支付宝付款
确定支付下载