Thiết kế website giá rẻ

Question

hi i’m koeran student and i got a problem while developing 1:1 chatting.
I spent almost a week to try to solve the problem, but ultimately couldn’t resolve it.
let me show you the problem i got.

I’ve deployed a total of 4 containers on an EC2 instance using Docker Compose (spring boot, redis, rabbitmq, postgresql). The inbound rule of the instance has been opened for port 8080, and currently, an Elastic IP address is assigned to the instance.

After connecting to the EC2 instance and installing all necessary modules, including Docker Compose, and running the build and docker-compose commands, all containers are functioning correctly.

However, when trying to test the Stomp API on an APIC website, it fails to connect to the endpoint (“/ws”) I configured.

I think the reason why the Stomp connection is not working is because the IP address might be incorrect. Could you please check if the IP address of RabbitMQ is configured correctly?

@Configuration
@EnableWebSocketMessageBroker
@RequiredArgsConstructor
public class StompConfig implements WebSocketMessageBrokerConfigurer {

    @Value("${spring.rabbitmq.host}")
    private String rabbitmqHost; // this is container's name

    @Value("${spring.rabbitmq.username}")
    private String rabbitmqUsername; // guest

    @Value("${spring.rabbitmq.password}")
    private String rabbitmqPassword; // guest

    private final ChatAuthInterceptor chatAuthInterceptor;

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry
                .addEndpoint("/ws")
                .setAllowedOriginPatterns("*");
                // .withSockJS();
    }

    // STOMP 에서 사용하는 메세지 브로커 설정
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableStompBrokerRelay("/queue", "/topic", "/exchange", "/amq/queue") // 구독 url

                .setClientLogin(rabbitmqUsername) // guest
                .setClientPasscode(rabbitmqPassword) // guest

                .setSystemLogin(rabbitmqUsername) // guest
                .setSystemPasscode(rabbitmqPassword) // guest

                .setRelayHost(rabbitmqHost) // facefriend_rabbitmq
                .setRelayPort(61613)

                .setVirtualHost("/");

        registry.setPathMatcher(new AntPathMatcher("."));
        registry.setApplicationDestinationPrefixes("/pub"); // 발행 url
    }

    @Override
    public void configureClientInboundChannel(ChannelRegistration registration) {
        registration.interceptors(chatAuthInterceptor);
    }
}

@Configuration
@EnableRabbit
public class RabbitConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitmqHost; // facefriend_rabbitmq // this is container's name

    @Value("${spring.rabbitmq.port}")
    private int rabbitmqPort; // 5672

    @Value("${spring.rabbitmq.username}")
    private String rabbitmqUsername; // guest

    @Value("${spring.rabbitmq.password}")
    private String rabbitmqPassword; // guest

    @Value("${rabbitmq.queue.name}")
    private String queueName; // chat.queue

    @Value("${rabbitmq.exchange.name}")
    private String exchangeName; // chat.exchange

    @Value("${rabbitmq.routing.key}")
    private String routingKey; // room.* (* will be replaced by member's id)

    // Queue 등록
    @Bean
    public Queue queue() {
        return new Queue(queueName, true);
    }

    // Exchange 등록
    @Bean
    public DirectExchange directExchange() {
        return new DirectExchange(exchangeName, true, false, null);
    }

    // Exchange 와 Queue 바인딩
    @Bean
    public Binding binding(Queue queue, DirectExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with(routingKey);
    }

    // MessageConverter 커스텀을 위해 Bean 새로 등록
    @Bean
    public RabbitTemplate rabbitTemplate() {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
        rabbitTemplate.setMessageConverter(jsonMessageConverter());
        rabbitTemplate.setRoutingKey(routingKey);
        return rabbitTemplate;
    }

    // 스프링이 자동 주입하는 ConnectionFactory 사용하지 않기 위함
    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory factory = new CachingConnectionFactory();
        factory.setHost(rabbitmqHost);
        factory.setPort(rabbitmqPort);
        factory.setUsername(rabbitmqUsername);
        factory.setPassword(rabbitmqPassword);
        return factory;
    }

    // LocalDateTime serialize 를 위해
    @Bean
    public Jackson2JsonMessageConverter jsonMessageConverter() {
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, true);
        objectMapper.registerModule(dateTimeModule());

        Jackson2JsonMessageConverter converter = new Jackson2JsonMessageConverter(objectMapper);
        return converter;
    }

    @Bean
    public Module dateTimeModule() {
        return new JavaTimeModule();
    }
}

