Java HttpProxyHandler类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中io.netty.handler.proxy.HttpProxyHandler类的典型用法代码示例。如果您正苦于以下问题：Java HttpProxyHandler类的具体用法？Java HttpProxyHandler怎么用？Java HttpProxyHandler使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

HttpProxyHandler类属于io.netty.handler.proxy包，在下文中一共展示了HttpProxyHandler类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: newProxyHandler

import io.netty.handler.proxy.HttpProxyHandler; //导入依赖的package包/类
/**
 * Return a new eventual {@link ProxyHandler}
 *
 * @return a new eventual {@link ProxyHandler}
 */
public final ProxyHandler newProxyHandler() {
	InetSocketAddress proxyAddr = this.address.get();
	String username = this.username;
	String password = Objects.nonNull(username) && Objects.nonNull(this.password) ?
			this.password.apply(username) : null;

	switch (this.type) {
		case HTTP:
			return Objects.nonNull(username) && Objects.nonNull(password) ?
					new HttpProxyHandler(proxyAddr, username, password) :
					new HttpProxyHandler(proxyAddr);
		case SOCKS4:
			return Objects.nonNull(username) ? new Socks4ProxyHandler(proxyAddr, username) :
					new Socks4ProxyHandler(proxyAddr);
		case SOCKS5:
			return Objects.nonNull(username) && Objects.nonNull(password) ?
					new Socks5ProxyHandler(proxyAddr, username, password) :
					new Socks5ProxyHandler(proxyAddr);
	}
	throw new IllegalArgumentException("Proxy type unsupported : " + this.type);
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:27，代码来源:ClientProxyOptions.java

示例2: newProxyHandler

import io.netty.handler.proxy.HttpProxyHandler; //导入依赖的package包/类
public ProxyHandler newProxyHandler() {
    switch (proxySetting.getType()) {
        case ProxySetting.TYPE_HTTP:
            if (proxySetting.getUser().isEmpty()) {
                return new HttpProxyHandler(address);
            } else {
                return new HttpProxyHandler(address, proxySetting.getUser(), proxySetting.getPassword());
            }

        case ProxySetting.TYPE_SOCKS5:
            if (proxySetting.getUser().isEmpty()) {
                return new Socks5ProxyHandler(address);
            } else {
                return new Socks5ProxyHandler(address, proxySetting.getUser(), proxySetting.getPassword());
            }
        case ProxySetting.TYPE_SOCKS4:
            if (proxySetting.getUser().isEmpty()) {
                return new Socks4ProxyHandler(address);
            } else {
                return new Socks4ProxyHandler(address, proxySetting.getUser());
            }
        default:
            throw new RuntimeException("unknown proxy type: " + proxySetting.getType());
    }
}

开发者ID:hsiafan，项目名称:byproxy，代码行数:26，代码来源:ProxyHandlerSupplier.java

示例3: addProxyHandlerIfNeeded

import io.netty.handler.proxy.HttpProxyHandler; //导入依赖的package包/类
private void addProxyHandlerIfNeeded(ChannelPipeline pipeline, HttpProxyConfig httpProxyConfig,
        @Nullable String passwordOverride) throws Exception {
    String proxyHost = httpProxyConfig.host();
    if (proxyHost.isEmpty()) {
        return;
    }
    int proxyPort = MoreObjects.firstNonNull(httpProxyConfig.port(), 80);
    SocketAddress proxyAddress = new InetSocketAddress(proxyHost, proxyPort);
    String username = httpProxyConfig.username();
    if (username.isEmpty()) {
        pipeline.addLast(new HttpProxyHandler(proxyAddress));
    } else {
        String password = getPassword(httpProxyConfig, passwordOverride);
        pipeline.addLast(new HttpProxyHandler(proxyAddress, username, password));
    }
}

开发者ID:glowroot，项目名称:glowroot，代码行数:17，代码来源:HttpClient.java

示例4: send

import io.netty.handler.proxy.HttpProxyHandler; //导入依赖的package包/类
public void send(String url, ProxyConfiguration pc, Map<String, Long> data) {
    if (!(eventLoopGroup.isShuttingDown() || eventLoopGroup.isShutdown())) {
        String[] parts = url.split(":");
        if (parts.length != 2) {
            throw new IllegalArgumentException("Invalid URL: " + url);
        }
        int port = Integer.parseInt(parts[1]);
        Bootstrap b = bootstrapCache.get(Pair.of(url, pc), k -> {
            Bootstrap bb = new Bootstrap()
                    .group(eventLoopGroup)
                    .channel(NioSocketChannel.class)
                    .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, config.readInt(ConfigProperty.GRAPHITE_CONNECT_TIMEOUT))
                    .option(ChannelOption.TCP_NODELAY, true)
                    .option(ChannelOption.SO_SNDBUF, 5 * 1024 * 1024)
                    .option(ChannelOption.SO_TIMEOUT, config.readInt(ConfigProperty.GRAPHITE_CONNECT_TIMEOUT));

            if (pc != ProxyConfiguration.NONE) {
                InetSocketAddress sa = new InetSocketAddress(pc.getHost(), pc.getPort());
                switch (pc.getProxyType()) {
                    case SOCKS5: {
                        bb.handler(new Socks5ProxyHandler(sa, pc.getUsername(), pc.getPassword()));
                        break;
                    }
                    case HTTP:
                    case HTTPS: {
                        if (pc.getProxyType() == ProxyType.HTTPS) {
                            bb.handler(sslContext.newHandler(PooledByteBufAllocator.DEFAULT));
                        }
                        HttpProxyHandler hph = pc.getUsername() != null ? new HttpProxyHandler(sa, pc.getUsername(), pc.getPassword()) :
                                new HttpProxyHandler(sa);
                        bb.handler(hph);
                        break;
                    }
                    default:
                }
            }
            bb.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                }
            });
            return bb;
        });
        try {
            LOG.info("!_! Connect.");
            ChannelFuture cf = b.connect(parts[0], port);
            LOG.info("!_! Sync.");
            cf.sync();
            LOG.info("!_! Get Channel.");
            Channel c = cf.channel();
            data.forEach((metric, timestamp) -> {
                // TODO optimize
                c.write(Unpooled.copiedBuffer(metric + " " + (timestamp / 1000) + "\n", Charsets.ISO_8859_1));
            });
            LOG.info("!_! Flush.");
            c.flush();
            LOG.info("!_! Close.");
            c.close();
        } catch (InterruptedException e) {
            throw Exceptions.runtime(e);
        }
    }
}

开发者ID:dmart28，项目名称:gcplot，代码行数:64，代码来源:GraphiteSender.java

示例5: initChannel

import io.netty.handler.proxy.HttpProxyHandler; //导入依赖的package包/类
@Override
protected void initChannel(SocketChannel ch) throws Exception {
    // Add the generic handlers to the pipeline
    // e.g. SSL handler
    if (proxyServerConfiguration != null) {
        if (proxyServerConfiguration.getProxyUsername() != null
                && proxyServerConfiguration.getProxyPassword() != null) {
            ch.pipeline().addLast("proxyServer",
                    new HttpProxyHandler(proxyServerConfiguration.getInetSocketAddress(),
                            proxyServerConfiguration.getProxyUsername(),
                            proxyServerConfiguration.getProxyPassword()));
        } else {
            ch.pipeline()
                    .addLast("proxyServer", new HttpProxyHandler(proxyServerConfiguration.getInetSocketAddress()));
        }
    }
    if (sslEngine != null) {
        log.debug("adding ssl handler");
        ch.pipeline().addLast("ssl", new SslHandler(this.sslEngine));
    }
    ch.pipeline().addLast("compressor", new CustomHttpContentCompressor(chunkDisabled));
    ch.pipeline().addLast("decoder", new HttpResponseDecoder());
    ch.pipeline().addLast("encoder", new HttpRequestEncoder());
    ch.pipeline().addLast("chunkWriter", new ChunkedWriteHandler());
    if (httpTraceLogEnabled) {
        ch.pipeline().addLast(Constants.HTTP_TRACE_LOG_HANDLER,
                              new HTTPTraceLoggingHandler("tracelog.http.upstream", LogLevel.DEBUG));
    }
    if (followRedirect) {
        if (log.isDebugEnabled()) {
            log.debug("Follow Redirect is enabled, so adding the redirect handler to the pipeline.");
        }
        RedirectHandler redirectHandler = new RedirectHandler(sslEngine, httpTraceLogEnabled, maxRedirectCount
                , chunkDisabled);
        ch.pipeline().addLast(Constants.REDIRECT_HANDLER, redirectHandler);
    }
    handler = new TargetHandler();
    ch.pipeline().addLast(Constants.TARGET_HANDLER, handler);
}

开发者ID:wso2，项目名称:carbon-transports，代码行数:40，代码来源:HTTPClientInitializer.java

示例6: initChannel

import io.netty.handler.proxy.HttpProxyHandler; //导入依赖的package包/类
@Override
public void initChannel(SocketChannel channel) {
    ChannelPipeline pipeline = channel.pipeline();

    if (proxyConfiguration != null) {
        if (proxyConfiguration.getType() == ProxyConfiguration.Type.HTTPS) {
            pipeline.addLast(new HttpProxyHandler(proxyConfiguration.getProxyAddress()));
        } else if (proxyConfiguration.getType() == ProxyConfiguration.Type.SOCKS5) {
            pipeline.addLast(new Socks5ProxyHandler(proxyConfiguration.getProxyAddress()));
        }
    }
    pipeline.addLast(httpClientConnectionHandler);

    if (channel.attr(SECURE) != null && channel.attr(SECURE).get() != null && channel.attr(SECURE).get()) {
        InetSocketAddress remoteAddress = channel.attr(REMOTE_SOCKET).get();
        pipeline.addLast(nettySslContextFactory().createClientSslContext().newHandler(channel.alloc(), remoteAddress.getHostName(), remoteAddress.getPort()));
    }

    // add logging
    if (mockServerLogger.isEnabled(TRACE)) {
        pipeline.addLast(new LoggingHandler("NettyHttpClient -->"));
    }

    pipeline.addLast(new HttpClientCodec());

    pipeline.addLast(new HttpContentDecompressor());

    pipeline.addLast(new HttpObjectAggregator(Integer.MAX_VALUE));

    pipeline.addLast(new MockServerClientCodec());

    pipeline.addLast(httpClientHandler);
}

开发者ID:jamesdbloom，项目名称:mockserver，代码行数:34，代码来源:HttpClientInitializer.java

注：本文中的io.netty.handler.proxy.HttpProxyHandler类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java JobTemplate类代码示例发布时间：2022-05-22

Java Discussion类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18213|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9656|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8168|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8543|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8449|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9375|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8418|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7855|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8403|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7391|2022-11-06

客服电话

电子邮件

Java HttpProxyHandler类代码示例

示例1: newProxyHandler

示例2: newProxyHandler

示例3: addProxyHandlerIfNeeded

示例4: send

示例5: initChannel

示例6: initChannel

请发表评论

全部评论

上一篇：

下一篇：

akexorcist/GoogleDirectionLibrary: [Andr

bradtraversy/iweather: Ionic 3 mobile we

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053