生产者: # !/usr/bin/env python # -*- coding: utf-8 -*- import pika # 创建连接对象 connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhos ...
分类：
其他好文 时间：
2019-12-07 01:30:09
阅读次数：
105
知识点 基于 Server-Sent Event 工作方式，Web 即时通信 Redis 包 发布订阅功能的使用 flask 快速入门，常用对象实例方法函数 Vuejs 列表页面自动渲染 效果图 代码段 app.py 主文件 import datetime from flask import Fla ...
分类：
其他好文 时间：
2019-12-06 21:30:08
阅读次数：
115
kafka基础架构 什么是kafka？ Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。 1.什么是消息队列？ 2.使用消息队列的好处 1）解耦 允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。 2）可恢复性 系统的一部分组件失效时，不会影响 ...
分类：
其他好文 时间：
2019-12-06 00:15:17
阅读次数：
124
在很多互联网应用系统中，请求处理异步化是提升系统性能一种常用的手段，而基于消息系统的异步处理由于具备高可靠性、高吞吐量的特点，因而在并发请求量比较高的互联网系统中被广泛应用。与此同时，这种方案也带来了调用链路处理上的问题，因为大部分应用请求都会要求同步响应实时处理结果，而由于请求的处理过程已经通过消息异步解耦，所以整个调用链路就变成了异步链路，此时请求链路的发起者如何同步拿到响应结果，就需要进行额外的系统设计考虑。
分类：
其他好文 时间：
2019-12-04 18:41:32
阅读次数：
116
一、Redis简介 Redis是一款基于key-value的高性能NoSQL数据库，开源免费，遵守BSD协议。支持string（字符串） 、 hash（哈希） 、list（列表） 、 set（集合） 、 zset（有序集合）等数据结构，除此之外还提供了键过期、发布订阅、Lua脚本、事务、流水线（Pi ...
分类：
其他好文 时间：
2019-11-28 23:17:56
阅读次数：
192
初识 Kafka 什么是 Kafka Kafka 是由 公司开发的，它是一个分布式的，支持多分区、多副本，基于 Zookeeper 的分布式消息流平台，它同时也是一款开源的 基于发布订阅模式的消息引擎系统 。 Kafka 的基本术语 消息：Kafka 中的数据单元被称为 ，也被称为记录，可以把它看作 ...
分类：
其他好文 时间：
2019-11-28 13:00:01
阅读次数：
54
对于消息的传递有两种类型： 一种是点对点的，即一个生产者和一个消费者一一对应； 另一种是发布/ 订阅模式，即一个生产者产生消息并进行发送后，可以由多个消费者进 行接收。 特点介绍： 点到点模型点对点传递模型：生产者发送消息到一个特定的队列（Queue）中，而消费者从一个消息队列中得到消息，如下图所示 ...
分类：
其他好文 时间：
2019-11-27 13:51:10
阅读次数：
116
1、 Redis支持消息的订阅与发布 Redis的消息订阅支持：先订阅后发布 订阅：subscribe c1 c2 发布：publish c2 hello-redis 支持通配符的订阅：psubscribe new* 实际开发中没用，RabbitMQ 2、Redis对于事务支持 Redis对于事务也 ...
分类：
其他好文 时间：
2019-11-25 23:35:49
阅读次数：
69
RabbitMQ使用以及原理解析 RabbitMQ是一个由erlang开发的AMQP(Advanved Message Queue)的开源实现;在RabbitMQ官网上主要有这样的模块信息, Work queues消息队列,Publish/Subscribe发布订阅服务,Routing, Topic ...
分类：
其他好文 时间：
2019-11-24 15:37:03
阅读次数：
84
简介 最近开发的项目中，kafka用的比较多，为了方便梳理，从今天起准备记录一些关于kafka的文章，首先，当然是如何安装kafka了。 Apache Kafka是分布式发布-订阅消息系统。 Apache Kafka与传统消息系统相比，有以下不同： 它被设计为一个分布式系统，易于向外扩展； 它同时为 ...
分类：
其他好文 时间：
2019-11-24 12:12:50
阅读次数：
64
