Loading...
消息中间件之Apache Kafka(一)Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以收集并处理用户在网站中的所有动作流数据，以及物联网设备的采样信息。Kafka提供了消息订阅与发布的消息队列，一般用作系统间解耦、异步通信、削峰填谷等作用。同时Kafka又提供了Kafka Streaming...
消息中间件之RocketMQ(五)RocketMQ常见问题为什么要使用MQ？因为项目比较大，做了分布式系统，所有远程服务调用请求都是同步执行，经常出现问题，所以引入了MQ。解耦系统耦合度降低，没有强依赖关系，面向MQ编程，即使某个服务挂掉了，也不会影响其他服务。异步不需要同步执行远程调用，可以有效提高响应时间。削峰请求达到峰值后，后端service还可以保持固定消费速率，不会被压垮。多个MQ...
消息中间件之RocketMQ(四)RocketMQ 集群单Master模式只有一个Master节点。优点: 配置简单，方便部署。缺点: 这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用，不建议线上环境使用。多Master模式一个集群，没有Slave，全是Master，例如2个Master或者3个Master优点: 配置简单，单个Master宕机或重启维护对应用无影响，在...
消息中间件之RocketMQ(三)Offsetmessage queue是无限长的数组，一条消息进来下标就会长1，下标就是offset，消息在某个MessageQueue里的位置，通过offset的值可以定位到这条消息，或者指示Consumer从这条消息开始向后处理。minOffset当前下标最小值，也就是从哪里开始读。maxOffset当前下标最大值，也就是可以读到哪。maxOffset并...
消息中间件之RocketMQ(二)消息消费模式消息消费模式由消费者来决定，可以由消费者设置MessageModel来决定消费模式。消费模式默认为集群模式consumer.setMessageModel(MessageModel.BROADCASTING); //广播模式 consumer.setMessageModel(MessageModel.CLUSTERING); //集群模式对于...
消息中间件之RocketMQ(一)什么是消息队列消息队列是《数据结构》中先进先出的数据结构，在当前的架构中，作为中间件提供服务消息中间件功能应用解耦在SOA模型中，使业务之间不再强依赖，可以异步处理，A与B都通过中间件交流，即使有一方下线了，也可以在上线之后继续处理。流量削峰流量达到高峰的时候，通常使用限流算法来控制流量涌入系统，避免系统瘫痪。但是，这种方式损失了一部分请求，此时可以使用消息...
消息中间件之ActiveMQ(四)集群配置官方文档http://activemq.apache.org/clustering主备集群http://activemq.apache.org/masterslave.html| Master Slave Type | Requirements | Pros | Cons || :-: | :-: | :-: | :-: || Shared File...
Centos7多服务器挂载同一文件系统服务器端配置安装nfsrpm -qa |grep nfs yum install nfs-utils修改配置编辑或新建配置文件,添加要共享的客户端地址vi /etc/exports/opt/share 192.168.50.18(rw,no_root_squash) /opt/share 192.168.50.19(rw,no_root_squash) ...
消息中间件之ActiveMQ(三)NIO配置ActiveMQ默认配置的是tcp，使用的是bio:<transportConnector name="openwire" uri="tcp://0.0.0.0:616166 maximumConnections=1000&wireFormat.maxFrameSize=104857600"/&...
消息中间件之ActiveMQ(二)事务在创建session时,通过 connection.createSession(true, Session.SESSION_TRANSACTED);第一个参数传入true表示开启事务，开启事务之后，发送的消息只有在调用 session.commit();提交之后，才能被消费，可以逐条提交，也可以批量提交。当发生异常时，可以使用 session.rollb...