I’ll show you the logs of each container.
enter image description here

rabbitmq container

Starting broker...2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>
2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>  node           : rabbit@57d64adb5ae5
2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>  home dir       : /var/lib/rabbitmq
2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>  config file(s) : /etc/rabbitmq/conf.d/10-defaults.conf
2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>  cookie hash    : 4bBGEUORqVoHc9xzQgcQTg==
2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>  log(s)         : <stdout>
2024-04-29 08:38:34.123373+00:00 [info] <0.230.0>  data dir       : /var/lib/rabbitmq/mnesia/rabbit@57d64adb5ae5
2024-04-29 08:38:39.511228+00:00 [info] <0.230.0> Running boot step pre_boot defined by app rabbit
2024-04-29 08:38:39.511340+00:00 [info] <0.230.0> Running boot step rabbit_global_counters defined by app rabbit
2024-04-29 08:38:39.511913+00:00 [info] <0.230.0> Running boot step rabbit_osiris_metrics defined by app rabbit
2024-04-29 08:38:39.512158+00:00 [info] <0.230.0> Running boot step rabbit_core_metrics defined by app rabbit
2024-04-29 08:38:39.512816+00:00 [info] <0.230.0> Running boot step rabbit_alarm defined by app rabbit
2024-04-29 08:38:39.520354+00:00 [info] <0.299.0> Memory high watermark set to 1534 MiB (1609326592 bytes) of 3836 MiB (4023316480 bytes) total
2024-04-29 08:38:39.532312+00:00 [info] <0.301.0> Enabling free disk space monitoring (disk free space: 24874184704, total memory: 4023316480)
2024-04-29 08:38:39.532420+00:00 [info] <0.301.0> Disk free limit set to 50MB
2024-04-29 08:38:39.536580+00:00 [info] <0.230.0> Running boot step code_server_cache defined by app rabbit
2024-04-29 08:38:39.536790+00:00 [info] <0.230.0> Running boot step file_handle_cache defined by app rabbit
2024-04-29 08:38:39.537493+00:00 [info] <0.304.0> Limiting to approx 1048479 file handles (943629 sockets)
2024-04-29 08:38:39.537673+00:00 [info] <0.305.0> FHC read buffering: OFF
2024-04-29 08:38:39.537737+00:00 [info] <0.305.0> FHC write buffering: ON
2024-04-29 08:38:39.538540+00:00 [info] <0.230.0> Running boot step worker_pool defined by app rabbit
2024-04-29 08:38:39.538645+00:00 [info] <0.282.0> Will use 2 processes for default worker pool
2024-04-29 08:38:39.538708+00:00 [info] <0.282.0> Starting worker pool 'worker_pool' with 2 processes in it
2024-04-29 08:38:39.539803+00:00 [info] <0.230.0> Running boot step database defined by app rabbit
2024-04-29 08:38:39.540482+00:00 [info] <0.230.0> Node database directory at /var/lib/rabbitmq/mnesia/rabbit@57d64adb5ae5 is empty. Assuming we need to join an existing cluster or initialise from scratch...
2024-04-29 08:38:39.540568+00:00 [info] <0.230.0> Configured peer discovery backend: rabbit_peer_discovery_classic_config
2024-04-29 08:38:39.540645+00:00 [info] <0.230.0> Will try to lock with peer discovery backend rabbit_peer_discovery_classic_config
2024-04-29 08:38:39.541106+00:00 [info] <0.230.0> All discovered existing cluster peers:
2024-04-29 08:38:39.541203+00:00 [info] <0.230.0> Discovered no peer nodes to cluster with. Some discovery backends can filter nodes out based on a readiness criteria. Enabling debug logging might help troubleshoot.
2024-04-29 08:38:39.544233+00:00 [notice] <0.44.0> Application mnesia exited with reason: stopped
2024-04-29 08:38:39.713550+00:00 [info] <0.230.0> Waiting for Mnesia tables for 30000 ms, 9 retries left
2024-04-29 08:38:39.713720+00:00 [info] <0.230.0> Successfully synced tables from a peer
2024-04-29 08:38:39.714926+00:00 [notice] <0.283.0> Feature flags: attempt to enable `stream_sac_coordinator_unblock_group`...
2024-04-29 08:38:39.791351+00:00 [notice] <0.283.0> Feature flags: `stream_sac_coordinator_unblock_group` enabled
2024-04-29 08:38:39.791521+00:00 [notice] <0.283.0> Feature flags: attempt to enable `restart_streams`...
2024-04-29 08:38:39.858448+00:00 [notice] <0.283.0> Feature flags: `restart_streams` enabled
2024-04-29 08:38:39.858847+00:00 [info] <0.230.0> Waiting for Mnesia tables for 30000 ms, 9 retries left
2024-04-29 08:38:39.859210+00:00 [info] <0.230.0> Successfully synced tables from a peer
2024-04-29 08:38:39.869551+00:00 [info] <0.230.0> Waiting for Mnesia tables for 30000 ms, 9 retries left
2024-04-29 08:38:39.870216+00:00 [info] <0.230.0> Successfully synced tables from a peer
2024-04-29 08:38:39.870293+00:00 [info] <0.230.0> Peer discovery backend rabbit_peer_discovery_classic_config does not support registration, skipping registration.
2024-04-29 08:38:39.872325+00:00 [info] <0.230.0> Will try to unlock with peer discovery backend rabbit_peer_discovery_classic_config
2024-04-29 08:38:39.881787+00:00 [info] <0.230.0> Running boot step tracking_metadata_store defined by app rabbit
2024-04-29 08:38:39.882517+00:00 [info] <0.480.0> Setting up a table for connection tracking on this node: tracked_connection
2024-04-29 08:38:39.882642+00:00 [info] <0.480.0> Setting up a table for per-vhost connection counting on this node: tracked_connection_per_vhost
2024-04-29 08:38:39.882770+00:00 [info] <0.480.0> Setting up a table for per-user connection counting on this node: tracked_connection_per_user
2024-04-29 08:38:39.882853+00:00 [info] <0.480.0> Setting up a table for channel tracking on this node: tracked_channel
2024-04-29 08:38:39.882925+00:00 [info] <0.480.0> Setting up a table for channel tracking on this node: tracked_channel_per_user
2024-04-29 08:38:39.887377+00:00 [info] <0.230.0> Running boot step networking_metadata_store defined by app rabbit
2024-04-29 08:38:39.887528+00:00 [info] <0.230.0> Running boot step feature_flags defined by app rabbit
2024-04-29 08:38:39.887706+00:00 [info] <0.230.0> Running boot step codec_correctness_check defined by app rabbit
2024-04-29 08:38:39.887765+00:00 [info] <0.230.0> Running boot step external_infrastructure defined by app rabbit
2024-04-29 08:38:39.887848+00:00 [info] <0.230.0> Running boot step rabbit_event defined by app rabbit
2024-04-29 08:38:39.888064+00:00 [info] <0.230.0> Running boot step rabbit_registry defined by app rabbit
2024-04-29 08:38:39.888197+00:00 [info] <0.230.0> Running boot step rabbit_auth_mechanism_amqplain defined by app rabbit
2024-04-29 08:38:39.888682+00:00 [info] <0.230.0> Running boot step rabbit_auth_mechanism_cr_demo defined by app rabbit
2024-04-29 08:38:39.889833+00:00 [info] <0.230.0> Running boot step rabbit_auth_mechanism_plain defined by app rabbit
2024-04-29 08:38:39.889973+00:00 [info] <0.230.0> Running boot step rabbit_exchange_type_direct defined by app rabbit
2024-04-29 08:38:39.890127+00:00 [info] <0.230.0> Running boot step rabbit_exchange_type_fanout defined by app rabbit
2024-04-29 08:38:39.890233+00:00 [info] <0.230.0> Running boot step rabbit_exchange_type_headers defined by app rabbit
2024-04-29 08:38:39.890354+00:00 [info] <0.230.0> Running boot step rabbit_exchange_type_topic defined by app rabbit
2024-04-29 08:38:39.890442+00:00 [info] <0.230.0> Running boot step rabbit_mirror_queue_mode_all defined by app rabbit
2024-04-29 08:38:39.890521+00:00 [info] <0.230.0> Running boot step rabbit_mirror_queue_mode_exactly defined by app rabbit
2024-04-29 08:38:39.890589+00:00 [info] <0.230.0> Running boot step rabbit_mirror_queue_mode_nodes defined by app rabbit
2024-04-29 08:38:39.890927+00:00 [info] <0.230.0> Running boot step rabbit_priority_queue defined by app rabbit
2024-04-29 08:38:39.890983+00:00 [info] <0.230.0> Priority queues enabled, real BQ is rabbit_variable_queue
2024-04-29 08:38:39.891072+00:00 [info] <0.230.0> Running boot step rabbit_queue_location_client_local defined by app rabbit
2024-04-29 08:38:39.891184+00:00 [info] <0.230.0> Running boot step rabbit_queue_location_min_masters defined by app rabbit
2024-04-29 08:38:39.891259+00:00 [info] <0.230.0> Running boot step rabbit_queue_location_random defined by app rabbit
2024-04-29 08:38:39.891331+00:00 [info] <0.230.0> Running boot step kernel_ready defined by app rabbit
2024-04-29 08:38:39.891370+00:00 [info] <0.230.0> Running boot step rabbit_sysmon_minder defined by app rabbit
2024-04-29 08:38:39.891536+00:00 [info] <0.230.0> Running boot step rabbit_epmd_monitor defined by app rabbit
2024-04-29 08:38:39.892568+00:00 [info] <0.488.0> epmd monitor knows us, inter-node communication (distribution) port: 25672
2024-04-29 08:38:39.893279+00:00 [info] <0.230.0> Running boot step guid_generator defined by app rabbit
2024-04-29 08:38:39.898438+00:00 [info] <0.230.0> Running boot step rabbit_node_monitor defined by app rabbit
2024-04-29 08:38:39.898914+00:00 [info] <0.492.0> Starting rabbit_node_monitor (in ignore mode)
2024-04-29 08:38:39.899112+00:00 [info] <0.230.0> Running boot step delegate_sup defined by app rabbit
2024-04-29 08:38:39.899767+00:00 [info] <0.230.0> Running boot step rabbit_memory_monitor defined by app rabbit
2024-04-29 08:38:39.900037+00:00 [info] <0.230.0> Running boot step rabbit_fifo_dlx_sup defined by app rabbit
2024-04-29 08:38:39.900545+00:00 [info] <0.230.0> Running boot step core_initialized defined by app rabbit
2024-04-29 08:38:39.900605+00:00 [info] <0.230.0> Running boot step rabbit_channel_tracking_handler defined by app rabbit
2024-04-29 08:38:39.901774+00:00 [info] <0.230.0> Running boot step rabbit_connection_tracking_handler defined by app rabbit
2024-04-29 08:38:39.901870+00:00 [info] <0.230.0> Running boot step rabbit_definitions_hashing defined by app rabbit
2024-04-29 08:38:39.901983+00:00 [info] <0.230.0> Running boot step rabbit_exchange_parameters defined by app rabbit
2024-04-29 08:38:39.902347+00:00 [info] <0.230.0> Running boot step rabbit_mirror_queue_misc defined by app rabbit
2024-04-29 08:38:39.902766+00:00 [info] <0.230.0> Running boot step rabbit_policies defined by app rabbit
2024-04-29 08:38:39.903232+00:00 [info] <0.230.0> Running boot step rabbit_policy defined by app rabbit
2024-04-29 08:38:39.903342+00:00 [info] <0.230.0> Running boot step rabbit_queue_location_validator defined by app rabbit
2024-04-29 08:38:39.903436+00:00 [info] <0.230.0> Running boot step rabbit_quorum_memory_manager defined by app rabbit
2024-04-29 08:38:39.903522+00:00 [info] <0.230.0> Running boot step rabbit_stream_coordinator defined by app rabbit
2024-04-29 08:38:39.903816+00:00 [info] <0.230.0> Running boot step rabbit_vhost_limit defined by app rabbit
2024-04-29 08:38:39.904232+00:00 [info] <0.230.0> Running boot step rabbit_mgmt_reset_handler defined by app rabbitmq_management
2024-04-29 08:38:39.904319+00:00 [info] <0.230.0> Running boot step rabbit_mgmt_db_handler defined by app rabbitmq_management_agent
2024-04-29 08:38:39.904367+00:00 [info] <0.230.0> Management plugin: using rates mode 'basic'
2024-04-29 08:38:39.904620+00:00 [info] <0.230.0> Running boot step recovery defined by app rabbit
2024-04-29 08:38:39.906940+00:00 [info] <0.230.0> Running boot step empty_db_check defined by app rabbit
2024-04-29 08:38:39.907039+00:00 [info] <0.230.0> Will seed default virtual host and user...
2024-04-29 08:38:39.907219+00:00 [info] <0.230.0> Adding vhost '/' (description: 'Default virtual host', tags: [])
2024-04-29 08:38:39.909723+00:00 [info] <0.230.0> Inserted a virtual host record {vhost,<<"/">>,[],
2024-04-29 08:38:39.909723+00:00 [info] <0.230.0>                                       #{description =>
2024-04-29 08:38:39.909723+00:00 [info] <0.230.0>                                             <<"Default virtual host">>,
2024-04-29 08:38:39.909723+00:00 [info] <0.230.0>                                         tags => []}}
2024-04-29 08:38:39.941412+00:00 [info] <0.537.0> Making sure data directory '/var/lib/rabbitmq/mnesia/rabbit@57d64adb5ae5/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L' for vhost '/' exists
2024-04-29 08:38:39.946296+00:00 [info] <0.537.0> Setting segment_entry_count for vhost '/' with 0 queues to '2048'
2024-04-29 08:38:39.951273+00:00 [info] <0.537.0> Starting message stores for vhost '/'
2024-04-29 08:38:39.951561+00:00 [info] <0.547.0> Message store "628WB79CIFDYO9LJI6DKMI09L/msg_store_transient": using rabbit_msg_store_ets_index to provide index
2024-04-29 08:38:39.955059+00:00 [info] <0.537.0> Started message store of type transient for vhost '/'
2024-04-29 08:38:39.955342+00:00 [info] <0.551.0> Message store "628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent": using rabbit_msg_store_ets_index to provide index
2024-04-29 08:38:39.956444+00:00 [warning] <0.551.0> Message store "628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent": rebuilding indices from scratch
2024-04-29 08:38:39.958765+00:00 [info] <0.537.0> Started message store of type persistent for vhost '/'
2024-04-29 08:38:39.958935+00:00 [info] <0.537.0> Recovering 0 queues of type rabbit_classic_queue took 11ms
2024-04-29 08:38:39.959038+00:00 [info] <0.537.0> Recovering 0 queues of type rabbit_quorum_queue took 0ms
2024-04-29 08:38:39.959167+00:00 [info] <0.537.0> Recovering 0 queues of type rabbit_stream_queue took 0ms
2024-04-29 08:38:39.964677+00:00 [info] <0.230.0> Created user 'guest'
2024-04-29 08:38:39.969513+00:00 [info] <0.230.0> Successfully set user tags for user 'guest' to [administrator]
2024-04-29 08:38:39.976397+00:00 [info] <0.230.0> Successfully set permissions for user 'guest' in virtual host '/' to '.*', '.*', '.*'
2024-04-29 08:38:39.976533+00:00 [info] <0.230.0> Running boot step rabbit_observer_cli defined by app rabbit
2024-04-29 08:38:39.977158+00:00 [info] <0.230.0> Running boot step rabbit_looking_glass defined by app rabbit
2024-04-29 08:38:39.977272+00:00 [info] <0.230.0> Running boot step rabbit_core_metrics_gc defined by app rabbit
2024-04-29 08:38:39.978334+00:00 [info] <0.230.0> Running boot step background_gc defined by app rabbit
2024-04-29 08:38:39.978519+00:00 [info] <0.230.0> Running boot step routing_ready defined by app rabbit
2024-04-29 08:38:39.978577+00:00 [info] <0.230.0> Running boot step pre_flight defined by app rabbit
2024-04-29 08:38:39.978651+00:00 [info] <0.230.0> Running boot step notify_cluster defined by app rabbit
2024-04-29 08:38:39.978746+00:00 [info] <0.230.0> Running boot step networking defined by app rabbit
2024-04-29 08:38:39.978843+00:00 [info] <0.230.0> Running boot step definition_import_worker_pool defined by app rabbit
2024-04-29 08:38:39.978933+00:00 [info] <0.282.0> Starting worker pool 'definition_import_pool' with 2 processes in it
2024-04-29 08:38:39.979243+00:00 [info] <0.230.0> Running boot step cluster_name defined by app rabbit
2024-04-29 08:38:39.979361+00:00 [info] <0.230.0> Initialising internal cluster ID to 'rabbitmq-cluster-id-TunZ_QWIW38gjEuu9OJ9Og'
2024-04-29 08:38:39.981998+00:00 [info] <0.230.0> Running boot step direct_client defined by app rabbit
2024-04-29 08:38:39.982203+00:00 [info] <0.230.0> Running boot step rabbit_maintenance_mode_state defined by app rabbit
2024-04-29 08:38:39.982279+00:00 [info] <0.230.0> Creating table rabbit_node_maintenance_states for maintenance mode status
2024-04-29 08:38:39.988640+00:00 [info] <0.230.0> Running boot step rabbit_management_load_definitions defined by app rabbitmq_management
2024-04-29 08:38:39.988872+00:00 [info] <0.589.0> Resetting node maintenance status
2024-04-29 08:38:40.025347+00:00 [info] <0.648.0> Management plugin: HTTP (non-TLS) listener started on port 15672
2024-04-29 08:38:40.025635+00:00 [info] <0.676.0> Statistics database started.
2024-04-29 08:38:40.025769+00:00 [info] <0.675.0> Starting worker pool 'management_worker_pool' with 3 processes in it
2024-04-29 08:38:40.047349+00:00 [info] <0.689.0> rabbit_stomp: default user 'guest' enabled
2024-04-29 08:38:40.049616+00:00 [info] <0.708.0> started STOMP TCP listener on [::]:61613
2024-04-29 08:38:40.053926+00:00 [info] <0.712.0> Prometheus metrics: HTTP (non-TLS) listener started on port 15692
2024-04-29 08:38:40.054244+00:00 [info] <0.589.0> Ready to start client connection listeners
2024-04-29 08:38:40.058245+00:00 [info] <0.756.0> started TCP listener on [::]:5672
 completed with 5 plugins.
