-
高性能消息中间件Kafka实战(一)
kafka简介 Kafka是一种高吞吐量的分布式发布订阅消息系统，使用Scala编写。 对于熟悉JMS（Java Message Service）规范的同学来说，消息系统已经不是什么新概念了(例如ActiveMQ，RabbitMQ等)。 Kafka拥有作为一个消息系统应该具备的功能，但是确有着独特的设计。可以这样来说，Kafka借鉴了JMS规范的思想，但是确并没有完全遵循JMS规范。 kafka是…- 20
- 0
-
STM32学习笔记之二：三种BOOT启动方式的使用
不同设计场景中的三种BOOT启动方式选择 最近需要用到STM32系列的芯片来做一个项目，之前接触的都是51和430系列的单片机，初次接触ST的，发现ST与之前的所接触的单片机的不同之一在于：ST芯片在下载方式的选择以及程序的启动方式是需要设计开发人员自己选择的，而51和430系列的单片机都是系统默认选择好的，这个是我认为的和之前所接触的单片机最大的不同点之一了（个人观点，可能有偏差）。好了，废话不…- 61
- 0
-
flume-ng+Kafka+Storm+HDFS 实时系统搭建
以下是我的flume配置文件,有一些重要的配置项我都加了注释。 ############################################ # producer config ########################################### #agent section producer.sources = s producer.channels = c c1…- 9
- 0
-
SparkStreaming:SparkStreaming简介及架构,WordCount案例,Dstream入门,文件及自定义数据源,Kafka数据源（重点）,DStream创建转换输出,状态转化操作
文章目录 第1章 Spark Streaming概述 1.1 Spark Streaming是什么 1.2 Spark Streaming特点 1.3 SparkStreaming架构 第2章 Dstream入门 2.1 WordCount案例实操 2.2 WordCount解析 第3章 Dstream创建 3.1文件数据源 3.1.1 用法及说明 3.1.2 案例实操 3.2 RDD队列（了解）…- 3
- 0
-
Java使用RabbitMQ（七）–Routing
Routing 路由选择 前面的文章 介绍了，怎么广播消息到多个接收者，这一篇将怎么订阅消息的子集。 比如指定一个消费者只把 错误日志写入磁盘，另一个消费者仍然能够将所有的日志消息打印到屏幕上。 Binding 一个Binding描述的是交换机和队列之间的关系，比如描述 某个队列对这个交换机中的哪些消息感兴趣。 1channel.queueBind(queueName, EXCHANGE_NAME…- 4
- 0
-
Kafka 常用命令
Kafka 的主要工具类如下（包路径为： kafka.tool.*）： 大家更加版本，可自行查看： https://github.com/apache/kafka/tree/trunk/core/src/main/scala/kafka/tools 获取当前消费进度 bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list …- 8
- 0
-
AMQP-RabbitMQ/5/主题模式
5. 主题模式 Topics 根据主题接收消息 routing_key - 它必须是由英文点.分隔的单词列表 *可以替代一个单词。 ＃可以替换零个或多个单词。 图示 个人理解 与路由模式基本相同，不同的点只是路由模式需要Queue订阅的路由键与消息的路由键完全匹配，Exchange才会将消息发送给Queue。 而主题模式(Exchange类型为topic)，消费者在将Exchange与Queue绑…- 1
- 0
-
基于Python语言使用RabbitMQ消息队列（一）
介绍 RabbitMQ 是一个消息中间人（broker）: 它接收并且发送消息. 你可以把它想象成一个邮局: 当你把想要寄出的信放到邮筒里时, 你可以确定邮递员会把信件送到收信人那里. 在这个比喻中, RabbitMQ 就是一个邮筒, 同时也是邮局和邮递员 . 和邮局的主要不同点在于RabbitMQ不处理纸质信件, 而是 接收（accepts）, 存储（stores） 和转发（forwards）二…- 6
- 0
-
RabbitMQ-整合Spring AMQP实战
文章目录 RabbitAdmin RabbitTemplate SimpleMessageListenerContainer(消息监听容器；可以运行中, 动态修改) MessageListenerAdapter(消息监听适配器) MessageConverter(消息转换器) 1. RabbitAdmin 概述 可以把RabbitAdmin作为Spring的一个Bean，然后细粒度的操作Rabbi…- 12
- 0
-
RabbitMQ基本原理
MQ是一种消息队列 项目中需要对接Java系统,这里做一下总结。 RabbitMQ 消息走向流程 Producer 消息生产者，Consumer消息消费者，Exchagne交换机，Queue队列。 Producer负责将数据发送到Exchange中，Consumer负责从Queue中取消息。 Exchange绑定多个Queue 一个交换机可以和多个Qeueu绑定 有三类交换机，分别是Diredct…- 18
- 0
-
RabbitMQ三种分布式策略总结
规约： exchange 交换机 queue 队列 broker 中间服务器/服务器 cluster 集群 node 节点 route 路由 RabbitMQ可以通过三种方法部署分布式系统：集群、联盟（federation）和shovel。 集群通过连接多个机器组成单个逻辑中间服务器。机器之间通信要借助于Erlang的消息传输，要求集群中所有节点…- 15
- 0
-
docker安装RabbitMQ
rabbitMQ是一款开源的高性能消息中间件，最近项目要使用，于是使用docker搭建，快速方便。 一、获取镜像 使用docker search rabbitMq命令获取镜像列表，结果如下 2.使用docker pull docker.io/rabbitmq:3.8-management 拉取镜像，我们选择了STARS数最多的官方镜像，此处需要注意，默认rabbitmq镜像是不带web端管理插件的…- 4
- 0
-
19. Dubbo原理解析-通信层之暴露服务
Dubbo的整个远程通信层由exchange,transport, serialize exchange，信息交换层，封装请求响应模式，同步转异步，以Request, Response为中心，扩展接口为Exchanger, ExchangeChannel, HeaderExchangeHandler,ExchangeClient, ExchangeServer transport，网络传输…- 23
- 0
-
15. Dubbo原理解析-集群&容错之目录服务Directory
集群目录服务Directory， 代表多个Invoker, 可以看成List<Invoker>,它的值可能是动态变化的比如注册中心推送变更。集群选择调用服务时通过目录服务找到所有服务 Directory的接口定义 public interfaceDirectory<T> extends Node { ** ** // 服务类型 Class<T>getInt…- 11
- 0
-
1. Dubbo原理解析-Dubbo内核实现之SPI简单介绍
Dubbo采用链接地址微内核+插件体系，使得设计优雅，扩展性强。那所谓的微内核+插件体系是如何实现的呢！大家是否熟悉spi(service providerinterface)机制，即我们定义了服务接口标准，让厂商去实现（如果不了解spi的请谷歌百度下）, jdk通过ServiceLoader类实现spi机制的服务查找功能。 JDK实现spi服务查找: ServiceLoader 首先定义下示…- 6
- 0
-
dubbo zookeeper注册模型结构
流程说明： 服务提供者启动时 向/dubbo/com.foo.BarService/providers目录下写入自己的URL地址。 服务消费者启动时 订阅/dubbo/com.foo.BarService/providers目录下的提供者URL地址。 并向/dubbo/com.foo.BarService/consumers目录下写入自己的URL地址。 监控中心启动时 …- 6
- 0
-
使用Redis分布式锁处理并发，解决超卖问题
一、使用Apache ab模拟并发压测 1、压测工具介绍 $ ab -n 100 -c 100 http://www.baidu.com/ -n表示发出100个请求，-c模拟100个并发，相当是100个人同时访问。 还可以这样写： $ ab -t 60 -c 100 http://www.baidu.com/ -t表示60秒，-c是100个并发，会在连续60秒内不停的发出请求。 使用ab工具模拟多…- 8
- 0
-
SpringCloud微服务监控——admin（一）：admin服务端搭建并加入安全控制
在SpringCloud微服务中，有多个服务，要监控这些服务是否已经挂掉，这时可以使用admin来实现。代码如下： 基础工程的搭建何其他的微服务一样，不再赘述。 1）：在pom文件中加入依赖： 1<!-- eureka client start --> 2<dependency> 3 <groupId>org.springframework.cloud</…- 80
- 0
-
Spring-cloud 微服务架构搭建 01 – Eureka服务搭建及高可用配置
文章目录 Eureka简介 Eureka 服务特点 Eureka-Server 服务端搭建 Eureka-Client端进行服务注册 高可用配置 1. Eureka简介 在任何的分布式架构中，都需要去寻找服务的物理机器地址，我们称之为服务发现，Eureka就是解决这类问题的组件。它是类似于Zookeeper的服务注册中心组件，但Eureka保证了服务的高可用性，它自身的集群机制和服务保护机制是其核…- 10
- 0
-
微服务分布式事务实战（六）编写第二个微服务
（1）创建工程 springCloud分布式事务实战（六）编写第二个微服务 （2）添加 jar pom.xml 添加:springboot 父， mysql连接，(mybatis， spring-mybatis springboot ,阿里连接池) , 服务中心客户端。 1<project xmlns="http://maven.apache.org/POM/4.0.0"…- 0
- 0
-
微服务架构核心（三）- 微服务技术架构体系
微服务架构的名字里虽然有个"微"，但它涉及的整体架构体系可一点也不"微"，微服务架构除了业务代码的开发以外，还需要很多的支撑服务。 每个公司都有自己的微服务架构体系，虽然在细节上有很多不同，但是整体的思路是类似的，下图展示了一个比较成熟的微服务架构体系。 这个体系按照请求接入，由外到内的顺序，将整体架构分为接入层、网关层、业务服务层、支撑服务层、平台服务层和…- 29
- 0
-
ASP.NET Core微服务之基于Polly+AspectCore实现熔断与降级机制
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、熔断、降级与AOP 1.1 啥是熔断？ 在广义的解释中，熔断主要是指为控制股票、期货或其他金融衍生产品的交易风险，为其单日价格波动幅度规定区间限制，一旦成交价触及区间上下限，交易则自动中断一段时间(“熔即断”)，或就此“躺平”而不得超过上限或下限(“熔而不断”)。 而对于微服务来说，熔断就是我们常说的“保险丝”，意为当服务出现某些状…- 15
- 0
-
Spring Cloud构建微服务架构：服务容错保护（Hystrix断路器）【Dalston版】
前言 在前两篇《Spring Cloud构建微服务架构：服务容错保护（Hystrix服务降级）》和《Spring Cloud构建微服务架构：服务容错保护（Hystrix依赖隔离）》中，我们对Hystrix提供的服务降级和依赖隔离有了基本的认识。下面我们将继续说说Hystrix的另外一个重要元件：断路器。 断路器 断路器模式源于Martin Fowler的Circuit Breaker一文。“断路器…- 4
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×