Kafka是一个分布式的Streaming处理平台，Kafka可以用于数据库中数据的导入导出，也可以用于实时流的处理，但是Kafka最核心的功能就是作为分布式的消息中间件。 Kafka集群是由多个Broker Server组成的，消息的发送者称为Producer，消息的消费者称为Consumer，t ...
分类：
其他好文 时间：
2019-09-08 22:43:34
阅读次数：
161
总体介绍 承接着我们的springmvc+mybatis+mysql初级高级课程，以Dept部门模块做一个微服务通用案例Consumer消费者（Client）通过REST调用Provider提供者（Server）提供的服务 Maven的分包分模块架构复习 一个简单的Maven模块结构是这样的： sp ...
分类：
其他好文 时间：
2019-09-08 20:05:05
阅读次数：
73
创建三个Maven Project： dubbo-service：公共模块，包括服务接口（packaging：jar） dubbo-service-impl：服务提供方，提供服务接口的具体实现，需要依赖dubbo-service（packaging：jar） dubbo-consumer：服务调用方 ...
分类：
其他好文 时间：
2019-09-08 11:19:21
阅读次数：
73
本地测试环境： dubbo 2.6.0 springboot 2.1.7 JDK 1.8 Zookeeper 3.5.5 pom关键依耐： 1.provider(提供者) 1.1 启动类注解 1.2 服务实现类 1.3 配置文件(yml) 2.consumer(消费者) 2.1 启动类注解 2.2 ...
分类：
编程语言 时间：
2019-09-05 22:56:59
阅读次数：
787
三、如何保证消息的顺序性 拆分多个queue，每个queue一个consumer，就是多一些queue而已，确实是麻烦点；或者就一个queue但是对应一个consumer，然后这个consumer内部用内存队列做排队，然后分发给底层不同的worker来处理 写入一个partition中的数据一定是有 ...
分类：
其他好文 时间：
2019-09-03 09:14:07
阅读次数：
117
前言 RabbitMQ六种队列模式-简单队列RabbitMQ六种队列模式-工作队列 [本文]RabbitMQ六种队列模式-发布订阅RabbitMQ六种队列模式-路由模式RabbitMQ六种队列模式-主题模式 上文我们了解了 RabbitMQ 六种队列模式中的简单队列，代码也是非常的简单，比较容易理解 ...
分类：
其他好文 时间：
2019-09-02 19:40:59
阅读次数：
200
1个partition只能被同组的一个consumer消费，同组的consumer则起到均衡效果 消费者多于partition topic： test 只有一个partition创建一个topic——test， 在g2组中启动两个consumer， 消费者数量为2大于partition数量1，此时p ...
分类：
其他好文 时间：
2019-09-01 17:00:39
阅读次数：
90
pom.xml: 创建连接的工具类： Producer类： 运行结果，看下这个队列: 模拟Get message： Consumer跟 Producer基本类似: 运行后的结果： ...
分类：
编程语言 时间：
2019-09-01 14:40:22
阅读次数：
93
git clone <url> [< 目录名 >] -- 从远程拷到本地 来的命令 git branch -a -- 查看远程分支和 本地分支情况 git branch -- 查看本地分支 git branch 分支名 origin/ 远程分支名 -- 新建本地分支，与远程分支 名一一对应 git ...
分类：
其他好文 时间：
2019-08-31 18:56:59
阅读次数：
75
概述 消息队列比作一个存放消息的容器，需要使用消息的时候可以取出消息供自己使用。是分布式中重要的组件，使用消息队列主要是为了通过异步处理提高系统性能和削锋、降低系统耦合性。（注意消费信息顺序问题，可能出现消费失败，或者一个queue多个consumer也会导致消息被消费顺序不对，一定要保证消息被消费 ...
分类：
其他好文 时间：
2019-08-31 16:55:54
阅读次数：
128
