消息转发

pom.xml

@@ -21,6 +21,12 @@
             <version>1.18.30</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.5.1</version>
+        </dependency>
+
         <dependency>
             <groupId>cn.hutool</groupId>
             <artifactId>hutool-all</artifactId>
@@ -38,6 +44,12 @@
             <version>1.2.75</version> <!-- 请检查并使用最新版本 -->
         </dependency>
 
+        <!-- MySQL连接驱动 -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+
 
         <dependency>
             <groupId>io.netty</groupId>

src/main/java/com/lutao/tcp/server/domain/entity/RecSendLog.java

@@ -0,0 +1,28 @@
+package com.lutao.tcp.server.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@TableName("rec_send_log")
+@Data
+public class RecSendLog implements Serializable {
+    private static final long serialVersionUID = 8546099831718789719L;
+
+    private String id;
+
+    private String rec;
+
+    private String send;
+
+    private LocalDateTime createTime;
+
+    private LocalDateTime updateTime;
+
+    private String logType;
+}

src/main/java/com/lutao/tcp/server/mapper/RecSendLogMapper.java

@@ -0,0 +1,9 @@
+package com.lutao.tcp.server.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.lutao.tcp.server.domain.entity.RecSendLog;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface RecSendLogMapper extends BaseMapper<RecSendLog> {
+}

src/main/java/com/lutao/tcp/server/service/RecSendLogService.java

@@ -0,0 +1,8 @@
+package com.lutao.tcp.server.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.lutao.tcp.server.domain.entity.RecSendLog;
+
+
+public interface RecSendLogService extends IService<RecSendLog> {
+}

src/main/java/com/lutao/tcp/server/service/impl/RecSendLogServiceImpl.java

@@ -0,0 +1,11 @@
+package com.lutao.tcp.server.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.lutao.tcp.server.domain.entity.RecSendLog;
+import com.lutao.tcp.server.mapper.RecSendLogMapper;
+import com.lutao.tcp.server.service.RecSendLogService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class RecSendLogServiceImpl extends ServiceImpl<RecSendLogMapper, RecSendLog> implements RecSendLogService {
+}

src/main/java/com/lutao/tcp/server/tcptest/BootNettyChannelInboundHandlerAdapter.java

@@ -1,14 +1,19 @@
 package com.lutao.tcp.server.tcptest;
 
+import cn.hutool.core.lang.UUID;
+import cn.hutool.http.HttpUtil;
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.lutao.tcp.server.domain.entity.RecSendLog;
+import com.lutao.tcp.server.service.RecSendLogService;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
 import java.io.IOException;
 import java.net.InetSocketAddress;
 import java.time.Instant;
@@ -21,6 +26,10 @@ import java.time.format.DateTimeFormatter;
 public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandlerAdapter {
 
     private static BootNettyChannelInboundHandlerAdapter nettyServerHandler;
+
+    @Resource
+    private RecSendLogService recSendLogService;
+
     @PostConstruct
     public void init() {
         nettyServerHandler = this;
@@ -44,6 +53,30 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
          if (JSONUtil.isJson(json)){
              JSONObject jsonObject = JSON.parseObject(json);
              log.info("======加载客户端报文======【" + ctx.channel().id() + "】" + " :" + jsonObject.toJSONString());
+             RecSendLog recSendLog = new RecSendLog();
+             String uuid = UUID.randomUUID().toString();
+             recSendLog.setRec(jsonObject.toJSONString());
+             recSendLog.setLogType("大范围速报报警");
+             recSendLog.setCreateTime(LocalDateTime.now());
+             recSendLog.setUpdateTime(LocalDateTime.now());
+             recSendLog.setId(uuid);
+             recSendLogService.save(recSendLog);
+             //http://115.85.203.230:45002/utility/scopeScan/warnData/submit  转发
+
+             String body = HttpUtil.createPost("http://115.85.203.230:45002/utility/scopeScan/warnData/submit")
+                     .body(jsonObject.toJSONString())
+                     .execute().body();
+             Integer code = JSONUtil.parseObj(body).getInt("code");
+             log.info("======转发状态码======【" + ctx.channel().id() + "】" + " :" + code);
+             if (code == 200){
+                 log.info("======转发成功======【" + ctx.channel().id() + "】" + " :" + jsonObject.toJSONString());
+                 recSendLog.setSend(jsonObject.toJSONString());
+                 recSendLogService.updateById(recSendLog);
+             }else{
+                 log.info("======转发失败======【" + ctx.channel().id() + "】" + " :" + jsonObject.toJSONString());
+             }
+
+
          }else{
              log.info("======无法转换为json======【" + ctx.channel().id() + "】" + " :" + json);
          }
@@ -53,7 +86,6 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
             e.printStackTrace();
         }finally {
 
-
         }
     }
 

src/main/resources/application.yml

@@ -1,2 +1,9 @@
 server:
-  port: 8081
+  port: 8081
+
+spring:
+  datasource:
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://172.29.21.84:3306/cloud_log?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&rewriteBatchedStatements=true
+    username: root
+    password: ozyebgwec@*wegh

src/main/resources/mapper/RecSendLogMapper.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.lutao.tcp.server.mapper.RecSendLogMapper">
+</mapper>