百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

.NET框架之“小马过河”(小马过河国际教育咨询有限公司)

ccwgpt 2024-09-23 04:27 46 浏览 0 评论

.NET框架之“小马过河”

有许多流行的 .NET框架,大家都觉得挺“重”,认为很麻烦,重量级,不如其它“轻量级”框架,从而不愿意使用。面对形形色色的框架发愁,笔者也曾发愁。但我发现只要敢于尝试,这些框架都是“纸老虎”。就像“小马过河”一样,自己尝试一下,就会发现“原来河水既不像老牛说的那样浅,也不像松鼠说的那样深。”

项目中的代码,都在 LINQPad6中运行并测试通过,也可以复制到VisualStudio中执行。

做简单的 Http服务器很“重”

有些非常简单的 Http服务器,我看到有些.NET开发居然也用Node.jsPython等语言,一问,他们会回答说“这种简单的东西,用.NET,太重了”。殊不知其实用.NET做起来,也很轻(甚至更轻):

  1. // 代码不需要引入任何第三方包

  2. var http = new HttpListener;

  3. http.Prefixes.Add("http://localhost:8080/");

  4. http.Start;


  5. while (true)

  6. {

  7. var ctx = await http.GetContext;

  8. using var writer = new StreamWriter(ctx.Response.OutputStream);

  9. writer.Write(DateTime.Now);

  10. }

运行效果:

可见,包括空行,仅10行代码即可完成一个简单的 HTTP服务器。

使用 EntityFramework很“重”

EntityFramework,简称EF,现在有两个版本,EFCoreEF6,其中EFCore可以同时运行在.NETFramework.NETCore中,但EF6只能在.NETFramework中运行。本文中只测试了EFCore,但EF6代码也一样简单。

EntityFramework.NET下常用的数据访问框架,以代码简单、功能强大而著名。但不少人却嗤之以鼻、不以为意。询问时,回答说EntityFramework很“重”。

这个“重”字,我理解为它可能占用内存高,或者它可能代码极其麻烦,配置不方便(像iBatis/Hibernate那样),真的这样吗?

如图,假设我有一个 UserVoiceStatus表:

下面,我们通过 EF将数据取出来:

  1. // 引用NuGet包:

  2. // Microsoft.EntityFrameworkCore.SqlServer

  3. void Main

  4. {

  5. var db = new MyDB(new DbContextOptionsBuilder

  6. .UseSqlServer(Util.GetPassword("ConnectionString"))

  7. .Options);

  8. db.UserVoiceStatus.Dump;

  9. }


  10. public class UserVoiceStatus

  11. {

  12. public byte Id { get; set; }

  13. public string Name { get; set; }

  14. }


  15. public class MyDB : DbContext

  16. {

  17. public MyDB(DbContextOptions options): base(options)

  18. {

  19. }


  20. public DbSet<UserVoiceStatus> UserVoiceStatus { get; set; }

  21. }

执行效果如图:

注意,如果使用 LINQPad,事情还能更简单,只要一行代码即可,效果完全一样:UserVoiceStatuses

使用 ASP.NET MVC很“重”

上文说到了如何做一个简单的 Http服务器,如果想复杂一点,初始化ASP.NET MVC也很简单,甚至只需要一个文件即可完成:

  1. void Main

  2. {

  3. WebHost

  4. .CreateDefaultBuilder

  5. .UseStartup<UserQuery>

  6. .UseUrls("https://localhost:55555")

  7. .Build

  8. .Run;

  9. }


  10. public void ConfigureServices(IServiceCollection services)

  11. {

  12. services.AddControllers;

  13. }


  14. public void Configure(IApplicationBuilder app)

  15. {

  16. app.UseRouting;

  17. app.UseEndpoints(endpoints =>

  18. {

  19. endpoints.MapControllerRoute(

  20. name: "default",

  21. pattern: "{controller}/{action}/{id?}",

  22. defaults: new { controller = "Home", action = "Index" });

  23. });

  24. }


  25. namespace Controllers

  26. {

  27. public class HomeController : Controller

  28. {

  29. public DateTime Index

  30. {

  31. return DateTime.Now;

  32. }

  33. }

  34. }

麻雀虽小,五脏俱全,这么简短的几千代码中,可以使用 Https、包含了依赖注入,还能完整的路由功能,就构成了ASP.NET MVC的基本代码。运行效果如图:

使用 WebSockets很“重”

