代码编织梦想

ActiveMQ主从集群方案:Zookeeper集群+ Replicated LevelDB + ActiveMQ集群-爱代码爱编程

集群信息概览 Zookeeper端口ActiveMQweb端口ActiveMQ协议端口218181616161621828162616172183816361618先搭建Zookeeper集群 1)上传zookeeper-3.4.6.tar.gz到linux 2)解压:tar -xzf zookeeper-3.4.6.tar.gz 3)创建根目录:

ActiveMQ 任意文件写入漏洞(CVE-2016-3088)复现-爱代码爱编程

ActiveMQ 任意文件写入漏洞(CVE-2016-3088)复现 导语 ActiveMQ的web控制台分三个应用:admin、api和fileserver,其中admin是管理员页面,api是接口,fileserver是储存文件的接口。admin和api都需要登录后才能使用,fileserver无需登录。 fileserver是一个RES

消息队列简史-爱代码爱编程

1983年,Teknekron。 孟买26岁的工程师Vivek Ranadive设想一种软件总线,同年Teknekron诞生了。1985年,The Information Bus(TIB)。 用于高盛,用于解决金融交易。于是发布订阅模式(PubSub)诞生了,同时还诞生了世界上第一个现代消息队列软件:Teknekron的The Information Bu

rocketmq如何保证顺序消费-爱代码爱编程

1、方案一 很简单,问题产生的关键在于多个队列都有消息,我消费的时候又不知道哪个队列的消息是最新的。那么思路就有了,发消息的时候你要想保证有序性的话,就都给我发到一个queue上,然后消费的时候因为只有那一个queue上有消息且queue是FIFO,先进先出,所以正常消费就完了。 很完美。而且RocketMQ也给我们提供了这种发消息的时候选择queue的

MQ 系列之 ActiveMQ 高级特性-爱代码爱编程

1.1 异步投递 1.1.1 概述   ActiveMQ 支持同步、异步两种发送的模式将消息发送到 Broker,模式的选择对发送延时有巨大的影响。producer 能达到怎样的产出率(产出率=发送数据总量/时间)主要受发送延时的影响,使用异步发送可以显著的提高发送的性能。ActiveMQ 默认使用异步发送通的模式:除非明确指定使用同步发送的方式或者在

MQ 系列之 ActiveMQ 搭建 Zookeeper + Replicated LevelDB 集群-爱代码爱编程

1.1 简介 1.1.1 概述   从 ActiveMQ 5.9 开始,ActiveMQ 的集群实现方式取消了传统的 Masster-Slave 方式.,增加了基于 Zookeeper + LevelDB 的 Master-Slave 实现方式,从 5.9 版本后也是官网推荐。需要注意的是 LevelDB 存储尚不支持存储与“延迟”和“计划任务消息”关

Pulsar 社区周报| 2020-11-28 ~ 2020-12-04-爱代码爱编程

关于 Apache Pulsar Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存储分离架构设计,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐、低延时及高可扩展性等。 项目地址:http://github.com/apac

MQ 系列之 ActiveMQ 消息持久化机制-爱代码爱编程

1.1 简介 1.1.1 概述   为了避免意外宕机以后丢失信息,需要做到重启后可以恢复消息队列,消息系统一般都会采用持久化机制。ActiveMQ 的消息持久化机制有 JDBC,AMQ,KahaDB 和 LevelDB,无论使用哪种持久化方式,消息的存储逻辑都是一致的。就是在发送者将消息发送出去后,消息中心首先将消息存储到本地数据文件、内存数据库或者远

ActiveMQ反序列化漏洞(CVE-2015-5254)复现-爱代码爱编程

ActiveMQ 反序列化漏洞(CVE-2015-5254)复现 导语 Apache ActiveMQ是美国阿帕奇(Apache)软件基金会所研发的一套开源的消息中间件,它支持Java消息服务、集群、Spring Framework等。 Apache ActiveMQ 5.13.0之前5.x版本中存在安全漏洞,该漏洞源于程序没有限制可在代理中

MQ 系列之 ActiveMQ 传输协议-爱代码爱编程

