zoukankan      html  css  js  c++  java
  • SignalR 中使用 MessagePack 序列化提高 WebSocket 通信性能

    It's like JSON.
    but fast and small.

    MessagePack is an efficient binary serialization format. It lets you exchange data among multiple languages like JSON. But it's faster and smaller. Small integers are encoded into a single byte, and typical short strings require only one extra byte in addition to the strings themselves.

    默认我们在 ASP.NET Core SignalR 中使用 WebSocket 协议通信,默认使用 JSON 格式数据传输,为了更高效我们可以使用 MessagePack 来替换。 MessagePack 是一个高效的二进制序列化格式。它让你像JSON一样可以在各种语言之间交换数据。但是它比JSON更快、更小。小的整数会被编码成一个字节,短的字符串仅仅只需要比它的长度多一字节的大小。

    在 SignalR 中使用 MessagePack 也很简单:

    public void ConfigureServices(IServiceCollection services)
            {
                //自定义配置
                services.Configure<DbSetting>(Configuration.GetSection("ConnectionStrings"));
    
                //https://docs.microsoft.com/en-us/aspnet/core/security/gdpr?view=aspnetcore-2.1
                services.Configure<CookiePolicyOptions>(options =>
                {
                    options.CheckConsentNeeded = context => true;
                    options.MinimumSameSitePolicy = SameSiteMode.None;
                });
    
                //添加 Hangfire 服务
                services.AddHangfire(config => config.UseRedisStorage(Redis));
                // services.AddHangfire(config => config.UseSqlServerStorage("<connection string>"));
    
                //添加 Cookie 中间件
                services.AddAuthentication(sharedOptions =>
                {
                    sharedOptions.DefaultScheme = CookieAuthenticationDefaults.AuthenticationScheme;
                    // sharedOptions.DefaultChallengeScheme = OpenIdConnectDefaults.AuthenticationScheme;
                })
    
                //.AddAzureAdB2C(opts => Configuration.Bind("AzureAdB2C", opts))
                .AddCookie(opts =>
                {
                    opts.LoginPath = new PathString("/account/login");
                    opts.AccessDeniedPath = new PathString("/account/denied");
                });
    
                services.AddSignalR(options =>
                {
                    //Faster pings for testing
                    //options.KeepAliveInterval = TimeSpan.FromSeconds(5);
                })
                .AddMessagePackProtocol(options =>
                {
                   // options.FormatterResolvers = new List<MessagePack.IFormatterResolver>()
                    //{
                     //   MessagePack.Resolvers.StandardResolver.Instance
                    //};
                })
                .AddRedis(Configuration.GetConnectionString("Redis"));
    
                //返回大小写问题
                services.AddMvc()
                        .AddJsonOptions(option => option.SerializerSettings.ContractResolver = new Newtonsoft.Json.Serialization.DefaultContractResolver());
            }
    .NET 客户端
    var hubConnection = new HubConnectionBuilder()
                            .WithUrl("/chatHub")
                            .AddMessagePackProtocol()
                            .Build();

    JavaScript 客户端

    npm install @aspnet/signalr-protocol-msgpack
    <script src="~/lib/signalr/signalr.js"></script>
    <script src="~/lib/msgpack5/msgpack5.js"></script>
    <script src="~/lib/signalr/signalr-protocol-msgpack.js"></script>
    const connection = new signalR.HubConnectionBuilder()
                                  .withUrl("/hqHub")
                                  .withHubProtocol(new signalR.protocols.msgpack.MessagePackHubProtocol())
                                  .build();

    运行日志

    image

    REFER:
    https://docs.microsoft.com/en-us/aspnet/core/signalr/messagepackhubprotocol?view=aspnetcore-2.1
    https://damienbod.com/2018/03/19/using-message-pack-with-asp-net-core-signalr/
    https://socket.io/docs/

  • 相关阅读:
    JQuery 日历控件
    恢复xp_cmdshell SQL Server阻止了对组件 'xp_cmdshell' 的过程'sys.xp_cmdshell' 启用
    XML基础总结
    09.09.16总结
    草根
    设计模式学习总结
    检索 COM 类工厂中 CLSID 为{0002450000000000C000000000000046} 的组件时失败,原因是出现以下错误: 80070005。
    09.09.22总结
    Singleton 单态模式
    【Tomcat源码学习】5.请求处理
  • 原文地址:https://www.cnblogs.com/Irving/p/9195213.html
Copyright © 2011-2022 走看看