WebSockets是个流行的Http双向通信技术,以前在Node.js中很流行(用socket.io)。代码如下:

  1. async Task Main

  2. {

  3. await WebHost

  4. .CreateDefaultBuilder

  5. .UseStartup<UserQuery>

  6. .UseUrls("https://*:55555")

  7. .Build

  8. .RunAsync;

  9. }


  10. async Task Echo(HttpContext ctx, WebSocket webSocket, CancellationToken cancellationToken)

  11. {

  12. var buffer = new byte[4096];

  13. ValueWebSocketReceiveResult result = await webSocket.ReceiveAsync(buffer.AsMemory, cancellationToken);

  14. while (!result.EndOfMessage)

  15. {

  16. await webSocket.SendAsync(buffer.AsMemory(..result.Count), result.MessageType, result.EndOfMessage, cancellationToken);

  17. result = await webSocket.ReceiveAsync(buffer.AsMemory, cancellationToken);

  18. }

  19. await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "NA", cancellationToken);

  20. }


  21. public void ConfigureServices(IServiceCollection services)

  22. {

  23. }


  24. public void Configure(IApplicationBuilder app)

  25. {

  26. app.UseWebSockets;

  27. app.Use(async (ctx, next) =>

  28. {

  29. if (ctx.Request.Path == "/ws")

  30. {

  31. if (ctx.WebSockets.IsWebSocketRequest)

  32. {

  33. WebSocket webSocket = await ctx.WebSockets.AcceptWebSocketAsync;

  34. await Echo(ctx, webSocket, CancellationToken.None);

  35. return;

  36. }

  37. }

  38. await next;

  39. });

  40. app.Run(x => x.Response.WriteAsync("Please call /ws using WebSockets."));

  41. }

该代码是个 Echo服务器,它会将客户端发过来和内容,按原因返回给客户端。然后,.NET也内置了WebSockets的客户端:可以高效地访问刚刚创建并运行的WebSockets服务器。

  1. using (var ws = new ClientWebSocket)

  2. {

  3. await ws.ConnectAsync(new Uri("wss://localhost:55555/ws"), CancellationToken.None);

  4. var completeEvent = new ManualResetEventSlim;

  5. var cts = new CancellationTokenSource;

  6. new Task( => SendMessage(ws, cts)).Start;


  7. var buffer = new byte[4096];

  8. do

  9. {

  10. var r = await ws.ReceiveAsync(buffer, cts.Token);

  11. $"[{Util.ElapsedTime}] Received {Encoding.UTF8.GetString(buffer, 0, r.Count)}".Dump;

  12. } while (ws.State != WebSocketState.Closed);

  13. }

  14. $"[{Util.ElapsedTime}] Closed.".Dump;


  15. async void SendMessage(WebSocket ws, CancellationTokenSource cts)

  16. {

  17. for (var i = 0; i <3; ++i)

  18. {

  19. await ws.SendAsync(

  20. Encoding.UTF8.GetBytes($"[{Util.ElapsedTime}] Send {DateTime.Now.ToString}".Dump),

  21. WebSocketMessageType.Text,

  22. endOfMessage: false, default);

  23. await Task.Delay(1000);

  24. }

  25. await ws.CloseAsync(WebSocketCloseStatus.Empty, , default);

  26. cts.Cancel;

  27. }

最后,客户端与服务器双向通信效果如下:

使用 SignalR很“重”

SignalRASP.NET推出的抽象式的Http协议双向通信框架。SignalR可以用相同的API,支持像长轮询、ServerSentEventsWebSocket的技术。SignalR默认优先选择使用WebSocket以达到最高性能,如果客户端或服务器不支持,则会回退至其它稍慢的技术。

SignalR客户端还支持几乎所有语言、所有平台。它是如此好用,几乎可以取代传统的请求/响应,成为新的Http开发模型。(事实上Blazor正在尝试这样做)

SignalR最为令人震撼的,还是它非常简单的使用方式,而恰恰是这一点给人误会最深。它的服务端API,甚至比WebSocket还要简单清晰简单:

  1. async Task Main

  2. {

  3. await WebHost

  4. .CreateDefaultBuilder

  5. .UseStartup<UserQuery>

  6. .UseUrls("https://localhost:55555")

  7. .Build

  8. .RunAsync;

  9. }


  10. public void ConfigureServices(IServiceCollection services)

  11. {

  12. services.AddSignalR;

  13. }


  14. public void Configure(IApplicationBuilder app)

  15. {

  16. app.UseRouting;

  17. app.UseEndpoints(endpoints =>

  18. {

  19. endpoints.MapHub<Hubs.ChatHub>("/chat");

  20. });

  21. }


  22. namespace Hubs

  23. {

  24. public class ChatHub : Hub

  25. {

  26. public async Task Broadcast(string id, string text)

  27. {

  28. await Clients.All.SendAsync("Broadcast", id, text);

  29. }

  30. }

  31. }

前文提到, SignalR提供了所有平台的SignalR客户端,如jsAndroid等,其中当然(显然)也包括.NET的。SignalR.NET客户端使用起来也非常简单:

  1. // 引入NuGet包:Microsoft.AspNetCore.SignalR.Client

  2. // 代码在LINQPad中运行

  3. var hub = new HubConnectionBuilder

  4. .WithUrl("https://localhost:55555/chat")

  5. .Build;


  6. hub.On("Broadcast", (string id, string msg) =>

  7. {

  8. Console.WriteLine($"{id}: {msg}");

  9. });


  10. new Label("姓名: ").Dump;

  11. var idBox = new TextBox(Guid.NewGuid.ToString).Dump;

  12. await hub.StartAsync;

  13. while (true)

  14. {

  15. var text = Console.ReadLine;

  16. if (text == "Q") break;

  17. await hub.SendAsync("Broadcast", idBox.Text, text);

  18. }