1.1 简介 1.1.1 概述   ActiveMQ 支持的 client-broker 通讯协议有:TCP、NIO、UDP、SSL、Http(s)、VM。其中配置 Transport Connector 的文件在 activeMQ 安装目录的 conf/activemq.xml 中的 <transportConnectors> 标签之内。

Mac 直接下载或用homeberw下载与安装ActiveMQ-爱代码爱编程

1.首先在activemq官网下载压缩包 解压后进入/bin/macosx目录下 通过./activemq start命令启动 控制台出现Starting ActiveMQ Broker… 启动成功 在浏览器输入 127.0.0.1:8161/admin/ 默认的用户名和密码都是admin 如图启动成功 2.mac 使用Homebrew安装Ac

ActiveMQ 的使用方法-爱代码爱编程

原理图 Queue Producer 生产者:生产消息,发送端。 把jar包添加到工程中。使用5.11.2版本的jar包。 第一步:创建ConnectionFactory对象,需要指定服务端ip及端口号。 第二步:使用ConnectionFactory对象创建一个Connection对象。 第三步:开启连接,调用Connection对象的star

ActiveMQ 安装-爱代码爱编程

下载ActiveMQ 进入http://activemq.apache.org/ 安装环境 1、需要jdk 2、安装Linux系统。生产环境都是Linux系统。 安装步骤 第一步: 把ActiveMQ 的压缩包上传到Linux系统。 第二步:解压缩。 第三步:启动。 使用bin目录下的activemq命令启动: [root@localhost b

MQ 系列之 ActiveMQ 可靠性-爱代码爱编程

说到 ActiveMQ 可靠性不可不提持久性、事务以及签收,正是这三个保证了单机版 ActiveMQ 的可靠性 1.1 持久性 1.1.1 非持久 ☞ 概述 所谓非持久化就是在 ActiveMQ 凉凉之后,消息不会被保留下来。 ☞ 示例 /** * Created with IntelliJ IDEA. * * @author

ActiveMQ整合SpringBoot-爱代码爱编程

文章目录 ActiveMQ整合SpringBootpom.xmlapplication.yml配置文件ActiveMQ结构ActiveConfigProducerControllerqueue模式的消费者 QueueConsumerListenertopic模式的消费者 TopicConsumerListener ActiveMQ整合Sprin

Connection request timed out与Adding the specified count to the semaphore would cause it to excee问题排除-爱代码爱编程

一,问题描述 C#开发的控制系统、Oracle数据库,在00:13用户反馈系统宕机,连上服务器查看,发现日志不再打印,准备重启服务,但重启失败,服务一直在Stopping中无法中止,无奈之下重启服务器后正常。 二,问题排除: 查看控制系统日志,发现从前一天的22:15:10,开始断断续续出现数据库连接失败的错误。到00:04时,彻底无法连接,服务假死。

ActiveMQ 代码案例-爱代码爱编程

一、原生API pom依赖 生产者 package cn.enjoyedu.usemq; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; /** *类说明:

深度报告(69页附下载)| 蜂窝车联网(C-V2X)技术与产业发展态势前沿报告2020-中国通信学会-爱代码爱编程

建议PC端阅读,下载完整PDF全文, 请关注本公众号后台回复“ 201207 ” 下载

视频 | 为何我对小鹏NGP“半信半疑”-爱代码爱编程

小鹏NGP即将上线,想聊一聊我对它的惊叹与担忧。   NGP直译过来叫「高速自动导航驾驶」,和我们经常听到的「领航辅助」,其实是一回事。最早被小鹏汽车NGP种草是在今年5月,它功能更强大,简单说就是在车辆车机上设定导航后,车辆会自动按照导航线路巡航、自动换道、自动进出匝道。   毫不夸张的讲,NGP背后的技术,是当下量产汽车搭载的自动

JMS消息事务-爱代码爱编程

消息事务 消息事务,是保证消息传递原子性的一个重要特征,和JDBC的事务特征类似。 一个事务性发送,其中一组消息要么能够全部保证到达服务器,要么都不到达服务器。 生产者、消费者与消息服务器直接都支持事务性; ActionMQ的事务主要偏向在生产者的应用。 一、生产者事务: 方式一: /** * 加入事务 */ @Test public void