smallchi / jt808gateway Goto Github PK

JT/T808 Gateway,JT808 Gateway, GB808 Gateway(support 2011, 2013, 2019 version) JT/T808网关、JT808网关、GB808网关(支持2011、2013、2019版本)

License: MIT License

C# 97.42% Batchfile 0.31% HTML 2.22% Dockerfile 0.05%

jt808 gb808 jt808-dotnetty gps-gateway jt808-gateway dotnetcore csharp jt808-pipeline net6 808

jt808gateway's Introduction

JT808Gateway

支持TCP/UDP通用消息业务处理

集成接口功能

接口名称	接口说明	使用场景
IJT808SessionProducer	会话通知（在线/离线）数据生产接口	有些超长待机的设备，不会实时保持连接，那么通过平台下发的命令是无法到达的，这时候就需要设备一上线，就即时通知服务去处理，然后在即时的下发消息到设备。
IJT808SessionConsumer	会话通知（在线/离线）数据消费接口	-
IJT808MsgProducer	数据生产接口	网关将接收到的数据发送到队列
IJT808MsgConsumer	数据消费接口	将数据进行对应的消息业务处理(例：设备流量统计、第三方平台数据转发、消息日志等)
IJT808MsgReplyProducer	应答数据生产接口	将生产的数据解析为对应的消息Id应答发送到队列
IJT808MsgReplyConsumer	应答数据消费接口	将接收到的应答数据下发给设备
IJT808MsgReplyLoggingProducer	网关应答数据日志生产接口	将网关能解析到直接能下发的数据发送到队列
IJT808MsgReplyLoggingConsumer	网关应答数据日志消费接口	将网关能解析到直接能下发的数据发送到日志系统

使用物联网卡通过udp下发指令时，存储的那个socket地址端口，有效期非常短,不速度快点下发，那个socket地址端口就可能映射到别的对应卡去了,所以此处采用跟随设备消息下发指令。

基于WebApi的消息业务处理程序

通过继承JT808.Gateway.Handlers.JT808MsgIdDefaultWebApiHandler去实现自定义的WebApi接口服务。

接口文档

基于Pipeline

Pipeline分为两种方式使用，一种是使用队列的方式，一种是网关集成的方式。

使用方式	特性	备注
使用队列	网关不需要重启，相当于透传数据，设备上来的数据直接入队列，通过服务去处理消息。	设备多的可以这样搞，这样关注点在业务上面。
使用网关集成	网关需要根据消息业务的变化去处理，也就意味着更改业务，需要重启网关，但是上手简单。	设备少的，开发能力弱的，允许设备丢点数据的。

Pipeline的NuGet安装

Package Name	Version	Preview Version	Downloads
Install-Package JT808.Gateway.Abstractions
Install-Package JT808.Gateway
Install-Package JT808.Gateway.WebApiClientTool
Install-Package JT808.Gateway.Client
Install-Package JT808.Gateway.Kafka

举个栗子

Pipeline

使用网关集成方式

1.打开/simples/JT808.Simples.sln项目进行还原编译生成

2.进入JT808.Gateway.SimpleServer项目下的Debug目录运行服务端

3.进入JT808.Gateway.SimpleClient项目下的Debug目录运行客户端

如图所示：

使用队列方式

1.打开/simples/JT808.Simples.sln项目进行还原编译生成

2.JT808.Gateway.SimpleQueueServer项目下的Debug目录运行服务端

3.JT808.Gateway.SimpleQueueService项目下的Debug目录运行消息处理服务

4.JT808.Gateway.SimpleQueueNotification项目下的Debug目录运行WebSocket服务从浏览器中打开localhost:5000查看数据

5.进入JT808.Gateway.SimpleClient项目下的Debug目录运行客户端

注意：需要安装kafka和zookeeper

如图所示：

Docker

此处以vscode为例，使用vscode打开当前文件夹

打包镜像

当前仅打包simples/JT808.Gateway.SimpleServer，可根据需求自行更改

按下F1按键
选择运行任务
选择打包示例网关镜像

运行容器

运行docker compose up

使用tcp工具或本项目中的示例项目测试本地808端口，

常见问题

多协议兼容实现思路点我查看

单端口兼容多协议虽然可以实现，但是还是不建议这么做，建议最好是用端口分开，避免不必要的麻烦

jt808gateway's People

Contributors

Stargazers

Watchers

Forkers

