Java版本的VPN（wlcn）1.3.1-JDK17-SNAPSHOT

article/2025/8/22 7:56:07
项目介绍

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

版本更新

1.3.1-JDK17-SNAPSHOT
[add] 新增http代理（客户端代理服务端、客户端代理客户杜安、服务端代理客户端、服务端代理服务端）
[add] 新增socks代理（客户端代理服务端、客户端代理客户杜安、服务端代理客户端、服务端代理服务端）
[add] 新增客户端路由管理、新增服务端路由管理
[add] 支持新增虚拟IP，代理到指定的IP
[add] 通过页面配置，代理支持控制端口代理控制

在这里插入图片描述

架构图

在这里插入图片描述

实现原理
服务端创建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
在这里插入图片描述

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

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

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

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

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

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

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

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

路由

  • 客户端路由管理
    在这里插入图片描述

  • 客户端虚拟路由管理

  • 创建一个虚拟的不存在的IP，代理到指定的IP
    在这里插入图片描述

  • 服务端路由管理
    在这里插入图片描述

  • 服务端虚拟路由管理

  • 创建一个虚拟的不存在的IP，代理到指定的IP
    在这里插入图片描述


http://www.hkcw.cn/article/OjuZZWwNpL.shtml

相关文章

javaweb 前言

javaweb 前言

Web的发展历史 Web的诞生 (1989-1991)&#xff1a; 1989年&#xff0c;欧洲核子研究组织&#xff08;CERN&#xff09;的蒂姆伯纳斯-李提出了World Wide Web的概念&#xff0c;并发明了统一资源定位符&#xff08;URL&#xff09;、超文本传输协议&#xff08;HTTP&#xff09…
阅读更多...
＜el-date-picker＞配置禁用指定日期之前的时间选择（Vue2+Vue3）

＜el-date-picker＞配置禁用指定日期之前的时间选择（Vue2+Vue3）

今天突然接受到一个离谱的需求&#xff1a;有一个需要配置定时任务开始执行时间的组件&#xff0c;之前的做法都是用<el-form>的rules定义校验规则&#xff0c;也能实现效果&#xff0c;但是今天产品突发奇想&#xff1a;不能选的时间就置灰&#xff08;就是我们说的禁用…
阅读更多...
Redis 主从节点

Redis 主从节点

Redis 主从节点的核心区别 特性主节点 (Master)从节点 (Slave/Replica)读写权限可读可写只读&#xff08;默认配置&#xff09;数据流向数据来源从主节点同步数据连接关系可连接多个从节点只能连接一个主节点故障切换故障时需要手动/自动提升从节点可被提升为新的主节点命令执…
阅读更多...
[NOIP 2001 普及组] 数的计算 Java

[NOIP 2001 普及组] 数的计算 Java

