Browser connection limitations(浏览器长连接个数限制)解决方案
Browser connection limitations解决方案
现象
Web界面订阅Server端长连接接口时,当订阅数量达到一定时,新建长连接将处于pending状态
环境
浏览器:Google Chrome 84.0.4147.135
建立长连接方法:new EventSource()
通讯方式:SSE
SSE实现:org.springframework.web.servlet.mvc.method.annotation.SseEmitter
原因
浏览器限制 具有相同域名的HTTP连接的数量。此限制在HTTP规范(RFC2616)中定义。大多数现代浏览器每个域允许六个连接。大多数较旧的浏览器每个域仅允许两个连接。
该HTTP 1.1协议规定,单用户的客户端不应该维持与任何服务器或代理多于两个连接。这就是浏览器限制的原因。有关更多信息,请参见RFC 2616 –超文本传输协议,第8节–连接。
现代浏览器的限制不那么严格,允许更多的连接。RFC没有指定如何防止超出限制。可以阻止打开连接,也可以关闭现有连接。
源码
前端
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>SseEmitter</title>
</head>
<body>
<button onclick="closeSse()">关闭连接</button>
<div id="message"></div>
</body>
<script>
let source = null;
// 拟登录用户
if (!!window.EventSource) {
// 建立连接
source = new EventSource('http://域/sseTest/sub?tId=1111114');
/**
* 连接一旦建立,就会触发open事件
* 另一种写法:source.onopen = function (event) {}
*/
source.addEventListener('open', function (e) {
setMessageInnerHTML("建立连接。。。");
}, false);
/**
* 客户端收到服务器发来的数据
* 另一种写法:source.onmessage = function (event) {}
*/
source.addEventListener('test', function (e) {
setMessageInnerHTML(e.data);
});
/**
* 如果发生通信错误(比如连接中断),就会触发error事件
* 或者:
* 另一种写法:source.onerror = function (event) {}
*/
source.addEventListener('error', function (e) {
if (e.readyState === EventSource.CLOSED) {
setMessageInnerHTML("连接关闭");
} else {
console.log(e);
}
}, false);
} else {
setMessageInnerHTML("你的浏览器不支持SSE");
}
// 监听窗口关闭事件,主动去关闭sse连接,如果服务端设置永不过期,浏览器关闭后手动清理服务端数据
window.onbeforeunload = function () {
closeSse();
};
// 关闭Sse连接
function closeSse() {
source.close();
const httpRequest = new XMLHttpRequest();
httpRequest.open('GET', 'http://域/sseTest/close?tId=1111', true);
httpRequest.send();
console.log("close");
}
// 将消息显示在网页上
function setMessageInnerHTML(innerHTML) {
document.getElementById('message').innerHTML += innerHTML + '<br/>';
}
</script>
</html>
后端
/**
* @author senkyouku
* @ClassName: TestDemoController
* @Description: sseDemo
* @date 2020-08-28
*/
@Slf4j
@CrossOrigin
@RestController
@RequestMapping("/sseTest")
public class TestDemoController {
private final ConcurrentHashMap<String, SseEmitter> sseContainer = new ConcurrentHashMap<>();
/***
* sse订阅
*
* @param sub 订阅参数
* @return SseEmitter
*/
@RequestMapping("/sub")
public Object sub(SseSubDTO sub) {
try {
SseEmitter sseEmitter = new SseEmitter(180000L);
sseContainer.put(sub.getTId(), sseEmitter);
return sseEmitter;
} catch (Exception e) {
log.error("sse订阅失败,参数:{}", sub);
return e.getMessage();
}
}
/***
* sse取消订阅
*
* @param sub 订阅参数
* @return String
*/
@RequestMapping("/close")
public String close(SseSubDTO sub) {
try {
// 2、创建SseEmitter 超时 3min
SseEmitter sseEmitter = sseContainer.get(sub.getTId());
sseEmitter.complete();
sseContainer.remove(sub.getTId());
return "ok";
} catch (Exception e) {
log.error("sse订阅失败,参数:{}", sub);
return e.getMessage();
}
}
/**
* 推送
*/
@Scheduled(fixedRate = 2000)
public void sseScheduled() {
sseContainer.entrySet().parallelStream().forEach(p -> {
// 推送失败,移除该订阅sse
SseEmitter sseEmitter = p.getValue();
SseEmitter.SseEventBuilder builder = SseEmitter
.event()
.data("ok")
.name("test");
try {
sseEmitter.send(builder);
} catch (IOException e) {
log.error("推送失败,订阅信息:{},e:{}", p.getKey(), e);
}
});
}
解决方案
方案一:使用多个子域
解决浏览器限制一种方法是提供多个子域。每个子域均允许最大连接数。通过使用编号的子域,客户端可以选择一个随机的子域进行连接。如果DNS服务器允许将与模式匹配的子域解析为同一服务器。
如上述前端代码中【域】,可以使用不同的域名或者使用不同的IP+端口,均可以解决限制问题,不过根据HTTP 1.1协议规定,单用户的客户端不应该维持与任何服务器或代理多于两个连接,我们可以参考方案二
方案二:同一个界面使用同一个长连接
由前端订阅通知业务类型,服务端根据不同的业务类型推送不同的事件,即不同的eventName,代码片段如下,SseEmitter.name 根据不同业务类型设置不同的eventName
try {
SseEmitter.SseEventBuilder builder = SseEmitter
.event()
.data("ok")
.name("test");
sseEmitter.send(builder);
} catch (IOException e) {
log.error("推送失败,订阅信息:{},e:{}", p.getKey(), e);
}
推荐
方案一和方案二同时使用,在一些交易服务中,个别用户可能会打开多个界面,一个界面使用一个长连接,以Chrome来说最多建立6个长连接,当使用多子域方案时可以进行水平扩展,打破这个限制。
附录
各个浏览器长连接个数
浏览器及版本 | 最大连接数 |
---|---|
Internet Explorer的® 7.0 | 2 |
Internet Explorer 8.0和9.0 | 6 |
Internet Explorer 10.0 | 8 |
Internet Explorer 11.0 | 13 |
火狐® | 6 |
Chrome™ | 6 |
Safari浏览器® | 6 |
歌剧® | 6 |
iOS版® | 6 |
Android™ | 6 |
相关文章
- 【技术种草】cdn+轻量服务器+hugo=让博客“云原生”一下
- CLB运维&运营最佳实践 ---访问日志大洞察
- vnc方式登陆服务器
- 轻松学排序算法:眼睛直观感受几种常用排序算法
- 十二个经典的大数据项目
- 为什么使用 CDN 内容分发网络?
- 大数据——大数据默认端口号列表
- Weld 1.1.5.Final,JSR-299 的框架
- JavaFX 2012:彻底开源
- 提升as3程序性能的十大要点
- 通过凸面几何学进行独立于边际的在线多类学习
- 利用行动影响的规律性和部分已知的模型进行离线强化学习
- ModelLight:基于模型的交通信号控制的元强化学习
- 浅谈Visual Source Safe项目分支
- 基于先验知识的递归卡尔曼滤波的代理人联合状态和输入估计
- 结合网络结构和非线性恢复来提高声誉评估的性能
- 最佳实践丨云开发CloudBase多环境管理实践
- TimeVAE:用于生成多变量时间序列的变异自动编码器
- 具有线性阈值激活的神经网络:结构和算法
- 内网渗透之横向移动 -- 从域外向域内进行密码喷洒攻击