聚合文章列表
20
浏览
基础拾遗----RabbitMQ（含封装类库源码）
基础拾遗基础拾遗------特性详解基础拾遗------webservice详解基础拾遗------redis详解基础拾遗------反射详解基础拾遗------委托详解基础拾遗------接口详解基础拾遗------泛型详解基础拾遗-----依赖注入基础拾遗-----数据注解与验证基础拾遗-----mongoDB操作基础拾遗----RabbitMQ前言消息队列,在高并发环境下，由于来不及同步处理，请求往往会发生堵塞，比如说双十一很多人进行下单，购买物品这是对于数据的操作是非常之大的，不管是是insert还是update是不是都有及时操作数据库，那么就有可能造成数据库思索移除什么堆积阻塞。那么我们这时是不是加入异步，nosql是不是能减轻其压力，那么这中间剑气的桥梁就是mq了，当然她的使用场景有很多，我们接下来把社么是消息队列了解清楚它是怎么一回事之后，希望大家能在自己的项目中灵活应用即可。消息队列（MQ）我们先从图文上说一下它的使用场景，异步处理，应用解耦，流量削锋和消息通讯四个场景
消息系统
2017-11-21 发布
13
浏览
RabbitMQ消息队列系列教程（一）认识RabbitMQ
摘要RabbitMQ是最为流行的消息中间件，是处理高并发业务的利器。本系列教程，将跟大家一起学习RabbitMQ。目录RabbitMQ的特点是什么？一、RabbitMQ是什么？RabbitMQ是基于Erlang开发的目前最流行的开源消息中间件，类似于MSMQ、ActiveMQ等消息队列组件。RabbitMQ是轻量级的，无论是在本地还是云端，都非常容易部署。它支持多种消息协议。RabbitMQ可以部署在分布式和联合配置中，以满足高规模，高可用性要求。RabbitMQ支持多种操作系统和云环境，并提供一系列编程语言开发工具。官网地址：http://www.rabbitmq.comMQ全称为MessageQueue,消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应
消息系统
2017-11-21 发布
14
浏览
《译文：RabbitMQ关于吞吐量，延迟和带宽的一些理论》
原文链接译者：flystarfly该文阅读自RabbitMQ官方网站，分享好文给大家你在Rabbit有一个队列，然后一些消费者从这个队列中消费。如果你根本没有设置QoS（basic.qos），那么Rabbit会把所有的队列消息都按照网络和客户端允许的速度推送给客户端。消费者将会飞速增加它们的内存占用，因为它们将所有消息都缓存在自己的RAM中。如果您询问Rabbit，队列可能会显示为空，但会有大量在客户端中，正准备由客户端应用程序处理的消息未被确认。如果您添加新的消费者，则队列中不会有消息发送给新的消费者。即使有其他消费者可用于更快地处理这样的消息，它们也只是在现有的客户端缓存，并且可能在那里很长一段时间。这是相当次优的。因此，默认的QoS预取设置为客户提供了无限的缓冲区，这可能导致不良的行为和性能。但是，怎样的QoS预取缓冲区大小才是您应该设置的？设置的目的是让消费者保持工作饱和状态，同时尽量减少客户端的缓冲区大小，以便更多的消息留在Rabbit的队列中，来可供新消费者使用，或在消费者空闲时发送给消费者。比方说Rabbit从这
消息系统
2017-11-21 发布
AD
友情赞助
17
浏览
RocketMQ集群部署配置
目标，使用2台机器部署RocketMQ多Master多Slave模式，异步复制集群模式。第一步，修改/etc/hosts文件192.168.116.115rocketmq1192.168.116.116rocketmq2集群机器配置完成之后，集群内进行ping一下，确保都通。编译得到环境gitclone-bdevelophttps://github.com/apache/rocketmq.gitcdrocketmqmvn-Prelease-all-DskipTestscleaninstall-Ucddistribution/target/apache-rocketmq本版本是基于4.1.0的，之后apache-rocketmq_4.1.0.tar.gz拷贝集群所有机器进行解压tar-zxvfapache-rocketmq_4.1.0.tar.gz配置集群模式【多Master多Slave模式，异步复制】配置的目录说明：2m-noslave：多Master模式2m-2s-sync：多Master多Sl
消息系统
2017-11-21 发布
12
浏览
Celery 源码解析六：Events 的实现
在Celery中，除了远程控制之外，还有一个元素可以让我们对分布式中的任务的状态有所掌控，而且从实际意义上来说，这个元素对Celery更为重要，这就是在本文中将要说到的Event。在Celery中，注册了很多的Event，这些Event将会在Task/Worker的状态发生变化的时候被发出，然后被绑定的Event消费者（Receiver）所接受，绑定的Event消费者可以是一连串的回调函数，相信细心的同学在前面的源码解析过程中也有发现一些关于event的蛛丝马迹，但是，我都是忽略了先，下面就正式得给大家介绍Event。Event有什么用前面说了，Celery在Task/Worker的状态发生变化的时候就会发出Event，所以，一个很明显的应用就是监控Event的状态，例如Celery大家所熟知的基于WebUI的管理工具flower就用到了Event，但是，这也是一个比较明显的应用，除此之外，我们还可以利用Event来给Task做快照，甚至实时对Task的状态转变
消息系统
2017-11-21 发布
14
浏览
Kafka设计解析（八）- Kafka事务机制与Exactly Once语义实现原理
因此，Kafka本身对ExactlyOnce语义的支持就非常必要。操作原子性操作的原子性是指，多个操作要么全部成功要么全部失败，不存在部分成功部分失败的可能。实现原子性操作的意义在于：操作结果更可控，有助于提升数据一致性便于故障恢复。因为操作是原子的，从故障中恢复时只需要重试该操作（如果原操作失败）或者直接跳过该操作（如果原操作成功），而不需要记录中间状态，更不需要针对中间状态作特殊处理实现事务机制的几个阶段幂等性发送上文提到，实现ExactlyOnce的一种方法是让下游系统具有幂等处理特性，而在KafkaStream中，KafkaProducer本身就是“下游”系统，因此如果能让Producer具有幂等处理特性，那就可以让KafkaStream在一定程度上支持Exactlyonce语义。为了实现Producer的幂等语义，Kafka引入了ProducerID（即PID）和SequenceNumber。每个新的Producer在初始化的时候会被分配一个唯一的P
消息系统
2017-11-22 发布
AD
友情赞助
14
浏览
发布订阅消息系统 Apache Pulsar 简介
ApachePulsar（孵化器项目）是一个企业级的发布订阅（pub-sub）消息系统，最初由Yahoo开发，并于2016年底开源，现在是Apache软件基金会的一个孵化器项目。Pulsar在Yahoo的生产环境运行了三年多，助力Yahoo的主要应用，如YahooMail、YahooFinance、YahooSports、Flickr、Gemini广告平台和Yahoo分布式键值存储系统Sherpa。Pulsar相关概念和术语向Pulsar发送数据的应用程序叫作生产者（producer），而从Pulsar读取数据的应用程序叫作消费者（consumer）。有时候消费者也被叫作订阅者。主题（topic）是Pulsar的核心资源，一个主题可以被看成是一个通道，消费者向这个通道发送数据，消费者从这个通道拉取数据。图1：生产者、消费者和主题构建Pulsar的目的是为了支持多租户（multi-tenant）应用场景。Pulsar的多租户机制包含了两种资源：资产（pro
消息系统
2017-11-22 发布
12
浏览
【JavaScript从入门到精通】第十一课（程序员学习dom基础）
第十一课DOM基础在讲JS的时候，我们已经学过，JS是由ECMA，DOM，BOM三部分组成，这节课开始我们将深入学习DOM。什么是DOMDOM是JS一个重要组成部分，可以让JS可以操作页面上的元素。实际上，DOM在JS里是以document的形式体现的，所有对页面元素的操作都是通过document进行的。首先来谈谈浏览器对DOM的支持性。目前主流的浏览器有3种：IE，Chrome和FF（火狐）。实际上，DOM除了是JS的一个组成部分外，也是一套规范，规定了浏览器如何去进行操作。在三种主流浏览器中，FF是最标准的浏览器，它对DOM有99%的支持性，而IE浏览器只有10%左右（IE9以后有了一定提升），Chrome浏览器则介于两者之间，有大概百分之60左右的支持性。DOM节点首先我们来看一个最基本的概念：子节点和父节点。在下面一个例子：