这是一个非常简单的多人聊天室,运行效果如下:

总结

面对形形色色的框架发愁,笔者也曾发愁。但现在不了,什么框架拿过来,马上试试,也就几十秒钟的事。好用不好用,用用便知。

那么读者,你的“小马过河”的故事是怎样的呢?

相关推荐

十分钟让你学会LNMP架构负载均衡(impala负载均衡)

业务架构、应用架构、数据架构和技术架构一、几个基本概念1、pv值pv值(pageviews):页面的浏览量概念:一个网站的所有页面,在一天内,被浏览的总次数。(大型网站通常是上千万的级别)2、u...

AGV仓储机器人调度系统架构(agv物流机器人)

系统架构层次划分采用分层模块化设计,分为以下五层:1.1用户接口层功能:提供人机交互界面(Web/桌面端),支持任务下发、实时监控、数据可视化和报警管理。模块:任务管理面板:接收订单(如拣货、...

远程热部署在美团的落地实践(远程热点是什么意思)

Sonic是美团内部研发设计的一款用于热部署的IDEA插件,本文其实现原理及落地的一些技术细节。在阅读本文之前,建议大家先熟悉一下Spring源码、SpringMVC源码、SpringBoot...

springboot搭建xxl-job(分布式任务调度系统)

一、部署xxl-job服务端下载xxl-job源码:https://gitee.com/xuxueli0323/xxl-job二、导入项目、创建xxl_job数据库、修改配置文件为自己的数据库三、启动...

大模型:使用vLLM和Ray分布式部署推理应用

一、vLLM:面向大模型的高效推理框架1.核心特点专为推理优化:专注于大模型(如GPT-3、LLaMA)的高吞吐量、低延迟推理。关键技术:PagedAttention:类似操作系统内存分页管理,将K...

国产开源之光【分布式工作流调度系统】:DolphinScheduler

DolphinScheduler是一个开源的分布式工作流调度系统,旨在帮助用户以可靠、高效和可扩展的方式管理和调度大规模的数据处理工作流。它支持以图形化方式定义和管理工作流,提供了丰富的调度功能和监控...

简单可靠高效的分布式任务队列系统

#记录我的2024#大家好,又见面了,我是GitHub精选君!背景介绍在系统访问量逐渐增大,高并发、分布式系统成为了企业技术架构升级的必由之路。在这样的背景下,异步任务队列扮演着至关重要的角色,...

虚拟服务器之间如何分布式运行?(虚拟服务器部署)

  在云计算和虚拟化技术快速发展的今天,传统“单机单任务”的服务器架构早已难以满足现代业务对高并发、高可用、弹性伸缩和容错容灾的严苛要求。分布式系统应运而生,并成为支撑各类互联网平台、企业信息系统和A...

一文掌握 XXL-Job 的 6 大核心组件

XXL-Job是一个分布式任务调度平台,其核心组件主要包括以下部分,各组件相互协作实现高效的任务调度与管理:1.调度注册中心(RegistryCenter)作用:负责管理调度器(Schedule...

京东大佬问我,SpringBoot中如何做延迟队列?单机与分布式如何做?

京东大佬问我,SpringBoot中如何做延迟队列?单机如何做?分布式如何做呢?并给出案例与代码分析。嗯,用户问的是在SpringBoot中如何实现延迟队列,单机和分布式环境下分别怎么做。这个问题其实...

企业级项目组件选型(一)分布式任务调度平台

官网地址:https://www.xuxueli.com/xxl-job/能力介绍架构图安全性为提升系统安全性,调度中心和执行器进行安全性校验,双方AccessToken匹配才允许通讯;调度中心和执...

python多进程的分布式任务调度应用场景及示例

多进程的分布式任务调度可以应用于以下场景:分布式爬虫:importmultiprocessingimportrequestsdefcrawl(url):response=re...

SpringBoot整合ElasticJob实现分布式任务调度

介绍ElasticJob是面向互联网生态和海量任务的分布式调度解决方案,由两个相互独立的子项目ElasticJob-Lite和ElasticJob-Cloud组成。它通过弹性调度、资源管控、...

分布式可视化 DAG 任务调度系统 Taier 的整体流程分析

Taier作为袋鼠云的开源项目之一,是一个分布式可视化的DAG任务调度系统。旨在降低ETL开发成本,提高大数据平台稳定性,让大数据开发人员可以在Taier直接进行业务逻辑的开发,而不用关...

SpringBoot任务调度:@Scheduled与TaskExecutor全面解析

一、任务调度基础概念1.1什么是任务调度任务调度是指按照预定的时间计划或特定条件自动执行任务的过程。在现代应用开发中,任务调度扮演着至关重要的角色,它使得开发者能够自动化处理周期性任务、定时任务和异...

取消回复欢迎 发表评论: