java 带宽控制_如何使用Java netty正确限制带宽使用?

对于我使用netty nio lib在

Java中开发的下载客户端,我还实现了带宽限制功能.从技术上讲,我是通过GlobalTrafficShapingHandler对象完成的.基于这个类’JavaDoc我初始化nio客户端管道如下:

...

trafficHandler = new GlobalTrafficShapingHandler(

new HashedWheelTimer(),1000);

execHandler = new ExecutionHandler(

new OrderedMemoryAwareThreadPoolExecutor(20,0));

...

public ChannelPipeline getPipeline() throws Exception

{

// create default pipeline

ChannelPipeline pipeline = pipeline();

// traffic shaping handler

pipeline.addLast("global-traffic-shaping",trafficHandler);

// SSL support

if(useSSL)

{

SSLEngine sslEngine = createSSLEngine();

pipeline.addLast("ssl",new SslHandler(sslEngine));

}

// memory executor

pipeline.addLast("memory-executor",execHandler);

// business logic

pipeline.addLast("data-processing",new NettyNioClientHandler(

nettyNioClient,localer,logger,ncMgr,username,useSSL));

return pipeline;

}

然后在运行时我设置最大值.通过下载速度

public void setDlSpeedLimit(long limit)

{

if(limit < 0)

return;

trafficHandler.configure(0,limit * 1000L);

}

好吧,所以基本上netty nio功能运行得很好而且速度很快.当我设置最大值.在应用程序中下载速度,我还可以看到带宽使用确实上限为最大值.水平.我监视带宽使用情况

trafficHandler.getTrafficCounter().getLastReadThroughput();

然而,不幸的是最大.速度我监控不是我之前设置的,甚至没有关闭.例如,我最初(没有限制)的下载速度约为2000 kb / s,然后我将限制设置为300 kb / s,如上所述,但实际下载速度则从700-900 kb /秒.

所以我在这种情况下的问题是:我可以看到流量整形器正在做某事,但不是我想要的.我在这里错过了什么,例如管道初始化中的任何步骤?

在此先感谢您的帮助!

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

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

相关文章

【LeetCode刷题笔记】动态规划(二)

647. 回文子串 解题思路: 1. 暴力穷举 , i 遍历 [0, N) , j 遍历 [i+1, N] ,判断每一个子串 s[i, j) 是否是回文串,判断是否是回文串可以采用 对撞指针 的方法。如果是回文串就计数 +1

mysql数据库集群备份策略_mysql高可用方案之集群(cluster)

1.实验环境我用三台服务器搭建mysql cluster环境,sql节点和数据节点在同一服务器上,管理节点单独一台.cluster node1:192.168.1.102 data node1:192.168.1.102cluster node2:192.168.1.104 data node2:192.168.1.104manager node:192.168.1.19OS:centos 6.4 64位…

数据结构 排序 java_Java数据结构之排序---选择排序

简单选择排序的介绍&#xff1a;从给定的序列中&#xff0c;按照指定的规则选出某一个元素&#xff0c;再根据规定交换位置后达到有序的目的。简单选择排序的基本思想&#xff1a;假定我们的数组为int [] arr new int[n]&#xff0c;第一次我们从arr[0]~arr[n-1]中选择出最小的…

php和java 2017_Php与java的区别

Php与java的区别1.java和php技术层面对比:java是纯面向对象开发,功能强大,分支众多,没有java不能做的软件,PHP有他独特的领域,那就是WEB在这方面没有可以和他相比较,其与java相比较之下在这一方面基本上完胜java因其专注的领域不同所以没有太大可比性,PHP适合于快速开发,中小型…

python百度aip移动目标监控系统_python利用百度云接口实现车牌识别

