Browser connection limitations(浏览器长连接个数限制)解决方案

原创
2020/12/04 11:30
阅读数 1K

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
展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部