消息的确认 RabbitMQ需要对每一条发送的消息进行确认。消费者必须通过AMQP的basic.ack命令显式地向RabbitMQ发送一个确认,或者在订阅到队列的时候就将auto_ack参数设置为true。当auto_ack为true时,一旦消费者接收消息,RabbitMQ会自动视其确认了消息。需要 ...
分类:
其他好文 时间:
2018-03-07 15:20:06
阅读次数:
155
RabbitMQ消息队列的发布与订阅类似于广播,一端发送消息,多个客户端可以同时接收到消息 fanout:所有绑定到exchange的queue都可以接收消息 消息发布端 消息订阅端 消息发布端需要在消息订阅端运行之后运行,不然消息订阅端收不到消息 开启3个消息订阅端和一个消息发布端 消息发布端发布 ...
分类:
编程语言 时间:
2018-02-24 22:03:23
阅读次数:
290
Redis 发布订阅 Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息。 Redis 客户端可以订阅任意数量的频道。 下图展示了频道 channel1 , 以及订阅这个频道的三个客户端 —— client2 、 client5 和 clie ...
分类:
其他好文 时间:
2018-02-21 15:57:26
阅读次数:
172
一、发布订阅 1、模型 发布者发布消息,订阅者接收消息 2、API 2.1、publish 2.2、订阅 2.3、取消订阅 unsubsribe 2.4、其他api 二、HyperLogLog 极小空间完成独立数量的统计,本质是字符串类型 优势:百万数据只占十几k内存 局限:错误率:0.81%,不能 ...
分类:
其他好文 时间:
2018-02-14 22:18:25
阅读次数:
455
队列: 从概念上来讲,AMQP消息路由必须有三部分:交换器、队列和绑定。生产者把消息发布到交换器上;消息最终到达队列,并被消费者接收;绑定决定了消息如何从路由器路由到特定的队列。 消费者通过以下两种方式从特定的队列中接收消息: 1)通过AMQP的basic.consume命令订阅。这样做会将信道置为 ...
分类:
其他好文 时间:
2018-02-12 18:38:05
阅读次数:
219
tutorial:http://www.rabbitmq.com/tutorials/tutorial-two-java.html 这里解释接收消息端关于 acknowledge和prefetch的设置问题 这里有两段代码,sender,负责发送100条消息; recv,负责接收消息,每接收到一条消 ...
分类:
其他好文 时间:
2018-02-09 17:27:09
阅读次数:
351
微信今日发布iOS端新版本6.6.2,支持两个账号一键切换登录,以及发现页管理功能。据了解,该版本仅支持切换账号,尚不支持同时接收消息。更新1、在本地添加两个常登录账号后,可一键切换登录。更新2、可在“设置”-“通用”-“发现页管理”控制功能是否在“发现”显示。 在本地添加两个常登录微信账号后,可一 ...
分类:
微信 时间:
2018-02-01 00:24:40
阅读次数:
354
前言 Spring Data Redis project,应用了Spring概念来开发使用键值形式的数据存储的解决方案。我们(官方)提供了一个 "template" ,这是一个高级别的抽象,来发送和接收消息。你会注意到它与Spring框架对JDBC的支持有些类似。 为什么选择Spring Data ...
分类:
编程语言 时间:
2018-01-29 15:58:02
阅读次数:
241
1.JMS简介 JMS的全称是Java Message Service,即Java消息服务。它主要用于在生产者和消费者之间进行消息传递,生产者负责产生消息,而消费者负责接收消息。把它应用到实际的业务需求中可以在特定的时候利用生产者生成消息,并进行发送,对应的消费者在接收到对应的消息后去完成对应的业务 ...
分类:
其他好文 时间:
2018-01-12 22:45:41
阅读次数:
277
简单聊天Demo 使用tcp协议实现的简单聊天功能(非常简单的) 思想:使用2个线程,一个线程是用来接收消息的,另一个线程是用来发消息的。 客户端Demo代码: 服务器端Demo代码: 发送线程的Demo代码: 接收线程的Demo代码: ...
分类:
编程语言 时间:
2017-12-25 00:46:14
阅读次数:
135