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

2024-02-21 13:04
文章标签 java 整理 cloud 自动化 架构 network lazy 穿透 wu

本文主要是介绍【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
在这里插入图片描述

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

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

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

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

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

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

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

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

这篇关于【wu-lazy-cloud-network】Java自动化内网穿透架构整理的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/731860。

相关文章

使用Java发送邮件到QQ邮箱的完整指南

使用Java发送邮件到QQ邮箱的完整指南

《使用Java发送邮件到QQ邮箱的完整指南》在现代软件开发中,邮件发送功能是一个常见的需求,无论是用户注册验证、密码重置,还是系统通知,邮件都是一种重要的通信方式,本文将详细介绍如何使用Java编写程... 目录引言1. 准备工作1.1 获取QQ邮箱的SMTP授权码1.2 添加JavaMail依赖2. 实现
阅读更多...
Java嵌套for循环优化方案分享

Java嵌套for循环优化方案分享

《Java嵌套for循环优化方案分享》介绍了Java中嵌套for循环的优化方法,包括减少循环次数、合并循环、使用更高效的数据结构、并行处理、预处理和缓存、算法优化、尽量减少对象创建以及本地变量优化,通... 目录Java 嵌套 for 循环优化方案1. 减少循环次数2. 合并循环3. 使用更高效的数据结构4
阅读更多...
java两个List的交集,并集方式

java两个List的交集,并集方式

《java两个List的交集,并集方式》文章主要介绍了Java中两个List的交集和并集的处理方法,推荐使用Apache的CollectionUtils工具类,因为它简单且不会改变原有集合,同时,文章... 目录Java两个List的交集,并集方法一方法二方法三总结java两个List的交集,并集方法一
阅读更多...
Spring AI集成DeepSeek三步搞定Java智能应用的详细过程

Spring AI集成DeepSeek三步搞定Java智能应用的详细过程

《SpringAI集成DeepSeek三步搞定Java智能应用的详细过程》本文介绍了如何使用SpringAI集成DeepSeek,一个国内顶尖的多模态大模型,SpringAI提供了一套统一的接口,简... 目录DeepSeek 介绍Spring AI 是什么？Spring AI 的主要功能包括1、环境准备2
阅读更多...
Spring AI集成DeepSeek实现流式输出的操作方法

Spring AI集成DeepSeek实现流式输出的操作方法

《SpringAI集成DeepSeek实现流式输出的操作方法》本文介绍了如何在SpringBoot中使用Sse（Server-SentEvents）技术实现流式输出,后端使用SpringMVC中的S... 目录一、后端代码二、前端代码三、运行项目小天有话说题外话参考资料前面一篇文章我们实现了《Spring
阅读更多...
Spring AI与DeepSeek实战一之快速打造智能对话应用

Spring AI与DeepSeek实战一之快速打造智能对话应用

《SpringAI与DeepSeek实战一之快速打造智能对话应用》本文详细介绍了如何通过SpringAI框架集成DeepSeek大模型,实现普通对话和流式对话功能,步骤包括申请API-KEY、项目搭... 目录一、概述二、申请DeepSeek的API-KEY三、项目搭建3.1. 开发环境要求3.2. mav
阅读更多...
Springboot的自动配置是什么及注意事项

Springboot的自动配置是什么及注意事项

《Springboot的自动配置是什么及注意事项》SpringBoot的自动配置（Auto-configuration）是指框架根据项目的依赖和应用程序的环境自动配置Spring应用上下文中的Bean... 目录核心概念：自动配置的关键特点：自动配置工作原理：示例：需要注意的点1.默认配置可能不适合所有场景
阅读更多...
使用Apache POI在Java中实现Excel单元格的合并

使用Apache POI在Java中实现Excel单元格的合并

《使用ApachePOI在Java中实现Excel单元格的合并》在日常工作中,Excel是一个不可或缺的工具,尤其是在处理大量数据时,本文将介绍如何使用ApachePOI库在Java中实现Excel... 目录工具类介绍工具类代码调用示例依赖配置总结在日常工作中，Excel 是一个不可或缺的工http://
阅读更多...
Java8需要知道的4个函数式接口简单教程

Java8需要知道的4个函数式接口简单教程

《Java8需要知道的4个函数式接口简单教程》：本文主要介绍Java8中引入的函数式接口,包括Consumer、Supplier、Predicate和Function,以及它们的用法和特点,文中... 目录什么是函数是接口？Consumer接口定义核心特点注意事项常见用法1.基本用法2.结合andThen链
阅读更多...
spring @EventListener 事件与监听的示例详解

spring @EventListener 事件与监听的示例详解

《spring@EventListener事件与监听的示例详解》本文介绍了自定义Spring事件和监听器的方法,包括如何发布事件、监听事件以及如何处理异步事件,通过示例代码和日志,展示了事件的顺序... 目录1、自定义Application Event2、自定义监听3、测试4、源代码5、其他5.1 顺序执行
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2