smallchi
5 年之前
共有 2 個檔案被更改，包括 197 行新增 和 77 行删除
統一視圖
Diff Options
-
+57 -77README.md
-
+140 -0README_V2.2.1.md
+ 57
- 77
README.md
查看文件
| @@ -1,6 +1,6 @@ | |||||
| # JT808DotNetty | # JT808DotNetty | ||||
| 基于DotNetty封装的JT808DotNetty支持TCP/UDP通用消息业务处理 | |||||
| 基于DotNetty封装的JT808DotNetty支持TCP/UDP通用消息业务处理 | |||||
| [了解JT808协议进这边](https://github.com/SmallChi/JT808) | [了解JT808协议进这边](https://github.com/SmallChi/JT808) | ||||
| @@ -10,11 +10,13 @@ | |||||
| [了解JTNE协议进这边](https://github.com/SmallChi/JTNewEnergy) | [了解JTNE协议进这边](https://github.com/SmallChi/JTNewEnergy) | ||||
| [玩一玩压力测试](https://github.com/SmallChi/JT808DotNetty/blob/master/doc/README.md) | |||||
| [玩一玩压力测试](https://github.com/SmallChi/JT808DotNetty/blob/master/doc/README.md) | |||||
| [V2.2.1老版本](https://github.com/SmallChi/JT808DotNetty/blob/master/doc/README_V2.2.1.md) | |||||
| [](https://github.com/SmallChi/JT808DotNetty/blob/master/LICENSE) | [](https://github.com/SmallChi/JT808DotNetty/blob/master/LICENSE) | ||||
| ## 新网关的优势： | |||||
| ## 新网关的优势 | |||||
| 1. 跨平台 | 1. 跨平台 | ||||
| 2. 借助 .NET Core模块化的思想 | 2. 借助 .NET Core模块化的思想 | ||||
| @@ -25,13 +27,16 @@ | |||||
|  |  | ||||
| ## 基于WebApi的消息业务处理程序（JT808.DotNetty.WebApi） | |||||
| 通过继承JT808.DotNetty.Core.Handlers.JT808MsgIdHttpHandlerBase去实现自定义的WebApi接口服务。 | |||||
| ## 基于Grpc的消息业务处理程序(JT808.Gateway.GrpcService) | |||||
| [WebApi公共接口服务](https://github.com/SmallChi/JT808DotNetty/blob/master/api/README.md) | |||||
| ``` 1 | |||||
| services.AddGrpcClient<JT808Gateway.JT808GatewayClient>(o => | |||||
| { | |||||
| o.Address = new Uri("https://localhost:5001"); | |||||
| }); | |||||
| ``` | |||||
| ## 集成接口功能（JT808.DotNetty.Abstractions） | |||||
| ## 集成接口功能(JT808.Gateway.PubSub) | |||||
| |接口名称|接口说明|使用场景| | |接口名称|接口说明|使用场景| | ||||
| |:------:|:------|:------| | |:------:|:------|:------| | ||||
| @@ -44,7 +49,7 @@ | |||||
| > 使用物联网卡通过udp下发指令时，存储的那个socket地址端口，有效期非常短,不速度快点下发，那个socket地址端口就可能映射到别的对应卡去了,所以此处采用跟随设备消息下发指令。 | > 使用物联网卡通过udp下发指令时，存储的那个socket地址端口，有效期非常短,不速度快点下发，那个socket地址端口就可能映射到别的对应卡去了,所以此处采用跟随设备消息下发指令。 | ||||
| ## 基于网关的相关服务 | |||||
| ## 基于网关的相关服务(JT808.Gateway.BusinessServices) | |||||
| |服务名称|服务说明|使用场景| | |服务名称|服务说明|使用场景| | ||||
| |:------:|:------|:------| | |:------:|:------|:------| | ||||
| @@ -59,82 +64,57 @@ | |||||
| | Package Name | Version | Downloads | | | Package Name | Version | Downloads | | ||||
| | --------------------- | -------------------------------------------------- | --------------------------------------------------- | | | --------------------- | -------------------------------------------------- | --------------------------------------------------- | | ||||
| | Install-Package JT808.DotNetty.Abstractions |  |  | | |||||
| | Install-Package JT808.DotNetty.Core |  |  | | |||||
| | Install-Package JT808.DotNetty.Tcp |  |  | | |||||
| | Install-Package JT808.DotNetty.Udp |  |  | | |||||
| | Install-Package JT808.DotNetty.WebApi |  |  | | |||||
| | Install-Package JT808.DotNetty.WebApiClientTool |  |  | | |||||
| | Install-Package JT808.DotNetty.Client |  |  | | |||||
| | Install-Package JT808.DotNetty.Transmit |  |  | | |||||
| | Install-Package JT808.DotNetty.Traffic |  | | | |||||
| | Install-Package JT808.DotNetty.SessionNotice |  | | | |||||
| | Install-Package JT808.DotNetty.ReplyMessage |  | | | |||||
| | Install-Package JT808.DotNetty.MsgLogging |  | | | |||||
| | Install-Package JT808.DotNetty.MsgIdHandler |  | | | |||||
| | Install-Package JT808.DotNetty.Kafka |  |  | | |||||
| | Install-Package JT808.DotNetty.RabbitMQ |  |  | | |||||
| | Install-Package JT808.Gateway |  |  | | |||||
| | Install-Package JT808.Gateway.Kafka|  |  | | |||||
| ## 举个栗子1 | ## 举个栗子1 | ||||
| ``` demo1 | |||||
| static async Task Main(string[] args) | |||||
| 1.进入JT808.Gateway.SimpleServer项目下的Debug目录运行服务端 | |||||
| 2.进入JT808.Gateway.SimpleClient项目下的Debug目录运行客户端 | |||||
| ``` 1 | |||||
| static void Main(string[] args) | |||||
| { | { | ||||
| var serverHostBuilder = new HostBuilder() | |||||
| .ConfigureAppConfiguration((hostingContext, config) => | |||||
| { | |||||
| config.SetBasePath(AppDomain.CurrentDomain.BaseDirectory); | |||||
| config.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true); | |||||
| }) | |||||
| .ConfigureLogging((context, logging) => | |||||
| Host.CreateDefaultBuilder(args) | |||||
| .ConfigureWebHostDefaults(webBuilder => | |||||
| { | { | ||||
| logging.AddConsole(); | |||||
| logging.SetMinimumLevel(LogLevel.Trace); | |||||
| //配置Grpc服务端 | |||||
| webBuilder | |||||
| .ConfigureKestrel(options => | |||||
| { | |||||
| options.Listen(IPAddress.Any, 5001, listenOptions => | |||||
| { | |||||
| listenOptions.Protocols = HttpProtocols.Http2; | |||||
| listenOptions.UseHttps($"{Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Configs", "test.cer")}", ""); | |||||
| }); | |||||
| }) | |||||
| .Configure(app => | |||||
| { | |||||
| app.UseRouting(); | |||||
| app.UseEndpoints(endpoints => | |||||
| { | |||||
| //配置Grpc服务节点 | |||||
| endpoints.MapGrpcService<JT808GatewayService>(); | |||||
| }); | |||||
| }); | |||||
| }) | }) | ||||
| .ConfigureServices((hostContext, services) => | |||||
| .ConfigureServices((hostContext,services) => | |||||
| { | { | ||||
| services.AddSingleton<ILoggerFactory, LoggerFactory>(); | |||||
| services.AddSingleton(typeof(ILogger<>), typeof(Logger<>)); | |||||
| //services.Configure<KestrelServerOptions>(hostContext.Configuration.GetSection("Kestrel")); | |||||
| //添加Grpc服务 | |||||
| services.AddGrpc(); | |||||
| //添加JT808协议 | |||||
| services.AddJT808Configure() | services.AddJT808Configure() | ||||
| .AddJT808NettyCore(hostContext.Configuration) | |||||
| .AddJT808TcpNettyHost() | |||||
| .AddJT808UdpNettyHost() | |||||
| .AddJT808WebApiNettyHost() | |||||
| //扩展webapi JT808MsgIdHttpHandlerBase | |||||
| //.ReplaceMsgIdHandler<JT808MsgIdHttpCustomHandler>() | |||||
| //添加JT808网关配置 | |||||
| .AddJT808Gateway(hostContext.Configuration) | |||||
| //添加基于Tcp的808网关 | |||||
| .AddJT808GatewayTcpHost() | |||||
| //添加基于Udp的808网关 | |||||
| .AddJT808GatewayUdpHost() | |||||
| .Builder(); | .Builder(); | ||||
| //添加kafka插件 | |||||
| //.AddJT808ServerKafkaMsgProducer(hostContext.Configuration) | |||||
| //.AddJT808ServerKafkaMsgReplyConsumer(hostContext.Configuration) | |||||
| //.AddJT808ServerKafkaSessionProducer(hostContext.Configuration) | |||||
| //.Builder(); | |||||
| //webapi客户端调用 | |||||
| //services.AddHttpApi<IJT808DotNettyWebApi>().ConfigureHttpApiConfig((c, p) => | |||||
| //{ | |||||
| // c.HttpHost = new Uri("http://localhost:828/jt808api/"); | |||||
| // c.FormatOptions.DateTimeFormat = "yyyy-MM-dd HH:mm:ss.fff"; | |||||
| // c.LoggerFactory = p.GetRequiredService<ILoggerFactory>(); | |||||
| //}); | |||||
| //var client = services.BuildServiceProvider().GetRequiredService<IJT808DotNettyWebApi>(); | |||||
| //var result = client.GetTcpAtomicCounter().InvokeAsync().Result; | |||||
| }); | |||||
| await serverHostBuilder.RunConsoleAsync(); | |||||
| }) | |||||
| .Build() | |||||
| .Run(); | |||||
| } | } | ||||
| ``` | ``` | ||||
| 如图所示： | |||||
|  | |||||
| ## 举个栗子2 | |||||
| 1.拉取JT808子模块 | |||||
| 2.打开项目进行还原编译生成 | |||||
| 3.进入JT808.DotNetty.SimpleServer项目下的Debug目录运行服务端 | |||||
| 4.进入JT808.DotNetty.SimpleClient项目下的Debug目录运行客户端 | |||||
| 如图所示： | |||||
|  | |||||
+ 140
- 0
README_V2.2.1.md
查看文件
| @@ -0,0 +1,140 @@ | |||||
| # JT808DotNetty | |||||
| 基于DotNetty封装的JT808DotNetty支持TCP/UDP通用消息业务处理 | |||||
| [了解JT808协议进这边](https://github.com/SmallChi/JT808) | |||||
| [了解JT809协议进这边](https://github.com/SmallChi/JT809) | |||||
| [了解JT1078协议进这边](https://github.com/SmallChi/JT1078) | |||||
| [了解JTNE协议进这边](https://github.com/SmallChi/JTNewEnergy) | |||||
| [玩一玩压力测试](https://github.com/SmallChi/JT808DotNetty/blob/master/doc/README.md) | |||||
| [](https://github.com/SmallChi/JT808DotNetty/blob/master/LICENSE) | |||||
| ## 新网关的优势： | |||||
| 1. 跨平台 | |||||
| 2. 借助 .NET Core模块化的思想 | |||||
| 3. 单机同时一万辆车在线不是梦(真有一万辆车那都很吃香了<(￣3￣)> <(￣3￣)> <(￣3￣)> ) | |||||
| 4. 简单易上手 | |||||
| ## 设计模型 | |||||
|  | |||||
| ## 基于WebApi的消息业务处理程序（JT808.DotNetty.WebApi） | |||||
| 通过继承JT808.DotNetty.Core.Handlers.JT808MsgIdHttpHandlerBase去实现自定义的WebApi接口服务。 | |||||
| [WebApi公共接口服务](https://github.com/SmallChi/JT808DotNetty/blob/master/api/README.md) | |||||
| ## 集成接口功能（JT808.DotNetty.Abstractions） | |||||
| |接口名称|接口说明|使用场景| | |||||
| |:------:|:------|:------| | |||||
| | IJT808SessionProducer| 会话通知（在线/离线）数据生产接口| 有些超长待机的设备，不会实时保持连接，那么通过平台下发的命令是无法到达的，这时候就需要设备一上线，就即时通知服务去处理，然后在即时的下发消息到设备。| | |||||
| | IJT808SessionConsumer| 会话通知（在线/离线）数据消费接口| -| | |||||
| | IJT808MsgProducer| 数据生产接口| 网关将接收到的数据发送到队列| | |||||
| | IJT808MsgConsumer| 数据消费接口| 将数据进行对应的消息业务处理(例：设备流量统计、第三方平台数据转发、消息日志等) | | |||||
| | IJT808MsgReplyProducer| 应答数据生产接口|将生产的数据解析为对应的消息Id应答发送到队列 | | |||||
| | IJT808MsgReplyConsumer| 应答数据消费接口| 将接收到的应答数据下发给设备| | |||||
| > 使用物联网卡通过udp下发指令时，存储的那个socket地址端口，有效期非常短,不速度快点下发，那个socket地址端口就可能映射到别的对应卡去了,所以此处采用跟随设备消息下发指令。 | |||||
| ## 基于网关的相关服务 | |||||
| |服务名称|服务说明|使用场景| | |||||
| |:------:|:------|:------| | |||||
| |MsgIdHandler| 消息处理服务|从队列中消费设备上报数据，再结合自身的业务场景，将数据进行处理并入库 | | |||||
| |MsgLogging | 消息日志服务|从队列中消费设备上报和平台应答数据，再将数据存入influxdb等数据库中，便于技术和技术支持排查设备与平台交互的原始数据| | |||||
| |ReplyMessage| 消息响应服务| 用于响应设备上报消息，以及下发指令信息到设备| | |||||
| |SessionNotice| 会话管理服务| 通知设备上线下线，对于udp设备来说，可以在设备上线时，将指令跟随消息下发到设备| | |||||
| |Traffic|流量统计服务 |由于运营商sim卡查询流量滞后，通过流量统计服务可以实时准确的统计设备流量，可以最优配置设备的流量大小，以节省成本 | |||||
| |Transmit| 原包转发服务|该服务可以将设备上报原始数据转发到第三方，支持全部转发，指定终端号转发| | |||||
| ## NuGet安装 | |||||
| | Package Name | Version | Downloads | | |||||
| | --------------------- | -------------------------------------------------- | --------------------------------------------------- | | |||||
| | Install-Package JT808.DotNetty.Abstractions |  |  | | |||||
| | Install-Package JT808.DotNetty.Core |  |  | | |||||
| | Install-Package JT808.DotNetty.Tcp |  |  | | |||||
| | Install-Package JT808.DotNetty.Udp |  |  | | |||||
| | Install-Package JT808.DotNetty.WebApi |  |  | | |||||
| | Install-Package JT808.DotNetty.WebApiClientTool |  |  | | |||||
| | Install-Package JT808.DotNetty.Client |  |  | | |||||
| | Install-Package JT808.DotNetty.Transmit |  |  | | |||||
| | Install-Package JT808.DotNetty.Traffic |  | | | |||||
| | Install-Package JT808.DotNetty.SessionNotice |  | | | |||||
| | Install-Package JT808.DotNetty.ReplyMessage |  | | | |||||
| | Install-Package JT808.DotNetty.MsgLogging |  | | | |||||
| | Install-Package JT808.DotNetty.MsgIdHandler |  | | | |||||
| | Install-Package JT808.DotNetty.Kafka |  |  | | |||||
| | Install-Package JT808.DotNetty.RabbitMQ |  |  | | |||||
| ## 举个栗子1 | |||||
| ``` demo1 | |||||
| static async Task Main(string[] args) | |||||
| { | |||||
| var serverHostBuilder = new HostBuilder() | |||||
| .ConfigureAppConfiguration((hostingContext, config) => | |||||
| { | |||||
| config.SetBasePath(AppDomain.CurrentDomain.BaseDirectory); | |||||
| config.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true); | |||||
| }) | |||||
| .ConfigureLogging((context, logging) => | |||||
| { | |||||
| logging.AddConsole(); | |||||
| logging.SetMinimumLevel(LogLevel.Trace); | |||||
| }) | |||||
| .ConfigureServices((hostContext, services) => | |||||
| { | |||||
| services.AddSingleton<ILoggerFactory, LoggerFactory>(); | |||||
| services.AddSingleton(typeof(ILogger<>), typeof(Logger<>)); | |||||
| services.AddJT808Configure() | |||||
| .AddJT808NettyCore(hostContext.Configuration) | |||||
| .AddJT808TcpNettyHost() | |||||
| .AddJT808UdpNettyHost() | |||||
| .AddJT808WebApiNettyHost() | |||||
| //扩展webapi JT808MsgIdHttpHandlerBase | |||||
| //.ReplaceMsgIdHandler<JT808MsgIdHttpCustomHandler>() | |||||
| .Builder(); | |||||
| //添加kafka插件 | |||||
| //.AddJT808ServerKafkaMsgProducer(hostContext.Configuration) | |||||
| //.AddJT808ServerKafkaMsgReplyConsumer(hostContext.Configuration) | |||||
| //.AddJT808ServerKafkaSessionProducer(hostContext.Configuration) | |||||
| //.Builder(); | |||||
| //webapi客户端调用 | |||||
| //services.AddHttpApi<IJT808DotNettyWebApi>().ConfigureHttpApiConfig((c, p) => | |||||
| //{ | |||||
| // c.HttpHost = new Uri("http://localhost:828/jt808api/"); | |||||
| // c.FormatOptions.DateTimeFormat = "yyyy-MM-dd HH:mm:ss.fff"; | |||||
| // c.LoggerFactory = p.GetRequiredService<ILoggerFactory>(); | |||||
| //}); | |||||
| //var client = services.BuildServiceProvider().GetRequiredService<IJT808DotNettyWebApi>(); | |||||
| //var result = client.GetTcpAtomicCounter().InvokeAsync().Result; | |||||
| }); | |||||
| await serverHostBuilder.RunConsoleAsync(); | |||||
| } | |||||
| ``` | |||||
| 如图所示： | |||||
|  | |||||
| ## 举个栗子2 | |||||
| 1.拉取JT808子模块 | |||||
| 2.打开项目进行还原编译生成 | |||||
| 3.进入JT808.DotNetty.SimpleServer项目下的Debug目录运行服务端 | |||||
| 4.进入JT808.DotNetty.SimpleClient项目下的Debug目录运行客户端 | |||||
| 如图所示： | |||||
|  | |||||