背景
RabbitMQ现在用的也比较多，但是没有过去那么多啦。现在很多的流行或者常用技术或者思路都是从过去的思路中演变而来的。了解一些过去的技术，对有些人来说可能会产生众里寻他千百度的顿悟，加深对技术的理解，更好的应用于工作中去。
本篇整体采用从浅到深的逻辑结构来描述。
入门部分
什么是MQ
MQ全称是Message Queue，消息的队列。因为是队列，所以遵循FIFO先进先出原则。因为存放的是消息，所以是一种跨进程的通信机制。
为什么使用MQ
流量削峰
这个跟很火的小吃店门口的排队原理是一样的。实时调用就好像是大家蜂拥而至，如果系统处理能力不够，就会让店家手忙脚乱，说不定会在冰激凌上浇上可乐。排队能保证有条不紊，代价是整体处理速度会慢些。
异步处理
当A调用B，B可能要花很长一段时间来完成。这时候一般有三种方式来异步处理。A调用B，B返回A说收到调用请求了。同步请求已经完成，但B的执行才刚开始。这时候，第一种方式是A每隔一段时间来查询一次，看B是否执行完，这是拉的方式；第二种方式是A提供一个回调地址，B执行完之后回调A，这是推的方式；第三种就是使用MQ，A使用MQ给B发消息，B处理完再回一个消息，好处是上面提到的同时可以流量削峰。
应用解耦
MQ实现了逻辑解耦+物理解耦。逻辑上，将请求和结果处理分开了；物理上，系统只用与MQ通信。听起来，MQ要优雅很多，但是上面提到异步处理的三种方式的前两种，现在也多很常见。那是因为MQ是有代价的，那就是需要一套MQ设施。做开放平台，用户之间的唯一设施就是互联网，这时候更依赖双方的协议约定，所以前两种异步处理方式不会被MQ取代。
MQ的分类
ActiveMQ是早期的MQ，倚老卖老一下，我那个年代用过，目前优势已经不太明显了。
Kafka号称是大数据的杀手锏，以百万级TPS吞吐量名声大噪。时效是ms级别，分布式的可用性高。消费者采用拉的方式获取消息，消息有序，通过控制可以保证消息仅被消费一次。但是单机超过64个分区，load会明显飙高；实时性取决于轮询时间间隔，关键是有可能丢消息，不适合订单业务中使用。
RocketMQ是国货，用Java语言实现，在设计时参考了Kafka，单机吞吐量达到十万级别，分布式架构可用性高，消息可以0丢失，扩展性高。但是支持的客户端成熟的也就是Java，核心代码没有实现JMS，迁移需要修改大量代码。
RabbitMQ是erlang开发的，吞吐量达到万级别，稳定、健壮、跨平台，支持多种语言，企业间通信中常用。
JMS支持
RabbitMQ不支持JMS协议。这个很好理解。因为JMS是Java消息服务，提供了消息传递的Java标准API。而RabbitMQ是Erlang写的，对Java的支持会弱一些。但是RabiitMQ实现了AMQP标准协议。AMQP只是统一了数据交换的标准格式，与语言无关。
核心部分
核心概念
所有的MQ都由生产者、消费者和broker(队列)三部分组成。但是不同的实现，根据核心思想不同，内部结构也各有特色。
比如银行系统中常用的跨银行间通信的MQ，相当于两组MQ拼起来的。
普通MQ
跨企业MQ
这样做的好处是任何一端网络出现问题，都可以暂存消息，等待网络恢复，不丢失消息。消息的重试放在broker端，减少了应用端的复杂度。为什么这里举例时提到银行间使用呢，因为使用这种模式的MQ，最重要的是有钱。因为想达到理想效果，要拉专线，并使用高配机器。
RabbitMQ和Kafka是一样的
再回来考虑普通MQ的场景，如果这个MQ是RabbitMQ。组件细化一下是这样：
这张图上来看，其实RabbitMQ和Kafka是一样的。来看Kafka的：
表面上来看，RabbitMQ的服务器(Broker)端由Exchange和Queue两部分组成。Exchange是交换机，交换机是做路由的。Kafka生产者发到Broker也需要路由啊，来决定路由到哪个Partition(也就是队列)中去。只不过Kafka的路由模式很固定，就是先找到哪个topic，然后使用负载均衡的策略找到一个Partition来投递消息。Kafka是用了逻辑概念topic简化了exchange路由，所以Kafka的路由功能也很单一。
表面上，RabbitMQ的生产者和消费者与服务端都是Channel信道来相连。Channel是复用连接来进行通信的，Kafka也是需要的，只是它内部帮我们把这些与核心功能关系不大的都自己内置实现了。而RabbitMQ暴露给用户，提供了更高的灵活性。
上面的两段如果我没有讲明白，也没有关系。只要知道更年轻的Kafka没有Exchange和Channel的概念是类似于采取了约定大于配置的方式提供的服务。
核心功能
RabbitMQ的核心实际上就是AMQP的核心：MessageQueue、Exchange和Binding。
MessageQueue就是消息队列，一个队列里的一条消息，也就是同一个message ID对应的消息，不管有多少个消费者来分摊压力，也只能被消费一次。消息队列和消费者之间有ack机制，消息一旦确认安全送达，RabbitMQ服务端就可以安全删除消息了。
Binding是MessageQueue与Exchange之间的连接，Exchange只能给Binding的MessageQueue发送消息。
Exchange有四种类型：fanout、topic、direct和header。本质上就是有一堆MessageQueue，一个消息是要被复制几份，发到哪几个Binding的消息队列去。Exchange给定了规则：fanout是对每个消息队列复制一份发送；direct意思是只发指定的一份，不复制；topic是发送通配符匹配的几份；header可以指定一些其他的过滤条件发送。消息从生产者发送到exchange之后也有ack机制来保证消息的可靠传输。
Kafka只有topic的概念。这是因为Kafka的设计上消息只用存一份，通过游标，发送后不立即删除消息。多个消费者组可以互不影响的消费。这是Kafka的一大改进。
内部原理
大家面试时有没有被问过：Kafka怎么保证消息能且仅能收到一次？这是个埋坑题，是与面试官斗智斗勇的开始。什么幂等、事务、流式EOS呀，其实呢，Kafka本身是不保证仅且仅收到一次的，所以这些实现方法都不优雅。
RabbitMQ通过AMQP事务机制，还有上面已经提过的ack也就是confirm两种可选方式保证消息被收到。
但是最为优雅的实现是IBM的Websphere MQ。因为这是收费的，所以研究的人不多。它通过消息序列号保证消息不丢失、不重传。
通道为每条消息的传送分配一个序列号，它会自动累积增值。消息序列号由发送通道分配，是通道的一个永久属性，每当发送一条消息，消息序列号就加一。通道的相关属性SEQWRAP标识序号的最大值，缺省为999,999,999。序列号越界后自动归零，从头开始。
正常情况下，通道两端的消息序列号或者相等或相差为一。双方对前面的某一条或一批消息是否发送成功理解不一致。在解决了不确定的消息后，可以用MQSC命令通过重置消息序号将双方调整到一致。一旦连接断开后，通道重连时双方会将消息序号同步。
推荐阅读
我有一个字符串input="maybe(thisis|thatwas)some((nice|ugly)(day|night)|(strange(weather|time)))"Ruby中解析该字符串的最佳方法是什么？我的意思是脚本应该能够像这样构建句子:maybethisissomeuglynightmaybethatwassomenicenightmaybethiswassomestrangetime等等，你明白了......我应该一个字符一个字符地读取字符串并构建一个带有堆栈的状态机来存储括号值以供以后计算，还是有更好的方法？也许为此目的准备了一个开箱即用的库？
我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？ 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co
我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i
我正在使用ruby1.9解析以下带有MacRoman字符的csv文件#encoding:ISO-8859-1#csv_parse.csvName,main-dialogue"Marceu","Giveittohimóhe,hiswife."我做了以下解析。require'csv'input_string=File.read("../csv_parse.rb").force_encoding("ISO-8859-1").encode("UTF-8")#=>"Name,main-dialogue\r\n\"Marceu\",\"Giveittohim\x97he,hiswife.\"\
我将应用程序升级到Rails4，一切正常。我可以登录并转到我的编辑页面。也更新了观点。使用标准View时，用户会更新。但是当我添加例如字段:name时，它不会在表单中更新。使用devise3.1.1和gem'protected_attributes'我需要在设备或数据库上运行某种更新命令吗？我也搜索过这个地方，找到了许多不同的解决方案，但没有一个会更新我的用户字段。我没有添加任何自定义字段。 最佳答案 如果您想允许额外的参数，您可以在ApplicationController中使用beforefilter，因为Rails4将参数
简而言之错误:NOTE:Gem::SourceIndex#add_specisdeprecated,useSpecification.add_spec.Itwillberemovedonorafter2011-11-01.Gem::SourceIndex#add_speccalledfrom/opt/local/lib/ruby/site_ruby/1.8/rubygems/source_index.rb:91./opt/local/lib/ruby/gems/1.8/gems/rails-2.3.8/lib/rails/gem_dependency.rb:275:in`==':und
目录前言滤波电路科普主要分类实际情况单位的概念常用评价参数函数型滤波器简单分析滤波电路构成低通滤波器RC低通滤波器RL低通滤波器高通滤波器RC高通滤波器RL高通滤波器部分摘自《LC滤波器设计与制作》，侵权删。前言最近需要学习放大电路和滤波电路，但是由于只在之前做音乐频谱分析仪的时候简单了解过一点点运放，所以也是相当从零开始学习了。滤波电路科普主要分类滤波器：主要是从不同频率的成分中提取出特定频率的信号。有源滤波器：由RC元件与运算放大器组成的滤波器。可滤除某一次或多次谐波，最普通易于采用的无源滤波器结构是将电感与电容串联，可对主要次谐波（3、5、7）构成低阻抗旁路。无源滤波器：无源滤波器，又称
项目介绍随着我国经济迅速发展,人们对手机的需求越来越大,各种手机软件也都在被广泛应用,但是对于手机进行数据信息管理,对于手机的各种软件也是备受用户的喜爱小学生兴趣延时班预约小程序的设计与开发被用户普遍使用,为方便用户能够可以随时进行小学生兴趣延时班预约小程序的设计与开发的数据信息管理,特开发了小程序的设计与开发的管理系统。小学生兴趣延时班预约小程序的设计与开发的开发利用现有的成熟技术参考,以源代码为模板,分析功能调整与小学生兴趣延时班预约小程序的设计与开发的实际需求相结合,讨论了小学生兴趣延时班预约小程序的设计与开发的使用。开发环境开发说明：前端使用微信微信小程序开发工具：后端使用ssm：VU
我正在使用ruby2.1.0我有一个json文件。例如:test.json{"item":[{"apple":1},{"banana":2}]}用YAML.load加载这个文件安全吗？YAML.load(File.read('test.json'))我正在尝试加载一个json或yaml格式的文件。 最佳答案 YAML可以加载JSONYAML.load('{"something":"test","other":4}')=>{"something"=>"test","other"=>4}JSON将无法加载YAML。JSON.load("
我在我的项目中有一个用户和一个管理员角色。我使用Devise创建了身份验证。在我的管理员角色中，我没有任何确认。在我的用户模型中，我有以下内容:devise:database_authenticatable,:confirmable,:recoverable,:rememberable,:trackable,:validatable,:timeoutable,:registerable#Setupaccessible(orprotected)attributesforyourmodelattr_accessible:email,:username,:prename,:surname,:
