JAVA流控及超流控后的延迟处理实例
本文实例讲述了JAVA流控及超流控后的延迟处理方法。分享给大家供大家参考。具体实现方法如下:
流控检查(每半秒累计,因此最小留空阀值只能做到每秒2条):
import java.text.SimpleDateFormat;
import java.util.Date;
import java.lang.Thread;
/**
* 流量控制
*
* @author chenx
*/
public class OverflowController {
private int maxSendCountPerSecend; // 该条链路上流控阀值
private Date sendTime = new Date();
private int sendCount = 0; // 该条链路上发送的数量
public OverflowController(int maxSendCountPerSecend) {
if (maxSendCountPerSecend < 2) {
maxSendCountPerSecend = 2;
}
this.maxSendCountPerSecend = maxSendCountPerSecend;
}
public int getMaxSendCountPerSecend() {
if (getMilliseconds(new Date()) >= 500) {
return maxSendCountPerSecend / 2;
}
return maxSendCountPerSecend – (maxSendCountPerSecend / 2);
}
/**
* 是否超流控
*/
public boolean isOverflow(int sendNum) {
synchronized (this) {
Date now = new Date();
if (now.getTime() – sendTime.getTime() >= 500) {
sendTime = now;
sendCount = sendNum;
} else {
if (sendCount + sendNum > getMaxSendCountPerSecend()) {
return true;
} else {
sendCount += sendNum;
}
}
return false;
}
}
/**
* 获取指定时间的毫秒数
*/
private int getMilliseconds(Date date) {
SimpleDateFormat df = new SimpleDateFormat(“SSS”);
return Integer.valueOf(df.format(date));
}
public static void main(String[] args) throws InterruptedException {
OverflowController oc = new OverflowController(50);
SimpleDateFormat df = new SimpleDateFormat(“yyyy-MM-dd HH:mm:ss:SSS”);
for (int i = 0; i <= 100; i++) {
if (oc.isOverflow(1)) {
System.out.println(i + “-isOverflow-” + df.format(new Date()));
} else {
System.out.println(i + “-sendOk-” + df.format(new Date()));
}
Thread.sleep(10);
}
}
}
超流控后的延迟处理,由于java中没有.net的“延迟委托”一说:
ThreadPool.RegisterWaitForSingleObject(
WaitHandle waitObject,
WaitOrTimerCallback callBack,
Object state,
int millisecondsTimeOutInterval,
bool executeOnlyOnce
)
Java下需实现一个简单的延迟队列:
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
public class DelayEntry implements Delayed {
private int count;
private long dequeuedTimeMillis; // 出队列时间
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
public long getDequeuedTimeMillis() {
return dequeuedTimeMillis;
}
public DelayEntry(long delayMillis) {
dequeuedTimeMillis = System.currentTimeMillis() + delayMillis;
}
@Override
public int compareTo(Delayed o) {
DelayEntry de = (DelayEntry) o;
long timeout = dequeuedTimeMillis – de.dequeuedTimeMillis;
return timeout > 0 ? 1 : timeout < 0 ? -1 : 0;
}
@Override
public long getDelay(TimeUnit unit) {
return dequeuedTimeMillis – System.currentTimeMillis();
}
}
import java.util.concurrent.DelayQueue;
public class DelayService {
public void run() {
DelayQueue queue = new DelayQueue();
DelayConsumer delayConsumer = new DelayConsumer(queue);
delayConsumer.start();
for (int i = 0; i < 100; i++) {
DelayEntry de = new DelayEntry(5000);
de.setCount(i);
System.out.println(System.currentTimeMillis() + “——–” + de.getCount());
queue.add(de);
}
}
class DelayConsumer extends Thread {
DelayQueue queue;
public DelayConsumer(DelayQueue queue) {
this.queue = queue;
}
public void run() {
while (true) {
try {
DelayEntry de = queue.take();
System.out.println(“queue size=” + queue.size());
System.out.println(de.getCount());
System.out.println(System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
DelayService ds = new DelayService();
ds.run();
}
}
希望本文所述对大家的Java程序设计有所帮助。相关阅读:
js 自动播放的实例代码
mysql 服务意外停止1067错误解决办法小结
win10应用安装10台设备后无法继续安装应用的解决方法
CSS实现微信扫码特效
js实现点击图片将图片地址复制到粘贴板的方法
JavaScript Promise启示录
Win7中打开txt文件显示“无法找到脚本文件”解决方法
一张GIF动图浓缩回顾 从Windows 1.0到Win 10正式版进化史
AngularJS基础 ng-keypress 指令简单示例
js之ActiveX控件使用说明 new ActiveXObject()
Android Http实现文件的上传和下载
javascript实现保留两位小数的多种方法
PHP+shell实现多线程的方法
电脑升级到win8系统后导致浏览器无法访问网页怎么办?
今天的文章
java多线程面试题及答案_java延迟两秒执行分享到此就结束了,感谢您的阅读。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/61055.html