import java.util.*;public class Main {public static void main(String[] args) {Scanner sc new Scanner(System.in);int n sc.nextInt();sc.close();int[] arr new int[n 1]; // 存储第i个数对应的合法数列数for (int i 1; i < n; i) {arr[i]; // 只有一个数n的数列…
阅读更多...
【NATURE氮化镓】GaN超晶格多沟道场效应晶体管的“闩锁效应”

【NATURE氮化镓】GaN超晶格多沟道场效应晶体管的“闩锁效应”

2025年X月X日，布里斯托大学的Akhil S. Kumar等人在《Nature Electronics》期刊发表了题为《Gallium nitride multichannel devices with latch-induced sub-60-mV-per-decade subthreshold slopes for radiofrequency applications》的文章，基于AlGaN/GaN超晶格多通道场效应晶…
阅读更多...
Vue-Router 基础使用

Vue-Router 基础使用

Vue Router 是 Vue 官方的客户端路由解决方案。 客户端路由的作用是在单页应用 SPA 中将浏览器的 URL 和用户看到的内容绑定起来。当用户在应用中浏览不同页面时&#xff0c;URL 会随之更新&#xff0c;但页面不需要从服务器重新加载。 Vue Router 基于 Vue 的组件系统构建&a…
阅读更多...
Linux服务器时间同步——Chronyd

Linux服务器时间同步——Chronyd

需求&#xff1a;现有三台服务器&#xff0c;想要确保服务器间时间保持一致。 一、安装Chronyd 确认是否安装了chronyd服务 systemctl status chronyd 如果Linux系统中没有安装&#xff0c;可以通过如下命令进行安装&#xff1a; yum install chrony -y 注&#xff1a;确保…
阅读更多...
手机实名认证接口如何用C#进行调用？

手机实名认证接口如何用C#进行调用？

一、什么是手机实名认证接口&#xff1f; 通过输入用户的姓名与手机号码&#xff0c;或手机号与身份证号码&#xff0c;验证三者之间的匹配关系&#xff0c;从而判断该手机号是否属于指定用户本人。 二、为什么需要运营商二要素验证&#xff1f;传统方式有哪些局限&#xff1…
阅读更多...
springboot多模块父pom打包正常，单模块报错

springboot多模块父pom打包正常，单模块报错

背景&#xff1a;因为项目开发中经常发测试环境&#xff0c;发现使用阿里的插件能一键上传&#xff0c;不用手动上传比较方便。但是多模块有多个启动jar的时候&#xff0c;全局打包太慢&#xff0c;单独打发现报错。这里贴一下我使用这个插件的方式&#xff1a; 附带一个我感觉…
阅读更多...
硬件同步机制-Swap指令实现互斥的基本讲解

硬件同步机制-Swap指令实现互斥的基本讲解

Swap 指令 Swap指令能原子地交换两个变量的值 &#xff0c;即这一操作不可分割、不会被中断。其代码逻辑为&#xff1a; boolean temp *a; &#xff1a;创建一个临时变量temp &#xff0c;将变量a的值暂存到temp中 。*a *b; &#xff1a;把变量b的值赋给变量a 。*b temp; &…
阅读更多...
中国国运新引擎：下一代液晶技术突破如何重塑全球显示格局

中国国运新引擎：下一代液晶技术突破如何重塑全球显示格局

一、国运崛起&#xff1a;中国在未来关键领域的集体突破 在全球科技竞争白热化的当下&#xff0c;中国正迎来关键领域的集中爆发。从新能源汽车到 5G 通信&#xff0c;从量子计算到航天工程&#xff0c;中国不仅打破了西方的技术封锁&#xff0c;更在多个战略领域实现了从 “跟…
阅读更多...
在雄性小鼠自发脑网络中定位记忆巩固的因果中枢

在雄性小鼠自发脑网络中定位记忆巩固的因果中枢

目录 简要总结 摘要 1 引言 2 方法 3 结果 简要总结 这篇文章主要研究了雄性小鼠在自发脑网络中记忆巩固的因果中枢定位。记忆巩固涉及学习后休息和睡眠期间全脑网络的自发重组&#xff0c;但具体机制尚不清楚。目前理论认为海马体在这一过程中至关重要&#xff0c;但其他…
阅读更多...
美国威胁退出俄乌冲突调解

美国威胁退出俄乌冲突调解

△联合国安理会（资料图）当地时间5月29日，美国告知联合国安理会，如果俄罗斯决定继续在乌克兰进行军事行动，美国将不得不考虑退出旨在结束冲突的谈判努力。美国表示，目前提出的协议是对俄罗斯最好的结果，俄罗斯总统普京应该接受。此外，对俄罗斯的额外制裁仍在讨论中。美国…
阅读更多...
flutter项目迁移空安全

flutter项目迁移空安全

重中之重 备份好项目文件&#xff0c;甚至连已经加载好的flutter库也可以备份。环境包升级 2.1 不要直接换成flutter:3.0以上的版本&#xff0c;这样做既有基本的库兼容问题&#xff0c;又有空安全下的语法问题(整个项目中需要增加 late、?、!的语法错误&#xff0c;一片报错的…
阅读更多...
单亲妈妈抗癌6年去世 生命旅程的坚韧与无奈

单亲妈妈抗癌6年去世 生命旅程的坚韧与无奈

单亲妈妈抗癌6年去世 生命旅程的坚韧与无奈！5月28日晚，浙江的单亲妈妈张潇群因结肠癌去世，年仅37岁。她在网络上是一位知名的抗癌博主，无数人关注着她的抗癌历程，从确诊到治疗的过程充满艰辛。浏览她的社交媒体，仿佛走进了一场关于疼痛的独白，无论是病痛的呻吟还是求生的…
阅读更多...
深入理解C#泛型：提升代码复用与类型安全的利器

深入理解C#泛型：提升代码复用与类型安全的利器

在现代软件开发中&#xff0c;编写灵活、可重用且类型安全的代码是每个开发者的追求。C#作为一种强类型语言&#xff0c;通过引入泛型(Generics)特性&#xff0c;完美地解决了代码重用与类型安全之间的矛盾。本文将全面探讨C#泛型的核心概念、实现原理、高级特性以及最佳实践&a…
阅读更多...
Deepseek升级 低调发布性能提升

Deepseek升级 低调发布性能提升

5月28日晚，DeepSeek在官方交流群中宣布R1模型已完成小版本试升级。今年3月，DeepSeek对V3模型进行小版本升级时也采用了同样的方式，先通过官方交流群宣布，随后才公布具体更新内容。本次试升级，DeepSeek依旧保持低调，没有发布详细的技术说明文档或举行发布活动。然而，据用…
阅读更多...
AET3156AP电源方案 禾纳代理商

AET3156AP电源方案 禾纳代理商

特性VDs-30V,ID-28ARDS(ON)13.5mOM(TYR.)VGS-10V&#xff0c;Ib-6ARDS(ON)18mOM(TYR.)VGS-4.5V&#xff0c;IB-5A可靠且坚固雪
阅读更多...
学生管理系统V2.0

学生管理系统V2.0

学生管理系统V2.0 需求: 要求实现一个基于指针的学生成绩管理系统&#xff0c;具体功能如下: 添加学生信息&#xff1a;输入学号和三门成绩&#xff0c;存储到数组中。显示所有学生信息&#xff1a;遍历数组&#xff0c;输出每个学生的学号和成绩。计算每个学生的平均分和总分&…
阅读更多...
从汇编的角度揭秘C++函数重载，原来这么简单

从汇编的角度揭秘C++函数重载，原来这么简单

函数重载是指在同一个作用域内&#xff0c;有多个同名函数&#xff0c;但是它们的形参列表不同。在调用时&#xff0c;根据不同的实参&#xff0c;调用相应的函数。函数重载是一种静态多态形式。我们先来看一个函数重载的例子&#xff0c;然后分析其背后的原理。请看下面这段代…
阅读更多...
推荐文章

Copyright @ 2022~2023