lulzzz ewsq gisdevelope nealgao lwp001 stephen-net maxxuxu wgms jackbestion achainchina max629 scorpian johnnyr1985 huaqiuming beifenku lalahome cimyong haolemawo huangweiboy luswei liblack ymd1223 ryansix leegkon aynstan sinapaul hlj671 lwqwag awei4home xdawenxi newwangshaofeng 491134648 jjg0519 lxking 19317362 leizhen waterliu99 waleswood liujiaoyoyo syrjgc11006 liuguiyou jz-zhou xiangbin72 sunw31 yingxiongtang leslietoo endlessc aynsten flydarkmiao yan2oo7 327 aivp mingkof coldily cartoecho jixuan2012 dengg88 hoku850 270sun knifecaojia smthhy lishewen qinqoushui chenbridge levphon cooperwj frunck8206 asdlei99 d8kzdzt ykgong wqgalex1 nop404 doraemon999 kimizhao amos-li poi2002 heibaifu wchuang20 horsewww zhaog918 metsystem jackyzcq jxmlegend ferren zhengjieyuan xhyangxianjun nirdino zhanzi hongweichang caijt ljz51 yunnet csuffyy lustfairy piwenjun zzyk chinesepartners spinach720 mainh xueshaoyu

jt808gateway's Issues

大神，这个包在源码中没找到，JT808.DotNetty.Transmit

大神，JT808.DotNetty.Transmit 这个不开源吗，我在源码中没找到。

通过WebApi接口UnificationSend向设备发送消息后，拿不到设备返回的消息

Q：通过WebApi接口UnificationSend向设备发送消息后，返回值只指明了是否发送成功，怎么取回设备返回的消息呢？比如发送0x8801后，设备返回0x0805,客户端怎么能拿到这个0x0805消息呢？

StatusFlag 哪个状态是点火哪个是熄火

我看了StatusFlag 基本都是0-3，提示是参考 JT808.Protocol.Enums.JT808Status ，
但是JT808Status的状态数据有点对不上啊？

是在JT808MessageHandlerImpl 接收消息时取到的数据。

GPS 设备超过2台，Channel 会频繁断开，倒置GPS设备重新注册、鉴权.

你好作者，我用了你部分代码监听GPS设备（DotNetty TCP协议）,一台设备接入的时候正常接收信息，但是当2台以上GPS 设备通讯的时候就会出现DotNetty 主动断开Channel 的情况，这时候GPS 设备又会重新连接（重新注册、鉴权）。这种情况会频繁出现。
我通过日志看到是先走了 CloseAsync函数（您在注释中说是 server端主动断开）。想请您看看我的代码帮我分析一下问题（有偿）。
WX号：15141173250. 希望得到你的帮助。

出现异常后无法继续接收并处理下个JT808包

若在接收JT808包中，有一个是非JT808包，会导致异常后，无法继续接收后面正常的JT808包。经查错误代码如下：
JT808TcpServer.cs(207行)
//if (beginMark != JT808Package.BeginFlag) throw new ArgumentException("Not JT808 Packages." + "[" + beginMark.ToString() + "]");
if (beginMark != JT808Package.BeginFlag)
{
totalConsumed = seqReader.Length;
seqReader.Advance(seqReader.Length);
}

另外，若MessageHandler处理出现异常也会出现无法继续接收下个JT808包的情况。目前，我是在MessageHandlertry-catch所有异常，不再向上抛。

能否增加设备自定义协议处理方式？

对于某些GPS设备发送的非808协议数据用该网关怎么处理呢？网关可以改造么，谢谢

HTML5中使用websocket怎么使用此网关进行数据同步

1、gps数据通过此网关处理后，怎么通过websocket将接收到的GPS位置数据广播到所有html5页面中，h5中通过websocket获取位置数据后立刻更新位置。
2、此网关服务实例怎么扩展自定义接收到的消息呢？不是标准的808协议

core3.0下可以完整运行吗？

作者你好！看了你的项目觉得做得很好，可以联系吗？

IJT808MsgConsumer等接口OnMessage的元组参数问题

不太明白这些接口里面为什么使用元组作为参数而不是强类型，目前遇到一些麻烦。在扩展RabbitMQ作为中间件时，想统一管理同进程中的订阅及分发调用，如果是强类型可以用泛型处理各个接口间不同的参数，但是目前您源码采用的是元组参数，动态调用不好处理，您设计时使用元组参数有什么特殊的原因吗？
调用的部分：

几个订阅的接口



JT808MsgConsumer的RabbitMQ实现部分

如何在编解码中添加自定义的编解码

大神，基于JT808DotNetty做主动安全的协议，里面的附件上传是码流方式，和信令是一个通道。原本想做一个拓展库，发现 AddJT808TcpNettyHost 这个方法里面用到类很多是internal。我想做的是在解码中再插入一个分隔符“0x30 0x31 0x63 0x64”，现在看来只有修改源码了吗?

接收808转发数据问题

