ActiveMQ主题/订阅模式添加用户名、密码、IP的连接验证

拼搏现实的明天。 2022-05-13 07:28 340阅读 0赞

1.打开activemq资源包--找到credentials.properties打开后修改密码；

![70][]

![70 1][]

2.接下来修改你的Spring的相关生产者和消费者相关配置；

2.1生产者配置

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:context="http://www.springframework.org/schema/context"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
        xmlns:amq="http://activemq.apache.org/schema/core"
        xmlns:jms="http://www.springframework.org/schema/jms"
        xsi:schemaLocation="http://www.springframework.org/schema/beans   
            http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   
            http://www.springframework.org/schema/context   
            http://www.springframework.org/schema/context/spring-context-4.0.xsd
            http://www.springframework.org/schema/jms
            http://www.springframework.org/schema/jms/spring-jms-4.0.xsd
            http://activemq.apache.org/schema/core
            http://activemq.apache.org/schema/core/activemq-core-5.6.0.xsd">
    
        
                               
        <bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">  
            
            <property name="brokerURL" value="tcp://10.86.38.17:61616" />
            <property name="userName" value="super"></property>
            <property name="password" value="Rfid123456"></property> 
            <property name="useAsyncSend" value="true" /> 
            
            <property name="dispatchAsync" value="true"></property>
        </bean>	
        
        
    	
    	
        <bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate">
        	<property name="connectionFactory" ref="connectionFactory" />
    		<property name="defaultDestination" ref="deviceStateTopicDestination" />
    		
    		<property name="pubSubDomain" value="true" />
    		<property name="receiveTimeout" value="60000"/>
        </bean>
    	 
    	<context:component-scan base-package="com.zit.activemq" />
    	 
    	<bean id="deviceStateTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">  
            <constructor-arg>
                <value>deviceStateTopic</value>  
            </constructor-arg>  
        </bean>
        
         
        <bean id="rfidRecordTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">  
            <constructor-arg>
                <value>rfidRecordTopic</value>  
            </constructor-arg>  
        </bean>
    </beans>

2.2消费者配置

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:context="http://www.springframework.org/schema/context"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
        xmlns:amq="http://activemq.apache.org/schema/core"
        xmlns:jms="http://www.springframework.org/schema/jms"
        xsi:schemaLocation="http://www.springframework.org/schema/beans   
            http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   
            http://www.springframework.org/schema/context   
            http://www.springframework.org/schema/context/spring-context-4.0.xsd
            http://www.springframework.org/schema/jms
            http://www.springframework.org/schema/jms/spring-jms-4.0.xsd
            http://activemq.apache.org/schema/core
            http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd">
            
    	
    	<bean id="consumerConnectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">  
            <property name="brokerURL" value="tcp://10.86.38.17:61616" /> 
            <property name="userName" value="super"></property>
            <property name="password" value="Rfid123456"></property> 
            <property name="useAsyncSend" value="true" /> 
            
            <property name="dispatchAsync" value="true"></property>
        </bean>
    	
    	<bean id="deviceStateConsumer" class="com.zit.activemq.main.consumer.DeviceStateConsumer"></bean>
        
        <jms:listener-container destination-type="topic"  
            connection-factory="consumerConnectionFactory"  
            acknowledge="auto">  
            <jms:listener destination="deviceStateTopic" ref="deviceStateConsumer" />  
        </jms:listener-container>
        
        
        
    	<bean id="rfidRecordConsumer" class="com.zit.activemq.main.consumer.RfidRecordConsumer"></bean>
        
        <jms:listener-container destination-type="topic"  
            connection-factory="consumerConnectionFactory"  
            acknowledge="auto">  
            <jms:listener destination="rfidRecordTopic" ref="rfidRecordConsumer" />  
        </jms:listener-container>
        
        
    	<bean id="cameraRecordConsumer" class="com.zit.activemq.main.consumer.CameraRecordConsumer"></bean>
        
        <jms:listener-container destination-type="topic"  
            connection-factory="consumerConnectionFactory"  
            acknowledge="auto">  
            <jms:listener destination="cameraRecordTopic" ref="cameraRecordConsumer" />  
        </jms:listener-container>
        
    	<bean id="dbssRecordConsumer" class="com.zit.activemq.main.consumer.DbssRecordConsumer"></bean>
        <jms:listener-container destination-type="topic"  
            connection-factory="consumerConnectionFactory"  
            acknowledge="auto">  
            <jms:listener destination="dbssRecordTopic" ref="dbssRecordConsumer" />  
        </jms:listener-container>
    </beans>

[70]: /images/20220513/ddd0fd2184b843d585dbec1e77cdf23c.png
[70 1]: /images/20220513/856e88ee28c34dea86456310007d1140.png