【wu-lazy-cloud-network】Java自动化内网穿透架构整理

项目介绍

wu-lazy-cloud-network 是一款基于（wu-framework-parent）孵化出的项目，内部使用Lazy ORM操作数据库，主要功能是网络穿透，对于没有公网IP的服务进行公网IP映射
使用环境JDK17 Spring Boot 3.0.2

版本更新

1.2.2-JDK17-SNAPSHOT
【fix】修正流量计算保存两位小数
架构图

在这里插入图片描述

实现原理
服务端创建socket服务端绑定本地端口（用于客户端连接）
package wu.framework.lazy.cloud.heartbeat.server.netty.socket;import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import wu.framework.lazy.cloud.heartbeat.server.netty.filter.NettyServerFilter;public class NettyOnCloudNettyServerSocket {private final EventLoopGroup bossGroup = new NioEventLoopGroup();private final EventLoopGroup workerGroup = new NioEventLoopGroup();private final NettyServerFilter nettyServerFilter;// 通道业务处理private ChannelFuture channelFuture;public NettyOnCloudNettyServerSocket(NettyServerFilter nettyServerFilter) {this.nettyServerFilter = nettyServerFilter;}/*** 启动服务端** @throws Exception*/public void startServer(int serverPort) throws Exception {try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)// 给服务端channel设置属性.option(ChannelOption.SO_BACKLOG, 128).childOption(ChannelOption.SO_KEEPALIVE, true).childHandler(nettyServerFilter);channelFuture = b.bind(serverPort).sync();channelFuture.addListener((ChannelFutureListener) channelFuture -> {// 服务器已启动});channelFuture.channel().closeFuture().sync();} finally {shutdown();// 服务器已关闭}}public void shutdown() {if (channelFuture != null) {channelFuture.channel().close().syncUninterruptibly();}if ((bossGroup != null) && (!bossGroup.isShutdown())) {bossGroup.shutdownGracefully();}if ((workerGroup != null) && (!workerGroup.isShutdown())) {workerGroup.shutdownGracefully();}}
}
客户端通过class NettyClientSocket 连接服务端
package wu.framework.lazy.cloud.heartbeat.client.netty.socket;import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import wu.framework.lazy.cloud.heartbeat.client.application.ClientNettyConfigApplication;
import wu.framework.lazy.cloud.heartbeat.client.netty.filter.NettyClientFilter;
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
import wu.framework.lazy.cloud.heartbeat.common.advanced.HandleChannelTypeAdvanced;
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;import java.util.List;
import java.util.concurrent.TimeUnit;/*** 客户端连接服务端*/
@Slf4j
public class NettyClientSocket {private static final EventLoopGroup eventLoopGroup = new NioEventLoopGroup();/*** 服务端host*/private final String inetHost;/*** 服务端端口*/private final int inetPort;/*** 当前客户端id*/@Getterprivate final String clientId;/*** nacos配置信息处理应用*/@Getterprivate final ClientNettyConfigApplication clientNettyConfigApplication;private final List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList; // 处理服务端发送过来的数据类型public NettyClientSocket(String inetHost, int inetPort, String clientId, ClientNettyConfigApplication clientNettyConfigApplication, List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList) {this.inetHost = inetHost;this.inetPort = inetPort;this.clientId = clientId;this.clientNettyConfigApplication = clientNettyConfigApplication;this.handleChannelTypeAdvancedList = handleChannelTypeAdvancedList;}public void newConnect2Server() throws InterruptedException {newConnect2Server(inetHost, inetPort, clientId, clientNettyConfigApplication);}protected void newConnect2Server(String inetHost, int inetPort, String clientId, ClientNettyConfigApplication clientNettyConfigApplication) throws InterruptedException {Bootstrap bootstrap = new Bootstrap();bootstrap.group(eventLoopGroup).channel(NioSocketChannel.class).handler(new NettyClientFilter(new ChannelTypeAdapter(handleChannelTypeAdvancedList), this));log.info("连接服务端IP:{},连接服务端端口:{}", inetHost, inetPort);ChannelFuture future = bootstrap.connect(inetHost, inetPort);Channel channel = future.channel();log.info("使用的客户端ID:" + clientId);future.addListener((ChannelFutureListener) futureListener -> {if (futureListener.isSuccess()) {log.info("连接服务端成功");// 告诉服务端这条连接是client的连接NettyProxyMsg nettyMsg = new NettyProxyMsg();nettyMsg.setType(MessageType.REPORT_CLIENT_CONNECT_SUCCESS);nettyMsg.setClientId(clientId);nettyMsg.setData((clientId).getBytes());ChannelAttributeKeyUtils.buildClientId(channel, clientId);channel.writeAndFlush(nettyMsg);// 在线clientNettyConfigApplication.clientOnLine(clientId);} else {log.info("每隔2s重连....");// 离线clientNettyConfigApplication.clientOffLine(clientId);futureListener.channel().eventLoop().schedule(() -> {try {newConnect2Server(inetHost, inetPort, clientId, clientNettyConfigApplication);} catch (InterruptedException e) {e.printStackTrace();}}, 2, TimeUnit.SECONDS);}});}/*** 关闭连接*/public void shutdown() {if ((eventLoopGroup != null) && (!eventLoopGroup.isShutdown())) {eventLoopGroup.shutdownGracefully();}}}
通过客户端与服务端建立的连接进行访客端口绑定
上述连接会形成一个channel，我们称之为通道（本文中简单叫**心跳通道**）
第一步 页面GUI进行新增访客端口而后将访客端口与客户端绑定（如果客户端已经启动，使用页面客户端下线触发第二步）
第二步 客户端与访客端口绑定后使用**心跳通道** 发送客户端告诉客户端，你帮我绑定你本地真实端口
第三步 访客访问，访客通过访客端口访问数据，此时访客通道打开截取访客发送的数据，然后将数据发送给客户真实通道，数据返回后再返回给访客通道

功能

1.内网穿透
2.服务端自主下发数据到客户端
3.流量监控

项目结构

模块版本描述
wu-lazy-cloud-heartbeat-common1.2.2-JDK17-SNAPSHOT内网穿透公共模块（声明接口、枚举、常量、适配器、解析器）
wu-lazy-cloud-heartbeat-client1.2.2-JDK17-SNAPSHOT客户端（支持二次开发）
wu-lazy-cloud-heartbeat-server1.2.2-JDK17-SNAPSHOT服务端（支持二次开发）
wu-lazy-cloud-network-ui1.2.2-JDK17-SNAPSHOT服务端页面
wu-lazy-cloud-heartbeat-client-sample1.2.2-JDK17-SNAPSHOT客户端样例
wu-lazy-cloud-heartbeat-server-sample1.2.2-JDK17-SNAPSHOT服务端样例

使用技术

框架版本描述
spring-boot3.0.7springboot框架
wu-framework-web1.2.2-JDK17-SNAPSHOTweb容器
Lazy -ORM1.2.2-JDK17-SNAPSHOTORM
mysql-connector-j8.0.33mysql驱动
wu-authorization-server-platform-starter1.2.2-JDK17-SNAPSHOT用户授权体系

使用环境

IDEA
Mac、Windows
JAVA >=13
MAVEN

启动

docker启动docker run  -d -it -p 18080:18080 --name wu-lazy-cloud-heartbeat-server registry.cn-hangzhou.aliyuncs.com/wu-lazy/wu-lazy-cloud-heartbeat-server:1.2.2-JDK17-SNAPSHOThttp://127.0.0.1:18080/swagger-ui/index.html源码启动
页面操作

启动项目后打开服务端界面
在这里插入图片描述

默认账号密码：admin/admin
在这里插入图片描述

初始化项目
在这里插入图片描述

添加角色
在这里插入图片描述

为用户授权
在这里插入图片描述

刷新页面
在这里插入图片描述

客户端管理（客户端会自动注册）
在这里插入图片描述

网络映射管理（修改后者新增需要映射的客户端）
在这里插入图片描述

访客端口池管理（服务器端需要开放的端口）
在这里插入图片描述

流量管理（每个客户端使用的流量）
在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/264533.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【51单片机】红外遥控红外遥控电机调速（江科大）

【51单片机】红外遥控红外遥控电机调速（江科大）

1.红外遥控简介 红外遥控是利用红外光进行通信的设备,由红外LED将调制后的信号发出,由专用的红外接收头进行解调输出 通信方式:单工,异步 红外LED波长:940nm 通信协议标准:NEC标准 2.硬件电路 红外发送部分 IN高电平时&#xff0c;LED不亮&#xff0c;IN低电平时&…
阅读更多...
飞天使-linux操作的一些技巧与知识点7-devops

飞天使-linux操作的一些技巧与知识点7-devops

文章目录 简述devopsCICD 简述devops 让技术团队&#xff0c;运维&#xff0c;测试等团队实现一体式流程自动化 进阶版图 CICD 持续集成&#xff0c; 从编译&#xff0c;测试&#xff0c;发布的完成自动化流程 持续交付&#xff0c;包含持续集成&#xff0c;并且将项目部署…
阅读更多...
Redis集群搭建笔记

Redis集群搭建笔记

redis集群: 1.hash取余算法 2.一致性hash算法 3.哈希槽算法 以下使用哈希槽算法 Redis 3主3从搭建 新建6个Redis Docker容器实例 docker run -d --name redis-node-1 --net host --privilegedtrue -v /usr/local/develop/redis/share/redis-node-1:/data redis:6.0.8 --c…
阅读更多...
SQL 中如何实现多表关联查询？

SQL 中如何实现多表关联查询？

阅读本文之前请参阅----MySQL 数据库安装教程详解&#xff08;linux系统和windows系统&#xff09; 在SQL中&#xff0c;多表关联查询是通过使用JOIN操作来实现的&#xff0c;它允许你从两个或多个表中根据相关列的值来检索数据。以下是几种常见的JOIN类型&#xff1a; …
阅读更多...
MFC 多文档程序的基本编程

MFC 多文档程序的基本编程

下载了一个openGL mfc的多文档程序，以此来学习mfc多文档模式的编程； 1 基本编程 它每次新建一个文档，会在窗口绘制一个三角形、一个矩形；如果没有了图形刷新一下； 先看一下为什么每次打开新文档会绘制图形； 生成工程之后主要有5个类，比单文档程序多了一个子框架类； 可…
阅读更多...
width:100%和width:auto有啥区别

width:100%和width:auto有啥区别

项目中使用了with属性&#xff0c;突然好奇auto 和 100% 的区别&#xff0c;特地搜索实践总结了一下观点 一、 width属性介绍二、 代码带入三、 分析比较四、 总结 一、 width属性介绍 width 属性用于设置元素的宽度。width 默认设置内容区域的宽度&#xff0c;但如果 box-siz…
阅读更多...
计算机组成原理 — 存储器(2)

计算机组成原理 — 存储器(2)

高速缓冲存储器 大家好呀&#xff01;我是小笙&#xff0c;由于存储器这部分章节内容较多&#xff0c;我分成二部分进行总结&#xff0c;以下是第二部分&#xff0c;希望内容对你有所帮助&#xff01; 概述 目的&#xff1a;避免CPU空等现象 原理&#xff1a;程序访问的局部…
阅读更多...
【k8s资源调度-Deployment】

【k8s资源调度-Deployment】

1、标签和选择器 1.1 标签Label 配置文件&#xff1a;在各类资源的sepc.metadata.label 中进行配置通过kubectl 命令行创建修改标签&#xff0c;语法如下 创建临时label&#xff1a;kubectl label po <资源名称> apphello -n <命令空间&#xff08;可不加&#xff0…
阅读更多...
IO进程：信号灯集

IO进程：信号灯集

程序代码&#xff1a; sem.h: 1 #ifndef __SEM_H__2 #define __SEM_H__3 4 //创建信号灯集并初始化&#xff0c;semcount表示灯个数5 int open_sem(int semcount);6 7 //申请资源操作&#xff0c;semno表示灯的编号8 int P(int semid,int semno);9 10 //释放资源操作&#xff…
阅读更多...
uniapp播放mp4省流方案

uniapp播放mp4省流方案

背景&#xff1a; 因为项目要播放一个宣传和讲解视频&#xff0c;视频文件过大&#xff0c;同时还为了节省存储流量&#xff0c;想到了一个方案&#xff0c;用m3u8切片替代mp4。 m3u8&#xff1a;切片播放&#xff0c;可以理解为一个1G的视频文件&#xff0c;自行设置文…
阅读更多...
【前端素材】推荐优质后台管理系统Be admin平台模板（附源码）

【前端素材】推荐优质后台管理系统Be admin平台模板（附源码）

一、需求分析 后台管理系统&#xff08;或称作管理后台、管理系统、后台管理平台&#xff09;是一种专门用于管理网站、应用程序或系统后台运营的软件系统。它通常由一系列功能模块组成&#xff0c;为管理员提供了管理、监控和控制网站或应用程序的各个方面的工具和界面。以下…
阅读更多...
Spring-IoC

Spring-IoC

文章目录 Spring IoC一、IoC概述1、概述2、IoC原理3、IoC作用4、Spring Bean 二、Spring容器 相关接口1、BeanFactory2、ApplicationContext1&#xff09;HierarchicalBeanFactory2&#xff09;ListableBeanFactory3&#xff09;EnvironmentCapable4&#xff09;ApplicationEve…
阅读更多...
Web3 基金会推出去中心化之声计划：投入高额 DOT 和 KSM ，助力去中心化治理

Web3 基金会推出去中心化之声计划：投入高额 DOT 和 KSM ，助力去中心化治理

作者&#xff1a;Web3 Foundation Team 编译&#xff1a;OneBlock 原文&#xff1a;https://medium.com/web3foundation/decentralized-voices-program-93623c27ae43 Web3 基金会为 Polkadot 和 Kusama 创建了去中心化之声计划&#xff08;Decentralized Voices Program&…
阅读更多...
软考39-上午题-【数据库】-关系代数运算1-传统的集合运算

软考39-上午题-【数据库】-关系代数运算1-传统的集合运算

一、笛卡尔积 二、关系代数 关系代数是施加于关系之上的集合代数运算。 关系代数包含&#xff1a; 传统的集合运算专门的关系运算 2-1、传统的集合运算 1、关系的并 示例&#xff1a; 2、关系的差 示例&#xff1a; 3、关系的交 示例&#xff1a; 关系的并、差、交&#xf…
阅读更多...
LeetCode 448.找到所有数组中消失的数字

LeetCode 448.找到所有数组中消失的数字

目录 1.题目 2.代码及思路 3.进阶 3.1题目 3.2代码及思路 1.题目 给你一个含 n 个整数的数组 nums &#xff0c;其中 nums[i] 在区间 [1, n] 内。请你找出所有在 [1, n] 范围内但没有出现在 nums 中的数字&#xff0c;并以数组的形式返回结果。 示例 1&#xff1a; 输入&am…
阅读更多...
【数学建模入门】

【数学建模入门】

数学建模入门 数学建模需要的学科知识怎么学习数学模型如何读好一篇优秀论文数学建模赛题常见类别数学建模常见问题数学建模组队和分工数学建模准备工作 数学建模需要的学科知识 怎么学习数学模型 &#x1f4a6;推荐阅读书籍&#xff1a; 《数学建模算法与应用》&#xff0c;…
阅读更多...
车规级MCU的行业走向

车规级MCU的行业走向

1 主要厂家 车规级MCU&#xff08;车用微控制器单元&#xff09;的主要厂家包括&#xff1a; NXP半导体&#xff1a;NXP是全球领先的车规级MCU提供商之一&#xff0c;提供广泛的产品用于汽车控制和管理系统。英飞凌科技&#xff1a;作为汽车半导体的领导者之一&#xff0c;英飞…
阅读更多...
fly-barrage 前端弹幕库（1）：项目介绍

fly-barrage 前端弹幕库（1）：项目介绍

fly-barrage 是我写的一个前端弹幕库&#xff0c;由于经常在 Bilibili 上看视频&#xff0c;所以对网页的弹幕功能一直蛮感兴趣的&#xff0c;所以做了这个库&#xff0c;可以帮助前端快速的实现弹幕功能。 项目官网地址&#xff1a;https://fly-barrage.netlify.app/&#xff…
阅读更多...
旅游分享系列之：福建旅游攻略

旅游分享系列之：福建旅游攻略

旅游分享系列之&#xff1a;福建旅游攻略 一、漳州1.福建土楼2.云水谣3.四菜一汤景点 二、厦门1.园林博览苑2.海上自行车道3.山海步道4.海滩5.闽南菜6.落日 三、泉州1.衙口沙滩2.海上日出3.珞珈寺4.海滩烟花 一、漳州 游玩2个景点&#xff1a;云水谣&#xff0c;四菜一汤可以住…
阅读更多...
《图解HTTP》笔记2：http的构成

《图解HTTP》笔记2：http的构成

目录 1&#xff0c;查看浏览器上面一个具体的http请求 2&#xff0c;HTTP报文的具体构成 2.1&#xff0c;http的报文结构 2.2&#xff0c;http的请求报文例子 2.3&#xff0c;http的响应报文例子 1&#xff0c;查看浏览器上面一个具体的http请求 浏览器地址栏输入网址&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发