当前位置:首页 > 服务端 > netty 请求 转发http

netty 请求 转发http

2022年11月07日 11:41:56服务端11

https://netty.io/4.1/xref/io/netty/example/proxy/package-summary.html

https://netty.io/4.1/xref/io/netty/example/proxy/HexDumpProxy.html

package com.test;

import io.netty.channel.ChannelInitializer;

import io.netty.channel.socket.SocketChannel;

import io.netty.handler.logging.LogLevel;

import io.netty.handler.logging.LoggingHandler;

public class HexDumpProxyInitializer extends ChannelInitializer {

private final String remoteHost;

private final int remotePort;

public HexDumpProxyInitializer(String remoteHost, int remotePort) {

this.remoteHost = remoteHost;

this.remotePort = remotePort;

}

@Override

public void initChannel(SocketChannel ch) {

// 获取当前类名;

System.out.println(this.getClass());

ch.pipeline().addLast(

new LoggingHandler(LogLevel.INFO),

new HexDumpProxyInitializer(remoteHost, remotePort)

);

}

}

package com.test;

import io.netty.bootstrap.ServerBootstrap;

import io.netty.channel.ChannelOption;

import io.netty.channel.EventLoopGroup;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.nio.NioServerSocketChannel;

import io.netty.handler.logging.LogLevel;

import io.netty.handler.logging.LoggingHandler;

public class HexDumpProxy {

static final int LOCAL_PORT = Integer.parseInt(System.getProperty("localPort", "8443"));

static final String REMOTE_HOST = System.getProperty("remoteHost", "11.21.1.2");

static final int REMOTE_PORT = Integer.parseInt(System.getProperty("remotePort", "50000"));

public static void main(String[] args) throws Exception {

System.err.println("Proxying *:" + LOCAL_PORT + " to " + REMOTE_HOST + ":" + REMOTE_PORT + "...");

// Configure the bootstrap

EventLoopGroup bossGroup = new NioEventLoopGroup(1);

EventLoopGroup workerGroup = new NioEventLoopGroup();

try {

ServerBootstrap b = new ServerBootstrap();

b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)

.handler(new LoggingHandler(LogLevel.INFO))

.childHandler(new HexDumpProxyInitializer(REMOTE_HOST, REMOTE_PORT))

.childOption(ChannelOption.AUTO_READ, false)

.bind(LOCAL_PORT).sync().channel().closeFuture().sync();

} finally {

bossGroup.shutdownGracefully();

workerGroup.shutdownGracefully();

}

}

}

作者:13775689191
来源链接:https://blog.csdn.net/weixin_34180753/article/details/112944782

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/server/68307.html

标签: NettyHTTP
分享给朋友:

“netty 请求 转发http” 的相关文章

HTTP Status 500

HTTP Status 500

HTTP Status 500 - JDBC exception on Hibernate data access: SQLException for SQL [n/a]; SQL state [HY000]; error code [1364]; could not exec...

SpringBoot 拦截器获取http请求参数

SpringBoot 拦截器获取http请求参数

SpringBoot 拦截器获取http请求参数—— 所有骚操作基础 目录 SpringBoot 拦截器获取http请求参数—— 所有骚操作基础 获取http请求参数是一种刚需 定义拦截器获取请求...

SpringBoot整合Netty并使用Protobuf进行数据传输(附工程)

前言 本篇文章主要介绍的是SpringBoot整合Netty以及使用Protobuf进行数据传输的相关内容。Protobuf会简单的介绍下用法,至于Netty在之前的文章中已经简单的介绍过了,这里就不再过多细说了。 Protobuf 介绍 protoc...

JavaEE 要懂的小事:一、图解Http协议

JavaEE 要懂的小事:一、图解Http协议

Writer      :BYSocket(泥沙砖瓦浆木匠) 微         博:BYSocket 豆  &...

SpringBoot系列——启用https

SpringBoot系列——启用https

  前言   有时候我们需要使用https安全协议,本文记录在SpringBoot项目启用https     生成证书   自签名证书   使用java jdk自带的生成SSL证书的工具keytool生成自己的证书   1、打开cmd...

RabbitMQ安装后无法访问https://localhost:15672/ 控制台问题解决

1.安装完后 我们进入到我们安装到 sbin目录C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.2\sbin执行:rabbitmq-plugins enable rabbitmq_management ...

IDEA:http://fls.jetbrains-agent.com-- No response

起因: win10电脑关机,打开,自动更新了系统。 (误删除vmoptions的-javaagent 绿色 jar包,也会出现↓。。。) [ 2022年1月14日改vmoptions这玩意又替换的别人后而忘了加 -javaagent:D:\idea\je...

SpringMVC优雅的获取HttpSevletRequest及HttpServletResponse简录

通常情况下,SpringMVC可以通过入参的方式绑定HttpServletRequest和HttpServletReponse(SpringMVC在调用处理器时会自动创建对应的HttpServletRequest和HttpServletReponse对象...

AndroidRuntime: FATAL EXCEPTION: OkHttp Dispatcher

今天使用OkHttp的时候遇到一个坑,加了句log后就报错 Log.d(TAG, "onResponse: "+ response.body().string()); String resp = response.body().string();  ...

C# http请求带请求头部分

C# http请求带请求头部分   1、JS设置http请求带请求头部分 <script type="text/javascript"> fun...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。