`
三问飞絮
  • 浏览: 320606 次
  • 性别: Icon_minigender_1
  • 来自: 厦门
社区版块
存档分类
最新评论

突然不发消息给ActiveMQ但能接收

 
阅读更多

        今天项目在联调过程中,ActiveMQ突然不好使了。在此之前一月内,项目组的人都没有去修改、重启过MQ服务。

        虽然现在知道是由于权限的问题导致只能收不能发(站在ActiveMQ角度是收不到,但可以发)。只是到现在还不知道原来没变过的代码,怎么以前可以用,现在却不行了???

       通过查询示例代码,发现有connectionFactory.setUserName("system");由此联想到,应该跟访问权限的设计有关系。

     查询activemq.home/conf/果然有activemq-security.xml,有关于安全方面的配置示例。查询资料,可以通过设置anonymousAccessAllowed="false"使得MQ不需要密码访问。

     去掉密码是不安全的,但之前没有设置过,真不知道怎么可以突然不行了。疑惑疑惑……

 

 

		<plugins>
			<!-- Configure authentication; Username, passwords and groups -->
			<simpleAuthenticationPlugin anonymousAccessAllowed="false">
				<users>
					<authenticationUser username="system" password="${activemq.password}"
						groups="users,admins"/>
					<authenticationUser username="user" password="${guest.password}"
						groups="users"/>
					<authenticationUser username="guest" password="${guest.password}" groups="guests"/>
				</users>
			</simpleAuthenticationPlugin>
        </plugins>

 

 

分享到:
评论

相关推荐

    springboot集成activemq实现消息接收demo

    配置完成后,我们创建一个`MessageReceiver`类来接收消息。这个类通常会实现`MessageListener`接口,这样可以监听消息队列中的新消息。下面是一个简单的`MessageReceiver`实现示例: ```java import org.spring...

    使用WebSocket协议接收ActiveMQ消息

    至于压缩包文件"activemq_ws_接收消息",其中可能包含示例代码、配置文件或者文档,帮助用户更好地理解如何在ActiveMQ中配置WebSocket接收消息。解压并研究这些文件将有助于实际操作中的实施。 总之,使用WebSocket...

    Spring+ActiveMQ消息队列+前台接收消息

    在Web应用中,前台接收消息通常涉及到AJAX轮询或者WebSocket技术。WebSocket提供双向通信,可以实现实时推送,但需要后端支持。对于不支持WebSocket的环境,可以使用Ajax轮询,定时向服务器请求新消息。 1. **Ajax...

    SpringBoot+ActiveMq+MQTT实现消息的发送和接收

    7. 测试与调试:编写测试用例,确保消息能正确发送和接收,同时监控ActiveMQ服务器以查看消息队列的状态。 在实际应用中,你可能还需要考虑消息的可靠性、顺序性、幂等性以及错误处理等复杂问题。例如,使用事务性...

    activemq 通过ajax发送接收消息简单例子

    在这个简单的例子中,我们将探讨如何利用Ajax与ActiveMQ交互,发送和接收消息。首先,你需要在服务器端设置一个ActiveMQ实例,可以通过下载并安装ActiveMQ来完成。安装完成后,启动ActiveMQ服务,这通常会开启一个...

    7道消息队列ActiveMQ面试题!

    在发布/订阅模式中,消息生产者发布消息到主题(Topic),多个消费者可以订阅该主题,接收消息。 2. ActiveMQ的存储机制和故障处理 ActiveMQ的存储机制包括非持久化消息和持久化消息两种方式。非持久化消息存储在...

    activeMQ收发工具.rar

    6. **消息生产者与消费者**:掌握如何使用ActiveMQ收发工具创建消息生产者发送消息,以及创建消息消费者接收消息。 7. **持久化与非持久化消息**:了解消息的持久性配置,这决定了消息在服务器重启后是否仍然可用。...

    activemq-cpp发送接收消息,消息过滤器

    在本文中,我们将深入探讨如何使用`activemq-cpp`库在C++环境中发送和接收消息,并利用消息过滤器来实现特定的消息处理。`activemq-cpp`是Apache ActiveMQ的一个C++客户端,它提供了与ActiveMQ服务器进行交互的能力...

    go语言实现使用activemq 收发消息

    启动该程序,你的Go应用就能连接到ActiveMQ,订阅并接收消息,同时也能发送消息到指定队列。 通过这种方式,Go语言可以很好地集成到基于ActiveMQ的消息传递系统中。了解Go的并发模型和错误处理机制,以及STOMP协议...

    activemq 接收文件流 C#

    4. 创建消费者:创建一个`IMessageConsumer`,它是接收消息的对象,通常会指定一个目的地(如队列或主题)。 5. 接收消息:调用消费者的消息接收方法,例如`Receive()`,这将阻塞直到有新消息到达。 6. 处理文件流:...

    消息队列activeMQ

    消息队列ActiveMQ允许应用程序通过发送和接收消息来进行通信,而不是直接调用彼此,从而简化了系统设计并提高了可扩展性。 ### 1. 消息队列基础概念 - **消息**:在ActiveMQ中,消息是数据传输的基本单元,通常...

    WebSocket协议接收ActiveMQ

    3. 订阅主题或队列:连接建立后,客户端可以订阅想要接收消息的主题或队列。 4. 数据交换:客户端和服务器之间可以通过发送和接收WebSocket帧来交换消息。ActiveMQ会将内部的消息格式转换为WebSocket帧,并反之亦然...

    java消息通信activemq

    在会话中,我们可以创建消息消费者、生产者以及发送和接收消息。 6. **消息生产者(MessageProducer)**:生产者负责将消息发送到目的地,如队列或主题。创建消息后,使用Session创建MessageProducer,然后调用其`...

    activeMQ发送消息返回消息

    在ActiveMQ中,发送和接收消息是一个核心功能,它允许应用程序之间进行异步通信,提高系统的可扩展性和解耦性。 在ActiveMQ中发送消息,通常涉及以下步骤: 1. **创建ConnectionFactory**:ConnectionFactory是...

    ActiveMQ消息发送接收封装实现及定时测试.

    实现了ActiveMQ的初步封装,比较适合新手入门学习,简单明了

    7道消息队列ActiveMQ面试题!.zip

    消息队列是一种异步通信机制,它允许应用程序之间通过发送和接收消息进行通信,而无需直接调用彼此。这种解耦特性可以提高系统的可扩展性和可靠性,因为消息生产者和消费者可以在不同的时间处理消息。 2. **...

    ActiveMQ发送和接收protobuf协议消息的实例(精心整理,亲测可用)

    在ActiveMQ中,我们可以利用protobuf的这种特性来高效地发送和接收消息。首先,你需要在项目的`src`目录下创建protobuf的定义文件(如`message.proto`),在这个文件中定义你想要传递的数据结构。例如: ```proto ...

    Springboot整合ActiveMQ,实现消息的发送接收功能源码

    为了接收消息,你需要定义一个监听器接口,如`MessageListener`,并实现`onMessage()`方法。Spring Boot会自动处理消息的接收并调用这个方法: ```java @JmsListener(destination = "myQueue") public void ...

    ActiveMQ消息过期时间设置和自动清除解决方案

    - **Message 过期则客户端不能接收**:当消息过期后,客户端将无法接收到这些过期的消息。 - **ttlCeiling**:表示过期时间的上限。例如,如果设置为30000毫秒(即30秒),那么任何通过程序设置的过期时间如果超过了...

Global site tag (gtag.js) - Google Analytics