From ea4cfdd042b89e2b545fc0a54442538c76781857 Mon Sep 17 00:00:00 2001 From: walker Date: Mon, 5 Jun 2023 18:14:57 +0800 Subject: [PATCH] =?UTF-8?q?OCC=E6=B6=88=E6=81=AF=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E5=AF=B9=E8=B1=A1=E6=8A=BD=E8=B1=A1=E5=88=9D=E7=89=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 6 +- .../xiannccda/ats/message/FrameHandler.java | 34 ++++++++++ .../xiannccda/ats/message/FrameSchema.java | 27 ++++++++ .../xiannccda/ats/message/MessageData.java | 18 ++++++ .../xiannccda/ats/message/MessageId.java | 25 ++++++++ .../ats/message/OccMessageManage.java | 25 ++++++++ .../ats/message/TcpClientConnection.java | 60 ++++++++++++++++++ .../ats/message/XianOccMessagingClient.java | 62 +++++++++++++++++++ .../ats/message/line3/HeartBeatMsg.java | 7 +++ 9 files changed, 263 insertions(+), 1 deletion(-) create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/FrameHandler.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/FrameSchema.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/MessageData.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/MessageId.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/OccMessageManage.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/TcpClientConnection.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/XianOccMessagingClient.java create mode 100644 src/main/java/club/joylink/xiannccda/ats/message/line3/HeartBeatMsg.java diff --git a/pom.xml b/pom.xml index 0a5df61..d1e35eb 100644 --- a/pom.xml +++ b/pom.xml @@ -7,7 +7,6 @@ org.springframework.boot spring-boot-starter-parent 3.1.0 - club.joylink @@ -43,6 +42,11 @@ spring-boot-starter-websocket + + io.netty + netty-all + + com.alibaba.fastjson2 fastjson2 diff --git a/src/main/java/club/joylink/xiannccda/ats/message/FrameHandler.java b/src/main/java/club/joylink/xiannccda/ats/message/FrameHandler.java new file mode 100644 index 0000000..479ba3d --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/FrameHandler.java @@ -0,0 +1,34 @@ +package club.joylink.xiannccda.ats.message; + +import io.netty.buffer.ByteBuf; +import io.netty.channel.ChannelHandlerContext; +import io.netty.handler.codec.ByteToMessageCodec; +import java.util.List; +import lombok.extern.slf4j.Slf4j; + +@Slf4j +public class FrameHandler extends ByteToMessageCodec { + + final XianOccMessagingClient client; + + public FrameHandler(XianOccMessagingClient client) { + this.client = client; + } + + @Override + public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { + super.channelRead(ctx, msg); + } + + @Override + protected void encode(ChannelHandlerContext channelHandlerContext, FrameSchema frameSchema, + ByteBuf byteBuf) throws Exception { + log.info("发送消息到OCC"); + } + + @Override + protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, + List list) throws Exception { + log.info("收到OCC消息"); + } +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/FrameSchema.java b/src/main/java/club/joylink/xiannccda/ats/message/FrameSchema.java new file mode 100644 index 0000000..c22beed --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/FrameSchema.java @@ -0,0 +1,27 @@ +package club.joylink.xiannccda.ats.message; + +import io.netty.buffer.ByteBuf; +import java.util.List; + +public class FrameSchema { + + /** + * (System ID)占1字节，系统中每台计算机均有唯一的System ID, 此处表示发送方的System ID，为0xff。 + */ + short systemId; + /** + * (Total Length) 占2字节，表示每个信息帧中消息的总长度+1字节（Multi-flag）。 最长为1025字节。如果数据长度大于1024字节，剩余的在紧接着的几帧数据中发送。 + */ + int totalLength; + /** + * (Multi-flag)为帧标识位，占1字节，值为0或者1，分别表示下面的意思： 1：表示在这帧数据中，一个完整的消息没有发送结束，有后续帧； + * 0：表示在这帧数据中，消息完整发送，没有后续帧。同样，几个消息可合并成一帧数据发送 + */ + short multiFlag; + /** + * 消息内容，最长为1024字节。它可由一个或多个消息组成，也可以是一个消息的一部分。每个消息由消息标识和消息数据组成 + */ + ByteBuf packageData; + + List messages; +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/MessageData.java b/src/main/java/club/joylink/xiannccda/ats/message/MessageData.java new file mode 100644 index 0000000..edfea92 --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/MessageData.java @@ -0,0 +1,18 @@ +package club.joylink.xiannccda.ats.message; + +public class MessageData { + + /** + * 消息的长度: 时间戳（Time）长度+ 版本号（Version）长度+消息ID（message _id）长度（2字节）+ 消息内容（content）长度。 + */ + int length; + /** + * （4字节，时间戳），为UTC时间 + */ + long time; + /** + * 用来区分协议的版本，本版指定为01H + */ + int version; + MessageId msgId; +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/MessageId.java b/src/main/java/club/joylink/xiannccda/ats/message/MessageId.java new file mode 100644 index 0000000..fb8bacb --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/MessageId.java @@ -0,0 +1,25 @@ +package club.joylink.xiannccda.ats.message; + +public enum MessageId { + UNKNOWN(0x0000), + /** + * 心跳 + */ + MESSAGE_POLLING(0x0001), + ; + + int val; + + MessageId(int val) { + this.val = val; + } + + public static MessageId of(int val) { + for (MessageId messageId : MessageId.values()) { + if (messageId.val == val) { + return messageId; + } + } + return MessageId.UNKNOWN; + } +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/OccMessageManage.java b/src/main/java/club/joylink/xiannccda/ats/message/OccMessageManage.java new file mode 100644 index 0000000..fe7cf7f --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/OccMessageManage.java @@ -0,0 +1,25 @@ +package club.joylink.xiannccda.ats.message; + +import java.util.HashMap; +import java.util.Map; +import org.springframework.boot.ApplicationArguments; +import org.springframework.boot.ApplicationRunner; +import org.springframework.stereotype.Component; + +/** + * OCC客户端管理 + */ +@Component +public class OccMessageManage implements ApplicationRunner { + + Map clientMap = new HashMap<>(); + + public void registerClient(XianOccMessagingClient client) { + clientMap.put(client.lineId, client); + } + + @Override + public void run(ApplicationArguments args) throws Exception { + // 读取数据配置，创建客户端 + } +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/TcpClientConnection.java b/src/main/java/club/joylink/xiannccda/ats/message/TcpClientConnection.java new file mode 100644 index 0000000..a575b63 --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/TcpClientConnection.java @@ -0,0 +1,60 @@ +package club.joylink.xiannccda.ats.message; + +import io.netty.bootstrap.Bootstrap; +import io.netty.channel.Channel; +import io.netty.channel.ChannelFuture; +import io.netty.channel.ChannelInitializer; +import io.netty.channel.EventLoopGroup; +import io.netty.channel.nio.NioEventLoopGroup; +import io.netty.channel.socket.nio.NioSocketChannel; +import lombok.extern.slf4j.Slf4j; + +@Slf4j +public class TcpClientConnection { + + boolean autoReconnect = true; + + XianOccMessagingClient client; + final String host; + final int port; + + volatile boolean connected; + + final EventLoopGroup group; + final Bootstrap bootstrap; + + public TcpClientConnection(XianOccMessagingClient client, String host, int port) { + this.client = client; + this.host = host; + this.port = port; + this.group = new NioEventLoopGroup(); + this.bootstrap = new Bootstrap(); + bootstrap.group(group) + .channel(NioSocketChannel.class) + .handler(new ChannelInitializer<>() { + @Override + protected void initChannel(Channel ch) { + ch.pipeline().addLast(new FrameHandler(client)); + } + }); + } + + public void connect() { + try { + ChannelFuture channelFuture = bootstrap.connect(this.host, this.port).addListener(future1 -> { + if (future1.isSuccess()) { + log.info("连接到OCC服务: host={}, port={}", this.host, this.port); + } else { + log.info("连接OCC失败，尝试重连"); + connect(); + } + }); + channelFuture.channel().closeFuture().sync(); + } catch (Exception e) { + log.error("与OCC服务连接异常", e); + } finally { + log.info("关闭eventLoop"); + group.shutdownGracefully(); + } + } +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/XianOccMessagingClient.java b/src/main/java/club/joylink/xiannccda/ats/message/XianOccMessagingClient.java new file mode 100644 index 0000000..4110c34 --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/XianOccMessagingClient.java @@ -0,0 +1,62 @@ +package club.joylink.xiannccda.ats.message; + +import lombok.extern.slf4j.Slf4j; + +@Slf4j +public class XianOccMessagingClient { + + final int realTimePortBase = 2600; + final int nonRealTimePortBase = 2700; + /** + * 线路号 实时信息的侦听端口号为2600+line_id，非实时信息的侦听端口号为2700+line_id。 + * (如对于地铁1号线来说，实时信息的侦听端口号为2601，非实时信息的侦听端口号为2701) + */ + final int lineId; + final String host; + /** + * 实时端口号 + */ + final int realTimePort; + /** + * 非实时端口号 + */ + final int nonRealTimePort; + /** + * 版本号 + */ + final int Version = 0x01; + /** + * 心跳发送间隔 + */ + final int heartbeatInterval = 10; + /** + * 心跳超时 + */ + final int heartbeatTimeout = 15; + + final TcpClientConnection connection; + + public XianOccMessagingClient(int lineId, String host) { + this.host = host; + this.lineId = lineId; + this.realTimePort = realTimePortBase + lineId; + this.nonRealTimePort = nonRealTimePortBase + lineId; + // 创建实时消息连接 + this.connection = new TcpClientConnection(this, host, this.realTimePort); + } + + /** + * 连接实时消息服务 + */ + public void rtMessageConnect() { + + } + + /** + * 连接非实时消息服务 + */ + public void nrtMessageConnect() { + + } + +} diff --git a/src/main/java/club/joylink/xiannccda/ats/message/line3/HeartBeatMsg.java b/src/main/java/club/joylink/xiannccda/ats/message/line3/HeartBeatMsg.java new file mode 100644 index 0000000..255e8cd --- /dev/null +++ b/src/main/java/club/joylink/xiannccda/ats/message/line3/HeartBeatMsg.java @@ -0,0 +1,7 @@ +package club.joylink.xiannccda.ats.message.line3; + +import club.joylink.xiannccda.ats.message.MessageData; + +public class HeartBeatMsg extends MessageData { + +}