一个小需求---实现车牌识别。目前有两个想法调云在线的接口或者使用SDK做开发(配置环境和编译第三方库很麻烦&#xff0c;当然使用python可以避免这些问题)自己实现车牌识别算法(复杂)&#xff01;一开始准备使用百度云文字识别C SDK来做&#xff0c;发现需要准备curl、jsoncpp…

centos tar安装mysql_centos系统通过tar.gz包安装mysql5.7.19

系统&#xff1a;centos6.5 64位系统1、下载mysql本人选的linux generic 通用版 64位2、把mysql传到服务器并解压到/usr/localtar -xzvf mysql-5.7.19-linux-glibc2.12-x86_64.tar -C /usr/local3、进入/usr/local目录:cd /usr/local4、为mysql安装目录创建软链接ln -s mysq…

java6打印机不能用_高分求解:java中调用的打印机在什么情况下不可用?

java文档中说PrinterJob类中的getPrinterJob()方法无论返回的打印机是否可用都不会返回一个null值。我查阅过一些文献有介绍说可以用getPrintService()方法测试返回的数值是否为null来...java文档中说PrinterJob类中的getPrinterJob()方法无论返回的打印机是否可用都不会返回一…

java中算两个时间内的秒数_java – Joda Time – 计算两个日期之间的秒数会引发异常....

我使用以下代码来计算两个日期之间的秒数差异&#xff1a;long secondsBetween (Seconds.secondsBetween(new LocalDate("1901-01-01"), new LocalDate()).getSeconds());但是我得到以下异常&#xff1a;08-08 18:21:27.345: E/AndroidRuntime(6972): java.lang.Run…

java快速排序从小到大_JAVA一个快速排序实现代码

首先排序的方法有很多种&#xff1a;插入排序&#xff0c;冒泡排序&#xff0c;堆排序&#xff0c;归并排序&#xff0c;选择排序&#xff0c;计数排序&#xff0c;基数排序&#xff0c;桶排序&#xff0c;快速排序等这里是主要讲解一下快速排序这个方法&#xff0c;我也是看了…

java 反射 内存_Java 反射

Java 反射正常的类加载过程当执行new xxx();语句时&#xff0c;JVM会被触发加载.class文件JVM从本地文件找到class文件并且加载到内存中JVM自动创建一个class对象 (一个类只产生一个class对象)将Java的二进制代码合并到JVM的运行状态之中验证&#xff1a; 确保类的信息符合JVM规…

java取json对象的值_java的JsonObject对象提取值方法

实例如下所示&#xff1a;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONArray;import com.alibaba.fastjson.JSONObject;import io.swagger.models.auth.In;import java.io.IOException;import java.security.KeyManagementException;import java.securi…

aqs clh java_【Java并发编程实战】----- AQS(一):简介

在前面博客中&#xff0c;LZ讲到了ReentrantLock、ReentrantReadWriteLock、Semaphore、CountDownLatch&#xff0c;他们都有各自获取锁的方法&#xff0c;同时相对于Java的内置锁&#xff0c;他们具有明显的优势&#xff1a;花最小的空间开销创建锁、最少的时间开销获得锁、使…

为什么数据结构不用java_泛谈Java中的不可变数据结构

作为我最近一直在进行的一些编码访谈的一部分&#xff0c;有时会出现不变性问题。我自己并不过分教条&#xff0c;但每当不需要可变状态时&#xff0c;我会试图摆脱导致可变性的代码&#xff0c;这在数据结构中通常是最明显的。然而&#xff0c;似乎对不可变性的概念存在一些误…

java后台解析json并保存到数据库_[Java教程]ajax 发送json 后台接收 遍历保存进数据库...

[Java教程]ajax 发送json 后台接收 遍历保存进数据库0 2017-09-25 15:00:23前台怎么拿参数的我就不管了我也不会反正用这个ajax没错ajax 代码 一定要写明http请求类型 {contentType:"application/x-www-form-urlencoded; charsetutf-8",}这一段很重要(就是因为这个…

java实时更新权限_java – 如何使用Spring Security重新加载用户更新的权限

如果您需要动态更新登录的用户权限(当这些权限发生变化时,无论什么原因),无需登出并登录,您只需要重置Spring SecurityContextHolder中的Authentication对象(安全令牌)即可.例&#xff1a;Authentication auth SecurityContextHolder.getContext().getAuthentication();List u…

gitlab ci 配置 java_GitLab CI/CD 配置

GitLab CI/CD 配置概念操作示例创建测试项目 sample-web&#xff0c;然后打开项目的 Runners 配置找到这个地方&#xff0c;后边要用然后搭建 gitlab-runner&#xff0c;CI/CD 需要通过它实现# 创建 gitlab-runner 目录mkdir -p /usr/local/gitlab-runner && cd /usr/l…

mysql的dbconn_管道错误使用mysql.conn

我完全迷路了。这是我的管道。我说我跑错了File "c:\python27\lib\site-packages\twisted\internet\defer.py", line 588, in _runCallbackscurrent.result callback(current.result, *args, **kw)File "C:\Python27\bff\bff\pipelines.py", line 42, in …

java失败javac成功_JAVA SE JDK-10安装、配置(解决java成功,javac失败问题)

本文是在win10环境下安装JDK-10在linux环境下安装JDK-10请点击&#xff1a;CentOS 7 安装、配置JDK-101、下载JDK包点击打开下载网站点击图中的Accept License Agreement&#xff0c;再选择Win版本进行下载2、安装JDK包下载完毕&#xff0c;运行安装程序修改安装路径(这里选择的…

java搭建聊天服务器_使用 ServerSocket 建立聊天服务器-2

1.从serverListener中可以看出,每一个客户端创建新的请求之后,都会把它分配给一个独立的chatsocket ,但是每一个ChatSocket都是相互独立的,他们之间并不能沟通,所以要新建一个类,将这些新建的线程管理起来,然后实现他们之间的相互通信.(类似于微信加群聊天的功能)由于一个聊天服…

java实验10流_实验9 Java输入输出流

《实验9 Java输入输出流》由会员分享&#xff0c;可在线阅读&#xff0c;更多相关《实验9 Java输入输出流(14页珍藏版)》请在金锄头文库上搜索。1、山 西 大 学 计 算 机 与 信 息 技 术 学 院实 验 报 告姓 名 颜 凯 丽 学 号 2010242100 专业班级 软件工程一班课程名称 Java …