大佬，接收平台方转发数据这里貌似有坑，目前有两种情况：1、连接正常情况下，对方IP端口不变，断开连接后调用item.ReceiveTimeout.Cancel()无效，超过10分钟的会话仍然存在，必须调用SessionManager.RemoveByTerminalPhoneNo方法才能移除该会话，不调用则必须重启服务，否则无法再次上线，重启服务之后也不能立即上线，需要最长10分钟才能上线。
2、对方IP不变端口一直在变，会话中存在多条该终端号记录，其中包含相同的IP端口数据，也有不同的端口。每台设备平均每10秒钟打印一条JT808SessionOnline日志。

JT808SessionManager.TerminalPhoneNoSessions数量为1500，JT808SessionManager.Sessions数量超过10万，不重启服务会话数量会一直增长，内存也随之不断增长。

有使用简单介绍说明么？

Pipeline版本怎么集成LengthFieldBasedFrameDecoder协议？

Pipeline版本怎么集成LengthFieldBasedFrameDecoder协议，调试代码的时候发现不是正确包的时候，抛出了相关异常，下次再发数据包时就进入了Write了，然后就断开了连接，是为什么呢？

运行找不到appsettings.json文件

有单独控制网关的start,stop功能吗

对于启动已配置好的端口的监听服务, 有单独控制器启动,暂停,结束的功能吗?
比如想集成到windows服务中运行, 在服务启动停止的时候对服务进行控制

Docker 下报错，ubuntu 下运行也是这个错，我弄到 CentOS 没问题，但是在CentOS 下 Docker 就报错

