一、RabbitMQ 原理图 二、Rabbit 交换器讲解 1 Direct 交换器(发布与订阅 完全匹配) 1.2搭建环境 1.2.1创建项目 1.2.2修改全局配置文件 修改 Consumer 的配置文件 修改 Provider 的配置文件 1.3编写 Consumer 1.4编写 Provid ...
分类：
其他好文 时间：
2019-04-06 09:36:54
阅读次数：
151
主题交换机类型为：topic。 是直连交换机的一种。只是比直连交换机更灵活，在路由键上引入了通配符的概念 生产者 ： 消费者： ...
分类：
其他好文 时间：
2019-04-06 09:26:52
阅读次数：
108
环境准备 环境规格： python3.5 django2.0 django-simple-sso-0.14 环境安装： pip install django-simple-sso-0.14 环境说明： opstest01为django应用，作为服务端使用，端口8001 testsso为django应 ...
分类：
其他好文 时间：
2019-04-03 22:25:27
阅读次数：
787
问题 问题 用过 Kafka 的同学用过都知道，每个 Topic 一般会有很多个 partitions。为了使得我们能够及时消费消息，我们也可能会启动多个 Consumer 去消费，而每个 Consumer 又会启动一个或多个streams去分别消费 Topic 里面的数据。我们又知道，Kafka ...
分类：
其他好文 时间：
2019-04-02 10:32:06
阅读次数：
187
之前写过如何用服务器端的API代码来获取订阅某topic的所有consumer group，参见这里。使用服务器端的API需要用到kafka.admin.AdminClient类，但是这个类在0.11.0.0版本已经被标记为不推荐使用了，故目前最合适的方式还是通过客户端API：org.apache. ...
分类：
其他好文 时间：
2019-04-01 18:37:17
阅读次数：
281
函数式接口 参数类型 返回类型 抽象方法 描述 其他方法 Runnable 无 void run 作为无参数和返回值的动作运行 Supplier 无 T get 提供一个T类型的值 Consumer T void accept 处理一个T类型的值 andThen BiConsumer T，U voi... ...
分类：
编程语言 时间：
2019-03-27 18:23:24
阅读次数：
185
1、 Maven POM POM( Project Object Model，项目对象模型 ) 是 Maven 工程的基本工作单元，是一个XML文件，包含了项目的基本信息，用于描述项目如何构建，声明项目依赖，等等。 执行任务或目标时，Maven 会在当前目录中查找 POM。它读取 POM，获取所需的 ...
分类：
编程语言 时间：
2019-03-25 17:41:49
阅读次数：
219
最近遇到一个为问题，就是dubbo调用服务时有些超时，而有些却调用成功 大前提：dubbo的设置中已服务端的设置的超时时间为准 PS: 配置的覆盖规则：1) 方法级配置别优于接口级别，即小Scope优先 2) Consumer端配置 优于 Provider配置 优于 全局配置，最后是Dubbo Ha ...
分类：
其他好文 时间：
2019-03-23 00:20:11
阅读次数：
481
Kafka是一种高吞吐量的分布式发布订阅消息系统 1、优点：① 通过磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。② 高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息。③ 支持通过Kafka服务器和消费机集群来分区消息。④ 支持Hado ...
服务启动检查配置 默认check=true dubbo:reference check=“false” 关闭某个服务的启动时检查：(没有提供者时报错) dubbo:consumer check=“false” 关闭所有服务的启动时检查：(没有提供者时报错) 写在定义服务消费者一方 dubbo:reg ...
分类：
其他好文 时间：
2019-03-21 18:38:54
阅读次数：
173
