some problem with STOMP-over-WebSockets

[xman01111]

em..... I was use stomp.js to connection rabbitmq server ，but the connection will close in 1-10 minute

debug log:

2022-01-14 17:54:10.976000+08:00 [debug] <0.5915.0> Deleting auto-delete queue 'stomp-subscription-6-LIT28y2NcReLZPQ7aEuw' in vhost '/' because all of its consumers (1) were on a channel that was closed
2022-01-14 17:54:10.976000+08:00 [debug] <0.5970.0> Closing all channels from connection '127.0.0.1:1834 -> 127.0.0.1:15674' because it has been closed
2022-01-14 17:54:10.977000+08:00 [debug] <0.5909.0> Deleting auto-delete queue 'stomp-subscription-I7H46bYvvy1EsJwahBA2zg' in vhost '/' because all of its consumers (1) were on a channel that was closed
2022-01-14 17:54:16.954000+08:00 [info] <0.5977.0> Supervisor {<0.5977.0>,rabbit_web_stomp_connection_sup}: child rabbit_web_stomp_keepalive_sup started (<0.5978.0>): {rabbit_web_stomp_connection_sup,start_keepalive_link,[]}
2022-01-14 17:54:16.954000+08:00 [info] <0.5977.0> Supervisor {<0.5977.0>,rabbit_web_stomp_connection_sup}: child cowboy_clear started (<0.5979.0>): {cowboy_clear,start_link,[{acceptor,{0,0,0,0,0,0,0,0},15674},ranch_tcp,#{env => #{dispatch => [{'_',[],[{[<<"ws">>],[],rabbit_web_stomp_handler,[{type,text},{ws_opts,#{}}]}]}],keepalive_sup => <0.5978.0>},middlewares => [cowboy_router,rabbit_web_stomp_middleware,cowboy_handler],proxy_header => false,stream_handlers => [rabbit_web_stomp_stream_handler,cowboy_stream_h]}]}
2022-01-14 17:54:16.957000+08:00 [info] <0.5981.0> Supervisor {<0.5981.0>,amqp_connection_sup}: child connection_type_sup started (<0.5982.0>): {amqp_connection_type_sup,start_link,[]}
2022-01-14 17:54:16.957000+08:00 [info] <0.5981.0> Supervisor {<0.5981.0>,amqp_connection_sup}: child connection started (<0.5983.0>): {amqp_gen_connection,start_link,[<0.5982.0>,{amqp_params_direct,<<"guest">>,{encrypted,<<"tO3cjf0QyftBX4MGYR3DImgx3j/dCJF0JGagThL4oldVZ9fIaxD3yx1qQQRjJhkI">>},<<"/">>,'rabbit@DESKTOP-LSUNVM2',{amqp_adapter_info,{127,0,0,1},15674,{127,0,0,1},2029,<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,{'Web STOMP',"1.1"},[{channels,1},{channel_max,1},{frame_max,0},{client_properties,[{<<"product">>,longstr,<<"STOMP client">>}]},{ssl,false}]},[]}]}
2022-01-14 17:54:16.958000+08:00 [debug] <0.5984.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2022-01-14 17:54:16.959000+08:00 [info] <0.5982.0> Supervisor {<0.5982.0>,amqp_connection_type_sup}: child channel_sup_sup started (<0.5986.0>): {amqp_channel_sup_sup,start_link,[direct,<0.5983.0>,<<"127.0.0.1:2029 -> 127.0.0.1:15674">>]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5982.0> Supervisor {<0.5982.0>,amqp_connection_type_sup}: child channels_manager started (<0.5987.0>): {amqp_channels_manager,start_link,[<0.5983.0>,<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,<0.5986.0>]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5982.0> Supervisor {<0.5982.0>,amqp_connection_type_sup}: child collector started (<0.5988.0>): {rabbit_queue_collector,start_link,[<<"127.0.0.1:2029 -> 127.0.0.1:15674">>]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5989.0> Supervisor {<0.5989.0>,amqp_channel_sup}: child gen_consumer started (<0.5990.0>): {amqp_gen_consumer,start_link,[amqp_selective_consumer,[],{<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,1}]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5989.0> Supervisor {<0.5989.0>,amqp_channel_sup}: child channel started (<0.5991.0>): {amqp_channel,start_link,[direct,<0.5983.0>,1,<0.5990.0>,{<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,1}]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5993.0> Supervisor {<0.5993.0>,rabbit_channel_sup}: child limiter started (<0.5994.0>): {rabbit_limiter,start_link,[{<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,1}]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5993.0> Supervisor {<0.5993.0>,rabbit_channel_sup}: child channel started (<0.5995.0>): {rabbit_channel,start_link,[1,<0.5991.0>,<0.5991.0>,<0.5983.0>,<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,rabbit_framing_amqp_0_9_1,{user,<<"guest">>,[administrator],[{rabbit_auth_backend_internal,none}]},<<"/">>,[{<<"publisher_confirms">>,bool,true},{<<"exchange_exchange_bindings">>,bool,true},{<<"basic.nack">>,bool,true},{<<"consumer_cancel_notify">>,bool,true},{<<"connection.blocked">>,bool,true},{<<"authentication_failure_close">>,bool,true}],<0.5988.0>,<0.5994.0>,{amqp_params_direct,<<"guest">>,{encrypted,<<"tO3cjf0QyftBX4MGYR3DImgx3j/dCJF0JGagThL4oldVZ9fIaxD3yx1qQQRjJhkI">>},<<"/">>,'rabbit@DESKTOP-LSUNVM2',{amqp_adapter_info,{127,0,0,1},15674,{127,0,0,1},2029,<<"127.0.0.1:2029 -> 127.0.0.1:15674">>,{'Web STOMP',"1.1"},[{channels,1},{channel_max,1},{frame_max,0},{client_properties,[{<<"product">>,longstr,<<"STOMP client">>}]},{ssl,false}]},[]}]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5978.0> Supervisor {<0.5978.0>,rabbit_web_stomp_connection_sup}: child heartbeat_sender started (<0.5997.0>): {rabbit_heartbeat,start_heartbeat_sender,[#Port<0.1741>,10,#Fun<rabbit_web_stomp_handler.1.99051470>,{heartbeat_sender,unknown}]}
2022-01-14 17:54:16.960000+08:00 [info] <0.5978.0> Supervisor {<0.5978.0>,rabbit_web_stomp_connection_sup}: child heartbeat_receiver started (<0.5998.0>): {rabbit_heartbeat,start_heartbeat_receiver,[#Port<0.1741>,10,#Fun<rabbit_web_stomp_handler.2.99051470>,{heartbeat_receiver,unknown}]}
2022-01-14 17:54:16.961000+08:00 [info] <0.6000.0> Supervisor {<0.6000.0>,rabbit_amqqueue_sup}: child rabbit_amqqueue started (<0.6001.0>): {rabbit_prequeue,start_link,[{amqqueue,{resource,<<"/">>,queue,<<"stomp-subscription-6ziKQ1qJRLo3xWYBuEMFUg">>},false,true,none,[],none,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>},rabbit_classic_queue,#{}},declare,<0.5999.0>]}
2022-01-14 17:54:16.964000+08:00 [info] <0.6006.0> Supervisor {<0.6006.0>,rabbit_amqqueue_sup}: child rabbit_amqqueue started (<0.6007.0>): {rabbit_prequeue,start_link,[{amqqueue,{resource,<<"/">>,queue,<<"stomp-subscription-wHCqOT89hEirvLqK1rOGCQ">>},false,true,none,[],none,[],[],[],undefined,undefined,[],[],live,0,[],<<"/">>,#{user => <<"guest">>},rabbit_classic_queue,#{}},declare,<0.6005.0>]}
2022-01-14 17:55:29.959000+08:00 [info] <0.5826.0> closing STOMP connection <0.5826.0> (127.0.0.1:1659 -> 127.0.0.1:61613)
2022-01-14 17:55:35.953000+08:00 [info] <0.6061.0> Supervisor {<0.6061.0>,rabbit_stomp_client_sup}: child rabbit_stomp_heartbeat_sup started (<0.6062.0>): {rabbit_connection_helper_sup,start_link,[]}
2022-01-14 17:55:35.954000+08:00 [info] <0.6061.0> Supervisor {<0.6061.0>,rabbit_stomp_client_sup}: child rabbit_stomp_reader started (<0.6063.0>): {rabbit_stomp_reader,start_link,[<0.6062.0>,{acceptor,{0,0,0,0},61613},{stomp_configuration,<<"guest">>,<<"guest">>,false,false,false}]}
2022-01-14 17:55:35.955000+08:00 [info] <0.6063.0> accepting STOMP connection <0.6063.0> (127.0.0.1:2210 -> 127.0.0.1:61613)
2022-01-14 17:55:46.976000+08:00 [debug] <0.6007.0> Deleting auto-delete queue 'stomp-subscription-wHCqOT89hEirvLqK1rOGCQ' in vhost '/' because all of its consumers (1) were on a channel that was closed
2022-01-14 17:55:46.976000+08:00 [debug] <0.6072.0> Closing all channels from connection '127.0.0.1:2029 -> 127.0.0.1:15674' because it has been closed
2022-01-14 17:55:46.978000+08:00 [debug] <0.6001.0> Deleting auto-delete queue 'stomp-subscription-6ziKQ1qJRLo3xWYBuEMFUg' in vhost '/' because all of its consumers (1) were on a channel that was closed

[xman01111]

<script src="jquery.min.js"></script> <script src="stom.js"></script> <style> .box { width: 440px; float: left; margin: 0 20px 0 20px; }

    .box div,
    .box input {
        border: 1px solid;
        -moz-border-radius: 4px;
        border-radius: 4px;
        width: 100%;
        padding: 5px;
        margin: 3px 0 10px 0;
    }

    .box div {
        border-color: grey;
        height: 300px;
        overflow: auto;
    }

    div code {
        display: block;
    }

    #first div code {
        -moz-border-radius: 2px;
        border-radius: 2px;
        border: 1px solid #eee;
        margin-bottom: 5px;
    }

    #second div {
        font-size: 0.8em;
    }
</style>
<title>RabbitMQ Web STOMP Examples : Echo Server</title>
<link href="main.css" rel="stylesheet" type="text/css" />

RabbitMQ Web STOMP Examples > Echo Server

<div id="first" class="box">
    <h2>Received</h2>
    <div></div>
    <form><input autocomplete="off" value="Type here..."></input></form>
</div>

<div id="second" class="box">
    <h2>Logs</h2>
    <div></div>
</div>
<input type="text" value="" id="queueName"></input>
<button type="button" id="startSub" onclick="connect(1)">Strat</button>
<button type="button" id="startSub" onclick="stopSub()">Stop</button>

<script>
    var has_had_focus = false;
    var pipe = function (el_name, send) {
        var div = $(el_name + ' div');
        var inp = $(el_name + ' input');
        var form = $(el_name + ' form');
        var print = function (m, p) {
            p = (p === undefined) ? '' : JSON.stringify(p);
            div.append($("<code>").text(m + ' ' + p));
            div.scrollTop(div.scrollTop() + 10000);
        };
        if (send) {
            form.submit(function () {
                send(inp.val());
                inp.val('');
                return false;
            });
        }
        return print;
    }; 
    var client = null;
    var id=null;
    var id2=null;
    
    function stopSub()
    {
       id.unsubscribe();
       id2.unsubscribe();
    }

    function connect(isTry) 
    {
        var queueName='test';
        if( $('#queueName').val()!='')
        {
            queueName= $('#queueName').val();
        }
        if (client == null || isTry) {
            client = Stomp.client('ws://127.0.0.1:15674/ws'); 
        }
        client.debug = pipe('#second');
        var print_first = pipe('#first', function (data) 
        {
            client.send('/exchange/PmsHotelExchange/'+queueName, { "content-type": "text/plain" }, data);  
        });

        var on_connect = function (x) 
        {
            id = client.subscribe("/exchange/PmsHotelExchange/"+queueName, function (d) {  print_first(queueName+':=====>'+d.body); }); 
            id2 = client.subscribe("/exchange/PmsPublic/pmsInfo", function (d) {  print_first('pmsInfo:====>'+d.body); });
        }; 
        client.connect('guest', 'guest', on_connect, on_error, '/');  
        $('#first input').focus(function () {
            if (!has_had_focus) {
                has_had_focus = true;
                $(this).val("");
            }
        });
    }
    var on_error = function () 
    {
        console.log('error');
        setTimeout(() => {
            connect(true); 
        }, 5000);        
    }; 
</script>

[michaelklishin]

I will convert this issue to a GitHub discussion. Currently GitHub will automatically close and lock the issue even though your question will be transferred and responded to elsewhere. This is to let you know that we do not intend to ignore this but this is how the current GitHub conversion mechanism makes it seem for the users :(

[michaelklishin]

According to the log, a client closed its connection after 11 seconds. We cannot know why or what the problem is, but the closure was client-initiated.

[xman01111]

At first I suspected that there were too many server connections in the production environment. The production environment had 1200 connections and 1200 channels, 5000 queues, and 10 exchange, so I tried to reproduce the problem in the local environment and got the same results. When I set stomp.js' heartbeat to 3 seconds, the disconnection time became shorter. When there is only one connection stomp.js takes a long time except for the first time. After the reconnect, the debug message shows that the disconnection time becomes very regular. The same user was used for all the connections tested above.

[xman01111]

https://s3-cn-south-1.qiniucs.com/ccshis/test/ws.png?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=dK1tHUjy1Wo-vOJWzz_oqhCmEFhdSjajf7PhOqV1%2F20220119%2Fcn-south-1%2Fs3%2Faws4_request&X-Amz-Date=20220119T040316Z&X-Amz-Expires=599&X-Amz-Signature=56c71e7230994cf2d89f4d03aaab3746a67e5ca432ca16307775cb5298b4b721&X-Amz-SignedHeaders=host