dbug: Microsoft.Extensions.Hosting.Internal.Host[1]
Hosting starting
Unhandled exception. System.Net.Sockets.SocketException (13): Permission denied
at System.Net.Sockets.Socket.UpdateStatusAfterSocketErrorAndThrowException(SocketError error, Boolean disconnectOnFailure, String callerName)
at System.Net.Sockets.Socket.UpdateStatusAfterSocketOptionErrorAndThrowException(SocketError error, String callerName)
at JT808.Gateway.JT808TcpServer.InitServer() in /_/src/JT808.Gateway/JT808TcpServer.cs:line 82
at JT808.Gateway.JT808TcpServer..ctor(IOptionsMonitor1 configurationMonitor, IJT808MsgProducer msgProducer, IJT808MsgReplyLoggingProducer msgReplyLoggingProducer, JT808MessageHandler messageHandler, IJT808Config jT808Config, ILoggerFactory loggerFactory, JT808SessionManager jT808SessionManager, JT808BlacklistManager jT808BlacklistManager) in /_/src/JT808.Gateway/JT808TcpServer.cs:line 75 at System.RuntimeMethodHandle.InvokeMethod(Object target, Void** arguments, Signature sig, Boolean isConstructor) at System.Reflection.MethodBaseInvoker.InvokeWithManyArgs(Object obj, BindingFlags invokeAttr, Binder binder, Object[] parameters, CultureInfo culture) at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteVisitor2.VisitCallSiteMain(ServiceCallSite callSite, TArgument argument)
at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteRuntimeResolver.VisitRootCache(ServiceCallSite callSite, RuntimeResolverContext context)
at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteVisitor2.VisitCallSite(ServiceCallSite callSite, TArgument argument) at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteRuntimeResolver.VisitIEnumerable(IEnumerableCallSite enumerableCallSite, RuntimeResolverContext context) at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteVisitor2.VisitCallSiteMain(ServiceCallSite callSite, TArgument argument)
at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteRuntimeResolver.VisitRootCache(ServiceCallSite callSite, RuntimeResolverContext context)
at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteVisitor2.VisitCallSite(ServiceCallSite callSite, TArgument argument) at Microsoft.Extensions.DependencyInjection.ServiceLookup.CallSiteRuntimeResolver.Resolve(ServiceCallSite callSite, ServiceProviderEngineScope scope) at Microsoft.Extensions.DependencyInjection.ServiceProvider.CreateServiceAccessor(ServiceIdentifier serviceIdentifier) at System.Collections.Concurrent.ConcurrentDictionary2.GetOrAdd(TKey key, Func`2 valueFactory)
at Microsoft.Extensions.DependencyInjection.ServiceProvider.GetService(ServiceIdentifier serviceIdentifier, ServiceProviderEngineScope serviceProviderEngineScope)
at Microsoft.Extensions.DependencyInjection.ServiceProvider.GetService(Type serviceType)
at Microsoft.Extensions.DependencyInjection.ServiceProviderServiceExtensions.GetRequiredService(IServiceProvider provider, Type serviceType)
at Microsoft.Extensions.DependencyInjection.ServiceProviderServiceExtensions.GetRequiredService[T](IServiceProvider provider)
at Microsoft.Extensions.Hosting.Internal.Host.StartAsync(CancellationToken cancellationToken)
at Microsoft.Extensions.Hosting.HostingAbstractionsHostExtensions.RunAsync(IHost host, CancellationToken token)
at Microsoft.Extensions.Hosting.HostingAbstractionsHostExtensions.RunAsync(IHost host, CancellationToken token)
at Microsoft.Extensions.Hosting.HostingAbstractionsHostExtensions.Run(IHost host)
at Program.

$(String[] args) in /Users/leida/MyCode/PandaServer/PandaServer.JT808Server/Program.cs:line 37

自定义了 5808 5000 端口都EXPOSE 了

关于平台主动给设备下发指令

请问如何使平台主动给设备下发指令？比如主动下发终端属性查询指令

Pipeline与DotNetty版本性能方面有差异吗？

Pipeline DotNetty性能方面有差异吗？

SocketOptionName.NoDelay 设置 True 的时候在Docker 运行会报错

Unhandled exception. System.Net.Sockets.SocketException (13): Permission denied

windows环境下QueueServerHosting占用内存过大

windows环境下使用kafka队列接入1200多台终端，QueueServerHosting占用内存会越来越大，大概每秒0.1M的速度增长，直至占用内存100%，始终找不到是哪出问题了

压测发现tcp并发到1200时会出现延时了(网关添加kafka)

只添加了消息发送到kafka而已，其他没有任何操作

Run in Ubuntu 18.04 arm64 error

Dears，

Great project，now I can build this project on Ubuntu arm64 platform, but encounter below error when I run the JT808.Gateway.SimpleServer, could you give me some help or hints to fix it, sorry for this naive problem.

bin/Debug/netcoreapp3.1/JT808.Gateway.SimpleServer
dbug: Microsoft.Extensions.Hosting.Internal.Host[1]
Hosting starting
info: JT808TcpServer[0]
JT808 TCP Server start at 0.0.0.0:808.
info: JT808TcpReceiveTimeout[0]
[Check Receive Timeout]
info: JT808TcpReceiveTimeout[0]
[Session Online Count]:0
info: JT808UdpServer[0]
JT808 Udp Server start at 0.0.0.0:808.
info: JT808UdpReceiveTimeout[0]
[Check Receive Timeout]
info: JT808UdpReceiveTimeout[0]
[Session Online Count]:0
fail: JT808TransmitService[0]
初始化配置链接远程服务端all_127.0.0.1:20000,链接异常：System.Net.Sockets.SocketException (111): Connection refused
at System.Net.Sockets.Socket.BeginConnectEx(EndPoint remoteEP, Boolean flowContext, AsyncCallback callback, Object state)
at System.Net.Sockets.Socket.UnsafeBeginConnect(EndPoint remoteEP, AsyncCallback callback, Object state, Boolean flowContext)
at System.Net.Sockets.Socket.BeginConnect(EndPoint remoteEP, AsyncCallback callback, Object state)
at System.Net.Sockets.Socket.ConnectAsync(EndPoint remoteEP)
at JT808.Gateway.Transmit.JT808TransmitService.InitRemoteServsers()
Unhandled exception. System.IO.IOException: Error loading native library "/root/dotnet/JT808Gateway/simples/JT808.Gateway.SimpleServer/bin/Debug/netcoreapp3.1/runtimes/linux/native/libgrpc_csharp_ext.x64.so".
at Grpc.Core.Internal.UnmanagedLibrary..ctor(String[] libraryPathAlternatives)
at Grpc.Core.Internal.NativeExtension.LoadUnmanagedLibrary()
at Grpc.Core.Internal.NativeExtension.LoadNativeMethods()
at Grpc.Core.Internal.NativeExtension..ctor()
at Grpc.Core.Internal.NativeExtension.Get()
at Grpc.Core.Internal.NativeMethods.Get()
at Grpc.Core.GrpcEnvironment.GrpcNativeInit()
at Grpc.Core.GrpcEnvironment..ctor()
at Grpc.Core.GrpcEnvironment.AddRef()
at Grpc.Core.Server..ctor(IEnumerable`1 options)
at Grpc.Core.Server..ctor()
at JT808.Gateway.JT808GrpcServer.StartAsync(CancellationToken cancellationToken)
at Microsoft.Extensions.Hosting.Internal.Host.StartAsync(CancellationToken cancellationToken)
at Microsoft.Extensions.Hosting.HostingAbstractionsHostExtensions.RunAsync(IHost host, CancellationToken token)
at Microsoft.Extensions.Hosting.HostingAbstractionsHostExtensions.RunAsync(IHost host, CancellationToken token)
at JT808.Gateway.SimpleServer.Program.Main(String[] args) in /root/dotnet/JT808Gateway/simples/JT808.Gateway.SimpleServer/Program.cs:line 61
at JT808.Gateway.SimpleServer.Program.

(String[] args)
Aborted (core dumped)