本教程主要说明kafka0.10.2.1集群的安装；hdp-02,hdp-03,hdp-04是我集群节点的名称，修改配置文件，请根据自身的节点名称进行修改。 基本概念 Broker ： 安装Kafka服务的那台集群就是一个broker（broker的id要全局唯一） Producer ：消息的生产者 ...
分类：
其他好文 时间：
2018-12-06 22:14:58
阅读次数：
147
迭代器（减少代码量增强可读性）和生成器（只能遍历一次）：遵循迭代器协议，就是生成可迭代对象 生产者和消费者模型：可触发生成器运行的方法 直接调用next方法 用系统next+生成器的方法 send yield（可执行多次）相当于return（只执行一次）控制的函数返回值， x=yield的另一个特性 ...
分类：
编程语言 时间：
2018-12-05 23:21:14
阅读次数：
344
Ribbon 在 SpringCloud 中的使用 1.构建 Eureka 注册中心 smart-platform-eureka1 （1）导入jar包 （2）添加eureka配置 application.yml (3) 编写启动类 2.构建生产者服务 smart-platform-base （1）导 ...
分类：
其他好文 时间：
2018-12-05 21:49:10
阅读次数：
220
什么是AMQP? AMQP 中包含的主要元素 生产者（Producer）：向Exchange发布消息的应用。 消费者（Consumer）：从消息队列queue中消费消息的应用。 消息队列（Message Queue）：服务器组件，用于保存消息，直到发送给消费者。 Queue：消息载体；每个消息都会被 ...
分类：
其他好文 时间：
2018-12-05 20:56:47
阅读次数：
321
安装RabbitMQ RabbitMQ是用Erlang开发的，所以需要先安装Erlang环境，在这里下载对应系统的Erlang安装包进行安装 点击这里下载对应平台的RabbitMQ安装包进行安装 编写生产者和消费者 Spring对RabbitMQ已经进行了封装，正常使用中，会使用Spring集成，第 ...
分类：
其他好文 时间：
2018-12-05 20:55:22
阅读次数：
222
生产者消费者模式是多线程中最为常见的模式：生产者线程(一个或多个)生成面包放进篮子里(集合或数组)，同时，消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗。虽然它们任务不同，但处理的资源是相同的，这体现的是一种线程间通信方式。
分类：
编程语言 时间：
2018-12-04 20:07:11
阅读次数：
183
生产者消费者模式是多线程中最为常见的模式：生产者线程(一个或多个)生成面包放进篮子里(集合或数组)，同时，消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗。虽然它们任务不同，但处理的资源是相同的，这体现的是一种线程间通信方式。 本文将先说明单生产者单消费者的情况，之后再说明多生产者多消费者 ...
分类：
编程语言 时间：
2018-12-04 11:29:42
阅读次数：
232
介绍 主要演示生产者和消费如何传递消息的 生产者 消费者 注：在消费者最后设置channel.basicConsume时，第二个参数代表是否需要自动回复，即如果是true,不论消费成功还是失败，即使抛出异常，该条消息也会从消息队列中删除，所以对于消息准确性要求教高的业务场景，可以设置为false,只 ...
分类：
其他好文 时间：
2018-12-03 12:45:18
阅读次数：
182
介绍 注：没有注册中心，总共只分为三个角色，product,server,customer。 Queue 消息队列，等同于rocketmq中的topic Exchange 生产者产生的消息并不是直接发送给消息队列Queue的，而是要经过Exchange（交换器），由Exchange再将消息路由到一个 ...
分类：
其他好文 时间：
2018-12-03 12:44:46
阅读次数：
194
前言 上篇我们学习了rabbitmq的作用以及直连交换机的代码实现，这篇我们继续看如何用代码实现扇形交换机和主题交换机 一、扇形交换机 1.生产者 2.消费者 Consumer1 Cosumer2 先启动Consumer1，Consumer2，再启动LogProducer。结果如下： LogProd ...
分类：
其他好文 时间：
2018-12-02 22:35:54
阅读次数：
184
