-
Kafka实战－实时日志统计流程
1.概述 在《Kafka实战－简单示例》一文中给大家介绍来Kafka的简单示例，演示了如何编写Kafka的代码去生产数据和消费数据，今天给大家介绍如何去整合一个完整的项目，本篇博客我打算为大家介绍Flume＋Kafka＋Storm的实时日志统计，由于涉及的内容较多，这里先给大家梳理一个项目的运用这些技术的流程。下面是今天的内容目录： 项目流程 Flume Kafka Storm 下面开始今天的内容…- 3
- 0
-
Spring Boot整合Kafka
Kafka是一个分布式的、可分区的、可复制的消息系统，下面是Kafka的几个基本术语： Kafka将消息以topic为单位进行归纳； 将向Kafka topic发布消息的程序成为producers； 将预订topics并消费消息的程序成为consumer； Kafka以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个broker。 producers通过网络将消息发送到Kafka集群，集…- 17
- 0
-
C# 操作rabbitmq（二）
接着上一篇继续分析rabbitmq的使用，此篇介绍rabbitmq的publish/Subcribe 一、 Exchange rabbitmq建议消息的producer不要直接的把消息发送给queue，而是把消息发送给Exchange。 Exchange一边接收来自producer的消息，一边将消息push给queue。 rabbitmq提供了四种exchange type： direct ：第三…- 1
- 0
-
AMQP-RabbitMQ/2/工作队列
2. 工作队列 Work queues Distributing tasks among workers 消息将发送给c1或者c2 个人理解 生产者定义Queue，并向该队列发送消息 多个消费者可以从指定的同一个Queue中读取消息。每条消息只会发送给其中某一个消费者。 生产者 1package com.futao.springmvcdemo.mq.rabbit.workqueue; 2 3imp…- 9
- 0
-
基于Python语言使用RabbitMQ消息队列（三）
发布/订阅 前面的教程中我们已经创建了一个工作队列。在一个工作队列背后的假设是每个任务恰好会传递给一个工人。在这一部分里我们会做一些完全不同的东西——我们会发送消息给多个消费者。这就是所谓的“发布/订阅”模式。 为了解释这种模式，我们将会构建一个简单的日志系统。它包含两个程序——第一个产生日志消息，第二个接收并把他们打印出来。 在我们的日志系统中，每一个接收程序的正在运行的拷贝都会获知消息，那样我…- 17
- 0
-
分布式Session的几种实现方式
一。分布式Session的几种实现方式 1.基于数据库的Session共享 2.基于NFS共享文件系统 3.基于memcached 的session，如何保证 memcached 本身的高可用性？ 基于resin/tomcat web容器本身的session复制机制 基于TT/Redis 或 jbosscache 进行 session 共享。 基于cookie 进行session共享 或者是： 一…- 13
- 0
-
RabbitMQ基本概念
RabbitMQ基本概念 RabbitMQ简介 RabbitMQ的特点 RabbitMQ核心概念 Producer(生产者) 和 Consumer(消费者) Exchange(交换器) Queue(消息队列) Broker（消息中间件的服务节点） RabbitMQ简介 RabbitMQ是采用Erlang语言实现AMQP(Advanced Message Queuing Protocol）的消息中间…- 29
- 0
-
windows下安装rabbitMQ
博客地址：博客地址 本文转自：https://www.cnblogs.com/ericli-ericli/p/5902270.html 本文转自：https://www.cnblogs.com/ericli-ericli/p/5902270.html rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。它遵循Mozilla Public License开源协议，采用 E…- 7
- 0
-
14. Dubbo原理解析-集群&容错之Cluster
Dubbo作为一个分布式的服务治理框架，提供了集群部署，路由，软负载均衡及容错机制 下图描述了dubbo调用过程中的对于集群，负载等的调用关系。 Cluster 将Directory中的多个Invoker伪装成一个Invoker, 对上层透明，包含集群的容错机制 Cluster接口定义 @SPI(FailoverCluster.NAME) public interface Cluster …- 5
- 0
-
SpringBoot+zk+dubbo架构实践（三）：部署Dubbo-admin管理平台
上一篇：SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper 前言 1我们的架构实践已经进行一半了，今天这波操作比较轻松哦。同样我们完成两件事情。 21、Dubbo Git下载（2.6.0版本） 32、dubbo-admin安装和验证 4 再次声明一下：本系列架构实践不做深入探讨，主旨是带领大家能够快速踏入微服务架构门槛，能够轻松的搭建一套属于自己的…- 13
- 0
-
初识Dubbo 系列之3-Dubbo 快速启动
快速启动 (+) (#) Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。 1 如果不想使用Spring配置，而希望通过API的方式进行调用（不推荐），请参见：API配置 (+) 1 链接地址服务提供者 (#) 完整安装步骤，请参见：示例提供者安装 (+) 1 定义服务…- 27
- 0
-
Apache 开源的curator 基于Zookeeper实现分布式锁以及源码分析
前一段时间，我发表了一篇关于Redis实现分布式锁 分布式环境下利用Redis实现分布式锁，今天我带领大家熟悉用zookeeper实现分布式锁。 在学习分布式锁之前，让我们想一想，在什么业务场景下会用到分布式锁以及设计分布式锁要注意什么？ 分布式锁介绍 1、在什么业务场景中会使用到分布式锁 当多个客户端访问服务器上同一个资源的时候，需要保证数据的一致性，比如秒杀系统，举个栗子： 某件商品在系统中的…- 12
- 0
-
ZooKeeper分布式锁实现java例子，附完整可运行源代码
本原创入门教程，涵盖ZooKeeper核心内容，通过实例和大量图表，结合实战，帮助学习者理解和运用，任何问题欢迎留言。 目录： zookeeper介绍与核心概念 安装和使用 ZooKeeper分布式锁实现 ZooKeeper框架Curator分布式锁实现及源代码分析 zookeeper 开发实战（java客户端） 分布式锁有多种实现方式，比如通过数据库、redis都可实现。作为分布式协同工具Zoo…- 55
- 0
-
Redisson实现Redis分布式锁的N种姿势
前几天发的一篇文章《Redlock：Redis分布式锁最牛逼的实现》，引起了一些同学的讨论，也有一些同学提出了一些疑问，这是好事儿。本文在讲解如何使用Redisson实现Redis普通分布式锁，以及Redlock算法分布式锁的几种方式的同时，也附带解答这些同学的一些疑问。 Redis几种架构 Redis发展到现在，几种常见的部署架构有： 单机模式； 主从模式； 哨兵模式； 集群模式； 我们首先基于…- 58
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day10 用户管理(图片验证码 手机验证码)
用户管理 老规矩 先新建用户模块 这里没有客户端模块 是因为用户模块是一个单独的模块 不用服务之间的调用 导入总的依赖 1<dependencies> 2 3 <!--所有provider公共依賴--> 4 <dependency> 5 <groupId>org.leryoo</groupId> 6 <artifactId>h…- 8
- 0
-
docker微服务部署之：二、搭建文章微服务项目
docker微服务部署之：一，搭建Eureka微服务项目 一、新增demo_article模块,并编写代码 右键demo_parent->new->Module->Maven,选择Module SK为jdk8->ArtifactId:demo_article 1.修改pom.xml文件 1<?xml version="1.0" encoding=&…- 3
- 0
-
docker微服务部署之：一，搭建Eureka微服务项目
先说明一下docker需要搭建的微服务的基本情况： 项目情况：一个demo_parent项目，下面三个子模块：demo_eureka(eureka服务)、demo_article(文章服务）、demo_zuul(网关服务)。 用到的资源有：jdk1.8、mysql5.7。 需要用到的docker容器有：mysql(mysql单独一个容器）、jdk1.8(article、eureka、zuul三个服…- 2
- 0
-
微服务分布式事务实战（三）SpringCloud注册中心编写和测试
SpringCloud注册中心编写和测试 （1）创建注册中心工程 （2）添加jar包 pom.xml 1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 2 xsi:schemaLocatio…- 9
- 0
-
微服务架构核心技术十三
集中式配置中心的作用和原理是什么? 简介: 一般普通开发下，我们都把程序配置设置保存在json或者xml文件中，然后程序中读取，来解耦(no hard coding).而传统的配置文件方式无法满足开发人员对于程序的动态更改(配置格式不标准、不统一，修改配置需要重新发布应用，不能动态调整),因此需要一个配置中心来管理配置文件 微服务建议用集中式配置中心，推荐携程开源的apollo，自带完善的配置管理…- 4
- 0
-
ASP.NET Core微服务实战系列
希望给你3-5分钟的碎片化学习，可能是坐地铁、等公交，积少成多，水滴石穿，码字辛苦，如果你吃了蛋觉得味道不错，希望点个赞，谢谢关注。 前言 这里记录的是个人奋斗和成长的地方，该篇只是一个系列目录和构想，并没有完全真正开弓。之所以有这个题目，是因为.NET Core在国内的学习资源七零八落，偶尔园里也有零星好文出现，但是系统性的，带深入浅出实战风格的专题介绍目前没有看到，之前特定整理了一个资源分享，…- 34
- 0
-
ASP.NET Core微服务之基于Ocelot实现API网关服务（1）
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、啥是API网关？ API 网关一般放到微服务的最前端，并且要让API 网关变成由应用所发起的每个请求的入口。这样就可以明显的简化客户端实现和微服务应用程序之间的沟通方式。以前的话，客户端不得不去请求微服务A（假设为Customers），然后再到微服务B（假设为Orders），然后是微服务C（假设为Invoices）。客户端需要去知道…- 11
- 0
-
Spring Cloud构建微服务架构：Hystrix监控面板【Dalston版】
在上一篇《服务容错保护（hystrix断路器）》的介绍中，我们提到断路器是根据一段时间窗内的请求情况来判断并操作断路器的打开和关闭状态的。而这些请求情况的指标信息都是由HystrixCommand和HystrixObservableCommand实例在执行过程中记录的重要度量信息，它们除了Hystrix断路器实现中使用之外，对于系统运维也有非常大的帮助。这些指标信息会以“滚动时间窗”与“桶”结合的…- 8
- 0
-
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)—->第3节: recycler的使用和创建…
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)---->第3节: recycler的使用和创建 Netty源码分析第八章: 高性能工具类FastThreadLocal和Recycler 第三节: recycler的使用和创建 ** ** 这一小节开始学习 recycler相关的知识 , recycler是 netty实现的一个轻量级对象回收站…- 6
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×