RUI个人博客 首页>>MQ

关于ActiveMQ传输messageObject的异常

关于ActiveMQ传输messageObject的异常

前言碎语 博主在做spring batch分片远程处理时用到ActiveMQ来通讯,但分片对象总是不能正确传输,查看ActiveMQ中的消息详情发现抛如下异常:Failed to build body from content. Serializable class not available to broke,原来为了安全考虑,ActiveMQ默认不接受自定义的序列化对象,需要将自定义的加入到受信任的列表。 具体解决方式 1.服务端可加入参数-Dorg.apache.activemq.SERIALIZABLE_PACKAGES=* 启动,脚本在bin目录...

阅读全文 »

spring boot通过MQ消费log4j2的日志

spring boot通过MQ消费log4j2的日志

前言碎语 当系统的并发比较高的时候,日志的处理输出也是一种性能的开销负担,所以,选择一个中间件来处理消费日志必不可少!下面是spring boot整合log42结合spring amqp来消费处理系统日志的实例,只需要简单的三步 1.添加相关jar依赖 dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactIdexclusionsexclusiongroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-logging/artifactId...

阅读全文 »

AMQP协议模型高阶概述

AMQP协议模型高阶概述

AMQP是什么 AMQP(高级消息队列协议)是一个网络协议。它支持符合要求的客户端应用(application)和消息中间件代理(messaging middleware broker)之间进行通信。 消息代理和他们所扮演的角色 消息代理(message brokers)从发布者(publishers)亦称生产者(producers)那儿接收消息,并根据既定的路由规则把接收到的消息发送给处理消息的消费者(consumers)。 由于AMQP是一个网络协议,所以这个过...

阅读全文 »

RabbitMQ的Web管理与监控

RabbitMQ的Web管理与监控

RabbitMQ提供了完善的管理和监控工具 1、management plugin rabbitmq-management plugin提供HTTP API来管理和监控RabbitMQ Server,具体包含如下功能: 删除、生成、列表,包括:exchanges,queues,bindings,users,virtual hosts and permissions。 监视 queue 长度,每个 channel的message rates ,每个连接的data rates,等等。 发送和接收messages。 监控Erlang processes,file descriptors,memory use。 导出/导出object definitions to JSON。 强...

阅读全文 »