当前位置：首页 > 科技 > 软件

了解HttpListener：用于创建基于HTTP协议的桌面&Web应用程序

来源：责编：时间：2024-02-29 14:37:13 113观看

导读一、场景思考在某些情况下，如使用WPF、WinForm或Windows服务开发的程序，可能需要提供接口以便第三方服务主动与其通信，并进行服务调用和数据推送，你想到哪些简单的方式快速实现？二、方案对比想到的部分实现方式有以下几种：

一、场景思考

在某些情况下，如使用WPF、WinForm或Windows服务开发的程序，可能需要提供接口以便第三方服务主动与其通信，并进行服务调用和数据推送，你想到哪些简单的方式快速实现？

二、方案对比

想到的部分实现方式有以下几种：

Web服务：使用Web服务（如RESTful API）可以使得第三方服务通过HTTP协议与你的程序通信。在WPF和WinForm中，可以使用ASP.NET Web API或ASP.NET Core Web API来实现接口逻辑。在Windows服务中，可以使用相应的框架（如Topshelf）来实现接口逻辑。

消息队列：使用消息队列（如RabbitMQ、Kafka）可以使得第三方服务通过异步消息传递与你的程序通信。这样可以提高程序的可靠性和扩展性，避免因为第三方服务的延迟或故障导致程序出现问题。

RPC（Remote Procedure Call）：使用RPC可以使得第三方服务像调用本地函数一样调用你的程序提供的接口。常见的RPC框架包括gRPC、Apache Thrift等。

Socket编程：使用Socket编程可以使得第三方服务与你的程序建立长连接，进行实时通信。这种方式适合需要高频率交互的场景，但需要考虑网络稳定性和安全性等问题。

其他方式：根据具体业务需求，还可以使用其他方式来实现接口的提供，如使用FTP、SMTP等协议进行文件传输和邮件推送等。

三、方案择一

本文就是采用一种非常简单的方式来对外提供接口，代码很简单就是使用.net里的System.Net命名空间下的HttpListener就可以实现Http协议的Server端。

适用场景说明

HttpListener 是 .NET Framework 提供的一个类，用于创建基于 HTTP 协议的服务器。它可以在本地监听指定的 IP 地址和端口号，并接收来自客户端的 HTTP 请求。HttpListener 可以用于各种场景，包括但不限于以下几个方面：

Web API：可以使用 HttpListener 创建自己的 Web API 服务，接收客户端的 HTTP 请求，并根据请求内容进行相应的处理和响应。这对于需要轻量级的、自定义的 Web 服务非常有用，尤其是在没有使用 ASP.NET 或其他 Web 框架的情况下。

嵌入式 Web 服务器：如果应用程序需要内置一个简单的 Web 服务器，以提供静态文件或动态内容，那么可以使用 HttpListener。例如，你可以将 HTML、CSS、JavaScript 文件作为静态资源提供给客户端，或者根据客户端请求生成动态的 HTML 页面。

反向代理：HttpListener 还可以用于创建反向代理服务器。通过监听指定的端口，将客户端的请求转发到不同的后端服务器上，并将后端服务器的响应返回给客户端。这在构建高性能、负载均衡的 Web 服务器集群时非常有用。

测试和调试：在开发和调试阶段，可以使用 HttpListener 模拟一个简单的 HTTP 服务器，以接收和处理来自客户端的请求。这样可以方便地测试和调试应用程序，而无需依赖于外部的 Web 服务器。

注意事项：使用 HttpListener 创建的服务器通常是基于 HTTP 协议的，因此它适用于与客户端之间进行 HTTP 通信的场景。对于其他协议（如 TCP、UDP 等），可能需要使用不同的技术和类库来实现。此外，使用 HttpListener 创建的服务器通常是单线程的，因此在高并发的情况下，可能需要进行性能优化或考虑使用其他技术来提高并发处理能力。

官网的示例代码

下面是服务端一个实现代码：

