专门做特卖的网站,下载手机微信,网站去掉后缀html,大连手机网站制作1、activemq.xml置文件新增如下内容 2、mqttx测试发送#xff1a; 主题#xff08;配置的模糊匹配#xff0c;为了并发#xff09;#xff1a;VirtualTopic/device/sendData/12312 3、mqtt接收的结果 4、程序处理 package comimport cn.hutool.core.date.DateUtil; imp…1、activemq.xml置文件新增如下内容 2、mqttx测试发送 主题配置的模糊匹配为了并发VirtualTopic/device/sendData/12312 3、mqtt接收的结果 4、程序处理 package comimport cn.hutool.core.date.DateUtil; import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil;import org.apache.activemq.ActiveMQMessageAudit; import org.apache.activemq.command.ActiveMQBytesMessage; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component;import javax.jms.Message; import java.nio.charset.Charset; import java.util.Date;Component public class MessageHandler {JmsListener(destination deviceQueue.receiveDate, containerFactory queueListener, concurrency 1-3)public void deviceMessage(ActiveMQBytesMessage message) {System.out.println(StrUtil.str(message.getContent().getData(), Charset.defaultCharset()));System.out.println(################### message ###################);} }控制台打印 全量的activemq.xml !--Licensed to the Apache Software Foundation (ASF) under one or morecontributor license agreements. See the NOTICE file distributed withthis work for additional information regarding copyright ownership.The ASF licenses this file to You under the Apache License, Version 2.0(the License); you may not use this file except in compliance withthe License. You may obtain a copy of the License athttp://www.apache.org/licenses/LICENSE-2.0Unless required by applicable law or agreed to in writing, softwaredistributed under the License is distributed on an AS IS BASIS,WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.See the License for the specific language governing permissions andlimitations under the License. -- !-- START SNIPPET: example -- beansxmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd!-- Allows us to use system properties as variables in this configuration file --bean classorg.springframework.beans.factory.config.PropertyPlaceholderConfigurerproperty namelocationsvaluefile:${activemq.conf}/credentials.properties/value/property/bean!--The broker element is used to configure the ActiveMQ broker.--broker xmlnshttp://activemq.apache.org/schema/core brokerNamelocalhost dataDirectory${activemq.data}destinationPolicypolicyMappolicyEntriespolicyEntry topic !-- The constantPendingMessageLimitStrategy is used to preventslow topic consumers to block producers and affect other consumersby limiting the number of messages that are retainedFor more information, see:http://activemq.apache.org/slow-consumer-handling.html--pendingMessageLimitStrategyconstantPendingMessageLimitStrategy limit1000//pendingMessageLimitStrategy/policyEntry/policyEntries/policyMap/destinationPolicy!--The managementContext is used to configure how ActiveMQ is exposed inJMX. By default, ActiveMQ uses the MBean server that is started bythe JVM. For more information, see:http://activemq.apache.org/jmx.html--managementContextmanagementContext createConnectorfalse//managementContext!--Configure message persistence for the broker. The default persistencemechanism is the KahaDB store (identified by the kahaDB tag).For more information, see:http://activemq.apache.org/persistence.html--persistenceAdapterkahaDB directory${activemq.data}/kahadb//persistenceAdapter!--The systemUsage controls the maximum amount of space the broker willuse before disabling caching and/or slowing down producers. For more information, see:http://activemq.apache.org/producer-flow-control.html--systemUsagesystemUsagememoryUsagememoryUsage percentOfJvmHeap70 //memoryUsagestoreUsagestoreUsage limit100 gb//storeUsagetempUsagetempUsage limit50 gb//tempUsage/systemUsage/systemUsage!--The transport connectors expose ActiveMQ over a given protocol toclients and other brokers. For more information, see:http://activemq.apache.org/configuring-transports.html--transportConnectors!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --transportConnector nameopenwire uritcp://0.0.0.0:61616?maximumConnections1000amp;wireFormat.maxFrameSize104857600/transportConnector nameamqp uriamqp://0.0.0.0:5672?maximumConnections1000amp;wireFormat.maxFrameSize104857600/transportConnector namestomp uristomp://0.0.0.0:61613?maximumConnections1000amp;wireFormat.maxFrameSize104857600/transportConnector namemqtt urimqtt://0.0.0.0:1883?maximumConnections1000amp;wireFormat.maxFrameSize104857600/transportConnector namews uriws://0.0.0.0:61614?maximumConnections1000amp;wireFormat.maxFrameSize104857600//transportConnectors!-- destroy the spring context on shutdown to stop jetty --shutdownHooksbean xmlnshttp://www.springframework.org/schema/beans classorg.apache.activemq.hooks.SpringContextHook //shutdownHooks!-- 消息订阅 --destinationInterceptorsvirtualDestinationInterceptorvirtualDestinationscompositeTopic nameVirtualTopic.device.sendData.*forwardToqueue physicalNamedeviceQueue.receiveDate //forwardTo/compositeTopic/virtualDestinations/virtualDestinationInterceptor/destinationInterceptorspluginssimpleAuthenticationPluginusersauthenticationUser username${activemq.username} password${activemq.password} groupsusers,admins/!--authenticationUser usernameuser passwordpassword groupsusers/authenticationUser usernameguest passwordpassword groupsguests/ --/users/simpleAuthenticationPlugin/plugins/broker!--Enable web consoles, REST and Ajax APIs and demosThe web consoles requires by default login, you can disable this in the jetty.xml fileTake a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details--import resourcejetty.xml//beans !-- END SNIPPET: example --