#EMQ

windows下的activemq的使用记录

1、ActiveMq软件包下载  下载地址:ActiveMQ(apache.org)  https://activemq.apache.org/components/classic/download/   2、安装Java环境3、修改IP,供外网访问     把里面的IP从127...

Java消息队列--ActiveMq

1.下载安装 ActiveMq    activemq的官方下载地址:http://activemq.apache.org/download.html    本次选择apache-activemq-5.15.4-bin(需要JDK1.8)版本下载,还提供了Windows和Linux、Uni...
代码星球 ·2021-02-15

Spring整合ActiveMQ测试

--注意:使用IDEA创建maven普通项目还是聚合项目,都可以不用勾选,直接点next。       然后填入坐标和模块的名字 然后点击左上角的+号,选择web。 在新打开的页面下会显示web选项,这里的路径改为srcmainw...
代码星球 ·2021-02-14

ActiveMQ学习笔记(22)----ActiveMQ的优化和使用建议

  1.异步通信  2.一对多通信  3.做个系统的集成,同构,异构  4.作为RPC的替代  5.多个应用相互解耦  6.作为事件驱动架构的幕后支撑  7.为了提高性能的可伸缩性    1.网络拓扑结构,比如;嵌入、主从复制、网络连接。    2.transport协议    3.service的质量,比如...

ActiveMQ学习笔记(21)----ActiveMQ集成Tomcat

  WebConsole方式:直接访问ActiveMQ的管理页面:http://localhost:8161/admin,默认的用户名和密码是admin/admin。具体配置在conf/jetty.xml里面,这就是我们前面例子中一直使用的方式。  Hawtio-webManagementConsole方式:  默认用...

ActiveMQ学习笔记(20)----Consumer高级特性(二)

  JMSSelectors用在获取消息的时候,可以基于消息属性和Xpath语法对消息进行过滤。JMSSelectors有SQL92语义定义。以下是个Selectors的例子:  consumer=session.createConsumer(destination,"JMSType='car'ANDweight>...

ActiveMQ学习笔记(19)----Consumer高级特性(一)

  独有消费者:Queue中的消息是按照顺序被分发到consumer的,然而,当你有多个consumers同时从相同的queue中提取消息时,你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候,保证消息按照顺序处理是很重要的。例如:你可能不希望在插入订单操作结束之前执行更新这个订单的操作。  ActiveM...

ActiveMQ学习笔记(18)----Message高级特性(二)

  有些时候,我们需要传递Blob(BinaryLargeObjects)消息,在5.14之前,(5.12和5.13需要在jetty.xml中手动开启)可以按照如下的方式配置使用fileserver:  配置BLOBTansferPolicy,可以在发送方的连接URI上设置,如:tcp://localhost:6161...

ActiveMQ学习笔记(17)----Message高级特性(一)

  ActiveMQ支持很多消息属性,具体可以参考  http://activemq.apache.org/activemq-message-properties.html  常见得一些属性说明:  1.queue得消息默认是持久化得  2.消息得优先级默认是4.  3.消息发送时设置了时间戳。  4.消息的过期时间默...

ActiveMQ学习笔记(16)----Message Dispatch高级特性(二)

  ActiveMQ缺省支持批量确认消息,由于批量确认会提高性能,如果希望在应用程序中禁止经过优化的确认方式,可以采用以下几种方式:  1.在Connection的URI上启用OptimizedAcknowledgementsActiveMQConnectionFactoryfactory=newActiveMQCon...

ActiveMQ学习笔记(15)----Message Dispatch高级特性(一)

  ActiveMQ发送持久化消息的典型的厝里方式是:当消息的消费者准备就绪时,消息发送系统把存储的消息按批次发送给消费者,在发送完一个批次的消息后,指针的标记位置指向下一个批次的待发消息的位置,进行后续的发送操作。这是一种比较健壮和灵活的消息发送方式,但是大多数的情况下,消息的消费者不一定一直都处于这种理想的活跃状态...

ActiveMQ学习笔记(14)----Destination高级特性(二)

  虚拟Destination用来创建逻辑Destinations,客户端可以通过它来产生和消费消息,它会把消息映射到物理Destinations。ActiveMQ支持两种方式:  1.虚拟主题(VirtualTopics)  2.组合Destinations(CompositeDestinations)  Activ...

ActiveMQ学习笔记(13)----Destination高级特性(一)

  1.Wildcards用来支持名字分层体系,它不是JMS规范的一部分,是ActiveMQ的扩展。    ActiveMQ支持一下三种wildcards:    1.".":用于作为匹配路径上名字间的分隔符    2.“*":用于匹配路径上的任何名字(不递归)    3.”>“:用于递归的匹配任何以这个名字开始...

ActiveMQ学习笔记(12)----ActiveMQ的集群

  ActiveMQ支持Consumer对消息的高可靠性的负载均衡消费,如果一个Consumer死掉,该消息会转发到其他的Consumer消费的Queue。如果一个Consumer获得消息比其他Consumer快,那么他将获得更多的消息。因此推荐ActiveMQ的Broker和Client使用failover://tr...

ActiveMQ学习笔记(11)----ActiveMQ的动态网络连接

  ActiveMQ使用Multicast协议将一个Service和其他的Broker是我Service里连接起来。IPMulticast是一个被用于网络中传输数据到其他一组接收者的技术。Ipmuiticast传统的概念称为组地址,组地址是ip地址在ActiveMQbroker使用multicast协议去建立服务与远程...
首页上一页12345...下一页尾页