开发过程中一些工具的安装使用笔记。。。。。 一、jenkins 安装部署项目（码云为例Gitee）：参考：https://blog.csdn.net/shuizhihun07/article/details/80168076 1. 安装 jdk 、maven、git jenkins 并设置环境变量 2. 安装完成后启动： 首次启动报如下错误： Starting Jenkins bash: /usr/bin/java: No such file or directory 解决方法： 添加java依赖：修改/etc/init.d/jenkins 配置文件，在candidates 第一行加...
秒杀存在的问题： 1、短时间内大量请求发送到服务器，很可能会造成服务器崩溃； 2、商品超卖； 3、服务器响应时间过久（频繁读写数据库，耗时长），用户体验性差。 解决思路：1、为解决频繁读数据库问题以及减轻数据库压力，使用 Redis ，项目初始化时先将商品信息缓存起来，请求过来时先查Redis，根据商品库存做进一步处理。 2、使用 Redis 解决超卖问题； 3、使用RabbitMQ 实现 流量削峰 和 异步调用，即当我们从 Redis 中知道库...
这里有一些我目前的设置. > REST API将数据推送(队列)到队列中> Queue有一个消费者,它始终在运行并生成到Exchange> Exchange路由到其他几个队列(如20)>每个(20)队列都执行特定任务(消费者总是运行)> Cron作业运行以检查是否所有(20)任务都已完成并生成另一个队列 我不确定我喜欢消费者一直在运行,因为每个消费者使用大约300MB的Ram(我认为它是MB,现在不在我面前)而且我正在寻找另一个实现.M <-- Message coming from REST API||+-F...
由于RabbitMQ中只有队列（queue）才能存储信息，所以用RabbitMQ实现超大用户级别（百万计）的消息在/离线收发需要对每一个用户创建一个永久队列。 但是RabbitMQ节点内存有限，经测试后发现节点集群也无法满足数百万用户队列收发数据的要求，所以最终决定采用数据库辅助实现该功能。 一、数据库结构 user_list数据库下有4张表：user_info、group_info、groupmember_info、message_info。 user_info表中含有username（主键，非空，VA...
本篇介绍一下RabbitMQ中的消费模式，在前边的所有栗子中我们采用的消费者都是EventingBasicConsumer，其实RabbitMQ中还有其他两种消费模式：BasicGet和QueueBaicConsumer，下边介绍RabiitMQ的消费模式，及使用它们时需要注意的一些问题。 1 RabbitMQ的消费模式 0 准备工作使用Web管理工具添加exchange、queue并绑定，bindingKey为“mykey”，如下所示：生产者代码如下： static void Main(string[] args){var factory = new ...
1 消息确认在一些场合，如转账、付费时每一条消息都必须保证成功的被处理。AMQP是金融级的消息队列协议，有很高的可靠性，这里介绍在使用RabbitMQ时怎么保证消息被成功处理的。消息确认可以分为两种：一种是生产者发送消息到Broke时，Broker给生产者发送确认回执，用于告诉生产者消息已被成功发送到Broker；一种是消费者接收到Broker发送的消息时，消费者给Broker发送确认回执，用于告诉消费者消息已成功被消费者接收。下边分别介绍...
一、背景介绍和描述MQ消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。何时需要消息队列？当你需要使用消息队列时，首先需要考虑它的必要性。可以使用mq的场景有很多，最常用的几种，是做业务解耦/最终一致性/广播/错峰流控等。本次分享课阿笨给大家分享的是MQ的广播场景使用，如何基于开源流行的消息中间件RabbitMQ来实现客户端...
生产者向队列发送消息，随机消费者从队列中接收消息 创建用户和虚拟主机 通过rabbitmq提供的用户管理界面可以很轻松的创建用户和虚拟主机，并且需要将用户绑定到对应的虚拟主机。自带有guest用户和/虚拟主机，也可以直接用这两个既有信息。我们创建了名为wuwl的用户和/vh的虚拟主机，注意虚拟主机需要以/开头。 导入依赖 <dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.10.0</vers...
开发过程中通常会碰到这样的需求： 淘宝订单业务：下单后 30min 之内没有付款，就自动取消订单。饿了吗订餐通知：下单成功后 60s 之后给用户发送短信通知。关闭空闲连接：服务器中有很多客户端的连接，空闲一段时间之后需要关闭之。缓存：缓存中的对象，超过了空闲时间，从缓存中移出。任务超时处理：在网络协议滑动窗口请求应答式交互时，处理超时未响应的请求。失败重试机制：业务操作失败后，间隔一定的时间进行失败重试。这类业...
程序要求： 1. 用Rabbit MQ实现RPC 1. 可以异步地执行多条命令 2. 可以对一次性对多个机器执行命令 程序效果： ---》run dir host1 host2 。。。。 ---》get task_id ---》taskId：xxxx host： xxxxxx ---》check task_id --->打印结果 程序分析： 为了达到异步地效果，可以使用多线程或协程，...
前言 我在刚接触使用中间件的时候，发现，中间件的使用并不是最难的，反而是中间件的下载，安装，配置才是最难的。 所以，这篇文章我们从头开始学习RabbitMq，真正的从头开始。 关于消息队列 其实消息队列没有那么神秘，我们这样想一下，用户访问网站，最终是要将数据以HTTP的协议的方式，通过网络传输到主机的某个端口上的。 那么，接收数据的方式是什么呢？自然是端口监听啦。 那消息队列是什么就很好解释了？ 它就是端口监听，接...