2024-04-29 08:38:40.265093+00:00 [info] <0.589.0> Server startup complete; 5 plugins started.
2024-04-29 08:38:40.265093+00:00 [info] <0.589.0>  * rabbitmq_prometheus
2024-04-29 08:38:40.265093+00:00 [info] <0.589.0>  * rabbitmq_stomp
2024-04-29 08:38:40.265093+00:00 [info] <0.589.0>  * rabbitmq_management
2024-04-29 08:38:40.265093+00:00 [info] <0.589.0>  * rabbitmq_management_agent
2024-04-29 08:38:40.265093+00:00 [info] <0.589.0>  * rabbitmq_web_dispatch
2024-04-29 08:38:40.390590+00:00 [info] <0.9.0> Time to start RabbitMQ: 12773511 us
2024-04-29 08:38:42.569849+00:00 [info] <0.760.0> accepting AMQP connection <0.760.0> (172.20.0.5:40836 -> 172.20.0.2:5672)
2024-04-29 08:38:42.638746+00:00 [info] <0.760.0> connection <0.760.0> (172.20.0.5:40836 -> 172.20.0.2:5672) has a client-provided name: connectionFactory#42130a5c:0
2024-04-29 08:38:42.646383+00:00 [info] <0.760.0> connection <0.760.0> (172.20.0.5:40836 -> 172.20.0.2:5672 - connectionFactory#42130a5c:0): user 'guest' authenticated and granted access to vhost '/'
2024-04-29 08:38:43.272630+00:00 [info] <0.781.0> accepting STOMP connection <0.781.0> (172.20.0.5:54648 -> 172.20.0.2:61613)
2024-04-29 08:38:43.342459+00:00 [warning] <0.781.0> AMQP 0-9-1 client call timeout was 70000 ms, is updated to a safe effective value of 130000 ms

spring boot container

2024-04-29T18:09:42.527+09:00  INFO 1 --- [MessageBroker-1] o.s.w.s.c.WebSocketMessageBrokerStats    : WebSocketSession[0 current WS(0)-HttpStream(0)-HttpPoll(0), 0 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(0)-CONNECTED(0)-DISCONNECT(0)], stompBrokerRelay[1 sessions, ReactorNettyTcpClient[reactor.netty.tcp.TcpClientConnect@18a129b8] (available), processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], outboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], sockJsScheduler[pool size = 2, active threads = 1, queued tasks = 0, completed tasks = 1]
2024-04-29T18:39:42.528+09:00  INFO 1 --- [MessageBroker-1] o.s.w.s.c.WebSocketMessageBrokerStats    : WebSocketSession[0 current WS(0)-HttpStream(0)-HttpPoll(0), 0 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(0)-CONNECTED(0)-DISCONNECT(0)], stompBrokerRelay[1 sessions, ReactorNettyTcpClient[reactor.netty.tcp.TcpClientConnect@18a129b8] (available), processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], outboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], sockJsScheduler[pool size = 2, active threads = 1, queued tasks = 0, completed tasks = 2]
2024-04-29T19:09:42.529+09:00  INFO 1 --- [MessageBroker-1] o.s.w.s.c.WebSocketMessageBrokerStats    : WebSocketSession[0 current WS(0)-HttpStream(0)-HttpPoll(0), 0 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(0)-CONNECTED(0)-DISCONNECT(0)], stompBrokerRelay[1 sessions, ReactorNettyTcpClient[reactor.netty.tcp.TcpClientConnect@18a129b8] (available), processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], outboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], sockJsScheduler[pool size = 2, active threads = 1, queued tasks = 0, completed tasks = 3]
2024-04-29T19:39:42.529+09:00  INFO 1 --- [MessageBroker-1] o.s.w.s.c.WebSocketMessageBrokerStats    : WebSocketSession[0 current WS(0)-HttpStream(0)-HttpPoll(0), 0 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(0)-CONNECTED(0)-DISCONNECT(0)], stompBrokerRelay[1 sessions, ReactorNettyTcpClient[reactor.netty.tcp.TcpClientConnect@18a129b8] (available), processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], outboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], sockJsScheduler[pool size = 2, active threads = 1, queued tasks = 0, completed tasks = 4]
2024-04-29T20:09:42.530+09:00  INFO 1 --- [MessageBroker-1] o.s.w.s.c.WebSocketMessageBrokerStats    : WebSocketSession[0 current WS(0)-HttpStream(0)-HttpPoll(0), 0 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(0)-CONNECTED(0)-DISCONNECT(0)], stompBrokerRelay[1 sessions, ReactorNettyTcpClient[reactor.netty.tcp.TcpClientConnect@18a129b8] (available), processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], outboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], sockJsScheduler[pool size = 2, active threads = 1, queued tasks = 0, completed tasks = 5]
2024-04-29T20:39:42.530+09:00  INFO 1 --- [MessageBroker-1] o.s.w.s.c.WebSocketMessageBrokerStats    : WebSocketSession[0 current WS(0)-HttpStream(0)-HttpPoll(0), 0 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(0)-CONNECTED(0)-DISCONNECT(0)], stompBrokerRelay[1 sessions, ReactorNettyTcpClient[reactor.netty.tcp.TcpClientConnect@18a129b8] (available), processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], outboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0], sockJsScheduler[pool size = 2, active threads = 1, queued tasks = 0, completed tasks = 6]

i omit postgresql container, redis container.

here are some capture image testing STOMP connection in APIC website
enter image description here

Thiết kế website giá rẻ

Danh mục

Rabbitmq STOMP direct exchange using docker compose, AWS EC2, spring boot