using Newtonsoft.Json;using System;using System.Collections.Generic;using System.IO;using System.Linq;using System.Net;using System.Text;using System.Threading.Tasks;namespace CustomHttpServer{    public class HttpServerService    {        private static bool isExcute = true;        private static HttpListener listener = new HttpListener();        public static void Start()        {           //单独开启一个线程执行监听消息            System.Threading.ThreadPool.QueueUserWorkItem(w => Excute());        }        private static void Excute()        {            if (HttpListener.IsSupported)            {                if (!listener.IsListening)                {                   //添加需要监听的url                    listener.Prefixes.Add("http://127.0.0.1:8888/");                     //开始监听端口，接收客户端请求                    listener.Start();                 }                while (isExcute)                {                    try                    {                        //阻塞主函数至接收到一个客户端请求为止  等待请求                        HttpListenerContext context = listener.GetContext();                        //解析请求                        HttpListenerRequest request = context.Request;                        //构造响应                        HttpListenerResponse response = context.Response;                        string httpMethod = request.HttpMethod?.ToLower();                        string rawUrl = request.RawUrl;                        var Url = request.Url;                        if (httpMethod == "get")                        {                            //获取查询参数                            var queryString = request.QueryString;                            //TODO 其他操作                        }                        else if (httpMethod == "post")                        {                           // TODO 处理请求体数据                             var reader = new StreamReader(request.InputStream);                            var questBody = reader.ReadToEnd();                            if (!string.IsNullOrEmpty(rawUrl))                            {                               //TODO 反序列化RequestBody，调用其他业务                            }                        }                        var responseString = string.Empty;                        responseString = JsonConvert.SerializeObject(new { code = 1, msg = "发送成功" });                        byte[] buffer = System.Text.Encoding.UTF8.GetBytes(responseString);                        //对客户端输出相应信息.                        response.ContentLength64 = buffer.Length;                        //发送响应                        using (System.IO.Stream output = response.OutputStream)                        {                            output.Write(buffer, 0, buffer.Length);                        }                    }                    catch (Exception exceotion)                    {                        string str = exceotion.Message;                    }                }            }            else            {                // TODO  系统不支持HttpListener            }        }        public static void Stop()        {            isExcute = false;            if (listener.IsListening)                listener.Stop();        }    }}

WPF客户端调用：

/// <summary>    /// App.xaml 的交互逻辑    /// </summary>    public partial class App : Application    {        public App()        {            HttpServerService.Start();        }    }

Windows服务调用：

protected override void OnStart(string[] args){  HttpServerService.Start();}protected override void OnStop(){  //停止监听  HttpServerService.Stop();}

作为文件服务器的应用。

using System;using System.IO;using System.Net;namespace FileServerDemo{    public class FileServer    {        private static FileServer _instance;        private HttpListener _listener;        private string _rootDirectory;        private FileServer()        {            _rootDirectory = @"C:/Files/"; // 指定文件根目录        }        public static FileServer Instance        {            get            {                if (_instance == null)                {                    _instance = new FileServer();                }                return _instance;            }        }        public void Start()        {            if (_listener != null && _listener.IsListening)            {                throw new InvalidOperationException("File server is already running.");            }            string url = "http://localhost:8080/";            try            {                _listener = new HttpListener();                _listener.Prefixes.Add(url);                _listener.Start();                Console.WriteLine($"File Server is running. Listening on {url}");                while (true)                {                    HttpListenerContext context = _listener.GetContext();                    HttpListenerRequest request = context.Request;                    HttpListenerResponse response = context.Response;                    string filePath = Path.Combine(_rootDirectory, request.Url.LocalPath.TrimStart('/'));                    if (File.Exists(filePath))                    {                        byte[] buffer = File.ReadAllBytes(filePath);                        response.ContentType = GetContentType(filePath);                        response.ContentLength64 = buffer.Length;                        response.OutputStream.Write(buffer, 0, buffer.Length);                        response.OutputStream.Close();                    }                    else                    {                        response.StatusCode = (int)HttpStatusCode.NotFound;                        response.Close();                    }                }            }            catch (Exception ex)            {                Console.WriteLine($"Error: {ex.Message}");            }        }        public void Stop()        {            if (_listener != null && _listener.IsListening)            {                _listener.Stop();                _listener.Close();                _listener = null;                Console.WriteLine("File Server stopped.");            }        }        private string GetContentType(string filePath)        {            string extension = Path.GetExtension(filePath).ToLower();            switch (extension)            {                case ".txt":                    return "text/plain";                case ".html":                    return "text/html";                case ".css":                    return "text/css";                case ".js":                    return "application/javascript";                case ".jpg":                case ".jpeg":                    return "image/jpeg";                case ".png":                    return "image/png";                default:                    return "application/octet-stream";            }        }    }}

在上述示例代码中，我们展示了如何使用 HttpListener 类构建一个简单的文件服务器。通过监听指定的 URL，并在接收到请求时返回对应的文件内容，我们可以实现一个基本的文件服务功能。

社区也有很多案例介绍

总之，HttpListener是一个强大而灵活的类，可以用于创建基于HTTP协议的服务器应用程序。它提供了丰富的功能和灵活的配置选项，能够轻松地处理HTTP请求和响应。通过深入了解HttpListener的用法和特性，就可以更好地利用它的优势，来提供高效、可靠的网络服务。因此，如果您正在开发基于HTTP的应用程序，不妨考虑使用HttpListener来实现您的需求。

本文链接：http://www.28at.com/showinfo-26-75296-0.html了解HttpListener：用于创建基于HTTP协议的桌面&Web应用程序

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：基于内存和 Redis 的两级 Java 缓存框架

下一篇： Lighthouse —— 优秀的网页性能分析工具

标签：

热门焦点

K60 Pro官方停产第三方瞬间涨价

虽然没有官方宣布，但Redmi的一些高管也已经透露了，Redmi K60 Pro已经停产且不会补货，这一切都是为了即将到来的K60 Ultra铺路，属于厂家的正常操作。但有意思的是该机在停产之后
官方承诺：K60至尊版将会首批升级MIUI 15

全新的MIUI 15今天也有了消息，在官宣了K60至尊版将会搭载天玑9200+处理器和独显芯片X7的同时，Redmi给出了官方承诺，K60至尊重大更新首批升级，会首批推送MIUI 15。也就是说虽然
小米降噪蓝牙耳机Necklace分享：听一首歌读懂一个故事

在今天下午的小米Civi 2新品发布会上，小米还带来了一款新的降噪蓝牙耳机Necklace，我们也在发布结束的第一时间给大家带来这款耳机的简单分享。现在大家能见到最多的蓝牙耳机
华为开发者大会2023日程公开：开设鸿蒙HarmonyOS 4体验区

IT之家 7 月 31 日消息，华为今日公布了 HDC.Together 开发者大会 2023 的详细日程。整场大会将于 8 月 4 日-6 日之间举行，届时将发布最新一代鸿蒙 H
iQOO Neo8 Pro抢先上架：首发天玑9200+ 安卓性能之王

经过了一段时间的密集爆料，昨日iQOO官方如期对外宣布：将于5月23日推出全新的iQOO Neo8系列新品，官方称这是一款拥有旗舰级性能调校的作品。随着发布时
iQOO Neo8系列或定档5月23日：首发天玑9200+ 安卓跑分王者

去年10月，iQOO推出了iQOO Neo7系列机型，不仅搭载了天玑9000+，而且是同价位唯一一款天玑9000+直屏旗舰，一经上市便受到了用户的广泛关注。在时隔半年后，
OPPO K11评测：旗舰级IMX890加持 2000元档最强影像手机

【Techweb评测】中端机型用户群体巨大，占了中国目前手机市场的大头，一直以来都是各手机品牌的“必争之地”，其中OPPO K系列机型一直以来都以高品质、
2022爆款：ROG魔霸6 冰川散热系统持续护航

喜逢开学季，各大商家开始推出自己的新产品，进行打折促销活动。对于忠实的端游爱好者来说，能够拥有一款梦寐以求的笔记本电脑是一件十分开心的事。但是现在的
三翼鸟智能家居亮相电博会，让用户体验更真实

2021电博会在青岛国际会展中心开幕中，三翼鸟直接把“家”搬到了现场，成为了展会的一大看点。这也是三翼鸟继9月9日发布了行业首个一站式定制智慧家平台后的