1.为什么使用信道（channel）而不使用TCP连接发送AMQP命令？ 对操作系统来说频繁的建立和销毁TCP连接开销非常昂贵，而操作系统每秒建立的连接是有上限的，性能瓶颈不可避免，而只建立一条TCP连接无疑是一个很好的方案，在这条连接当中建立多条信道与RabbitMQ进行私密通信，相当于光纤电缆一样，一条电缆有多条光束，信道是没有限制的 2.队列 1）AMQP的命令basic.consume与basic.get 如果需要消息一到达队列就自动接收的话，应该使用basic.consume basic.get会订阅消息，获得单条消息，然后取消订阅，值得注意的是不应该循环basic.get来替代basic.consume，应该理性使用basic.consume实现高吞吐量 消息如果到达无人订阅的队...阅读全文
/* switch ssh username cisco password cisco ip domain name hupu crypto key generate rsa ip ssh time-out 30 line vty 0 4 transport input all login local */ package main import ( "fmt" "io" "log" "os" "strings" "sync" ) import ( "golang.org/x/crypto/ssh" ) func main() { config := &ssh.ClientConfig{ User: "cisco", Auth: []ssh.AuthMethod{ ssh.Password(...阅读全文
package main import ( "fmt" ) // 使用第三变量交换a,b值 func swap(a *int, b *int) { tem := *a *a = *b *b = tem return } // 使用第三变量交换a,b值:go 直接交换值 func swapTwo(a *int, b *int) { *a, *b = *b, *a } // 不使用第三变量交换a,b值：直接返回 func swapReturn(a int, b int) (int, int) { return b, a } // 不使用第三变量交换a,b值：数学运算 func swapThree(a *int, b *int) { *a = *a + *b *b = *a - *b *a = *...阅读全文
AMQP协议 AMQP（Advanced Message Queuing Protocol，高级消息队列协议）是一个进程间传递异步消息的网络协议。 RabbitMQ 就是 amqp 协议的Erlang的实现。 AMQP的模型架构的主要角色，生产者、消费者、交换器、队列。 生产者、消费者、服务节点 生产者(Producter) 消息投递方 消费者(Consumer) 消息接收方 服务节点(Broker) 消息的服务节点，基本上可以简单的把一个broker看成一台消息服务器 交换器、队列、绑定 绑定 Rabbitmq中需要路由键和绑定键联合使用才能使生产者成功投递到队列中去。 RoutingKey 生产者发送给交换器绑定的Key BindingKey 交换器和队列绑定的Key 生产者将消息投递到...阅读全文
## 发布／订阅 **（使用Go客户端）** 在[上篇教程](https://bingjian-zhu.github.io/2019/09/01/RabbitMQ%E6%95%99%E7%A8%8B%EF%BC%88%E8%AF%91%EF%BC%89-Work-queues/)中，我们搭建了一个工作队列，每个任务只分发给一个工作者（worker）。在本篇教程中，我们要做的跟之前完全不一样 —— 分发一个消息给多个消费者（consumers）。这种模式被称为“发布／订阅”。 为了描述这种模式，我们将会构建一个简单的日志系统。它包括两个程序——第一个程序负责发送日志消息，第二个程序负责获取消息并输出内容。 在我们的这个日志系统中，所有正在运行的接收方程序都会接受消息。我...阅读全文
子操作函数 分为下面系列函数，其中Xxx可以是Int32/Int64/Uint32/Uint64/Uintptr/Pointer其中一种。 1.SwapXxx系列：交换新旧值； // SwapInt32 atomically stores new into *addr and returns the previous *addr value. func SwapInt32(addr *int32, new int32) (old int32) 2.CompareAndSwapXxx系列：比较并交换； // CompareAndSwapInt32 executes the compare-and-swap operation for an int32 value. func CompareAn...阅读全文
导语 rabbitMQ是市面上应用很广的一种应用间传送数据的通信方式，是由erlang语言开发，主要特点就是异步通信，实现服务与服务之间的解耦。特点可靠性：提供了持久化、传输时确认、发布时确认、跟踪机制灵活的路由：有四种交换器负责分发路由集群：支持集群多种协议：支持STOMP、和MQTT协议多语言：支持大部分流行语言友好的界面：提供了直观的管理界面可扩展：提供了许多插件。应用场景高并发排队机制：比如在秒杀场景，提示用户正在等待，在队列里存放了有序的待处理的消息，而不是所有的消息杂乱无章服务之间的解耦：服务之间可通过发布订阅的模式，让Rabbitmq队列通知订阅了该消息的服务执行相关代码。工作机制在其通信的过程中，有两个重要的角色，分别是生产者和消费者，需要强调的是RabbitMQ服务器并不产...阅读全文
Rabbitmq 简单介绍,安装和go客户端使用 1，消息队列介绍 1.1 什么是消息队列？ 消息队列（英语：Message queue）是一种进程间通信或同一进程的不同线程间的通信方式，软件的贮列用来处理一系列的输入，通常是来自用户。消息队列提供了异步的通信协议，每一个贮列中的纪录包含详细说明的数据，包含发生的时间，输入设备的种类，以及特定的输入参数，也就是说：消息的发送者和接收者不需要同时与消息队列互交。消息会保存在队列中，直到接收者取回它。消息队列，一般我们会简称他为MQ(Message Queue)，消息队列可以简单的理解为：把要传输的数据放在队列中 说明： Producer：消息生产者，负责产生和发送消息到 Broker； Broker：消息处理中心。负责消息存储、确认、重试等，一...阅读全文
一、前言 RabbitMQ是一个开源的消息代理软件（面向消息的中间件），它的核心作用就是创建消息队列，异步接收和发送消息，MQ的全程是：Message Queue中文的意思是消息队列。 1.1 使用场景 削峰填谷：用于应对间歇性流量提升对于系统的“破坏”，比如秒杀活动，可以把请求先发送到消息队列在平滑的交由系统去处理，当访问量大于一定数量的时候，还可以直接屏蔽后续操作，给前台的用户友好的显示； 延迟处理：可以进行事件后置，比如订单超时业务，用户下单30分钟未支付取消订单； 系统解耦：消息队列也可以帮开发人员完成业务的解耦，比如用户上传头像的功能，最初的设计是用户上传完之后才能发帖，后面有增加了经验系统，需要在上传头像之后增加经验值，到后来又上线了金币系统，上传头像之后可以增加金币，像这种需求...阅读全文
导语 上一节介绍了简单的工作模式，即一个队列可以被多个消费者进行消费，只有一条消息被送到消费者，采用公平调度的方式，在以往的例子中似乎我们还没用到交换器进行发送消息，我们都知道，往队列里发送消息，是需要用交换器进行分发的消息的，为什么我们没有申请交换器仍然可以发送消息呢？因为在RabbitMQ服务器中，如果不申请交换器，服务器会使用默认的交换器，所以说，交换器在发送消息的时候必不可少，今天我们学习两种交换器分别为fanout（扇形交换器）和direct（直连交换器） 扇形交换器（日志记录器） 特性 分发消息到与之绑定的所有队列，发送消息到交换器时会忽略routing key（路由），我们可以称它为广播消息。 生产者 申请交换器 指定交换器的名字 指定交换器的类型 err = ch.Excha...阅读全文
导语 昨天的内容主要讲了RabbitMQ的发布订阅模式和路由模式，都很好的满足了我们的日志打印，但是如果说，我对日志的打印，希望可以过滤掉一些内容呢，比如说，在打印错误日志的时候，只打印login时的错误？这个时候，就需要我们使用主题订阅的模式，可以说，主题订阅模式可以完全代替路由模式，因为在主题订阅模式中，如果没有响应的关键词，便和路由模式完全一样。 主题交换器介绍 在使用主题交换器时需要注意以下几点 在使用routing_key，必须是有点分隔符进行分隔 * 可以代表代替一个单词 # 可以代替0个或多个单词 案例 我们对我们之前的例子做修改，这次修改希望生产者可以在运行的时候指定路由需要增加下面这个函数 func severityFrom(args []string) string { ...阅读全文
