Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
RocketMQ 简介
本文根据阿里云 RocketMQ产品文档整理 地址 https help aliyun com document detail 29532 html userCode qtldtin2 简介 RocketMQ是由阿里捐赠给Apache的一款
RocketMQ
消息队列
Java 项目的跨库的方式查询的方法
Java 项目的跨库的方式查询的方法 目录 概述 需求 设计思路 实现思路分析 性能参数测试 参考资料和推荐阅读 Survive by day and develop by night talk for import biz show yo
消息队列
Java
Kafka实战——简单易懂的生产者消费者demo
单线程版本适合本地调试 多线程版本适合做压测 1 引入maven依赖
服务端
大数据
kafka
消息队列
代码技巧——如何关闭订单?延迟任务的实现方案【建议收藏】
先思考个问题 为什么要关闭订单 业务上 1 提供待付款时间 而不是简单的 一次付款机会 提高业务指标之一的成单率 成单率 成功下单的人数 发起支付的人数 2 下单成功意味着这个商品被当前订单占用 库存已经预扣减 如果迟迟不支付则需要回收库存
代码技巧
消息队列
Redis
订单关闭
延迟任务
RocketMQ消费重试问题
异常现象 监控日志展示如下 2019 10 30 14 31 23 339 INFO ConsumeMessageThread 7 com xxx service mq MQConsumerService 93 消费消息 msgId 0A0
消息队列
php消息队列的应用
欢迎加入 新群号码 99640845 最近打算开发一个新功能 计划应用消息队列 以前对消息队列都是简单的理论了解 真正应用之后把自己的感觉和一些理解整理下来 说正事分割线 具体的业务场景如下 用户下单 生成订单 支付 返回支付信息 就是正常
php
脚本
并发
消息队列
RocketMQ第五篇 RocketMQ API基本使用
目录 生产者Product 消费者Consumer 前面已经学习了Rocket的基本知识 以及搭建MQ单机版和集群环境 下面开始进行实际开发 根据前面下载的RocketMQ源码 开展讲解RocketMQ 的基本使用 生产者Product 在
RocketMQ
消息队列
将mysql中的数据移到另一个数据库中
1 导出整个数据库 mysqldump u 用户名 p 数据库名 gt 导出的文件名 mysqldump u admin p vmiplatform gt sql sql 运行结果如下 2 导出一个表 mysqldump u 用户名 p 数
数据库及sql
MyBatis
Spring
消息队列
RabbitMQ理论+实战
1 引出 1 1 中间件应用场景 1 跨系统数据传输 2 高并发的流量削峰 3 数据的分发与异步处理 4 大数据分析与传递 5 分布式事务 1 2 中间件常用协议 01 什么是协议 所谓协议是指 1 计算机底层操作系统和应用程序通讯时共同遵
消息队列
rabbitmq
大数据
队列
Rabbitmq入门到进阶看这篇就够了!
安装前提 安装 erlang windows用户名非中文 可以关注我的公众号 知识追寻者 回复 rabbitmq 获取已经下载好的安装包和配套源码地址 本套教程对应知识追寻者网址 windows安装rabbitmq zszxz com Ra
消息队列
7 SpringBoot整合RocketMQ发送单向消息
发送单向消息是指producer向 broker 发送消息 执行 API 时直接返回 不等待broker 服务器的结果 这种方式主要用在不特别关心发送结果的场景 举例 日志发送 RocketMQTemplate给我们提供了sendOneWa
RocketMQ
Java
消息队列
(一)调试RocketMq源码
文章目录 一 启动NameServer 1 1namesrv模块找到NamesrvStartup java 1 2修改配置文件目录 1 3启动NamesrvStartup java 二 配置Broker 2 1配置BrokerStartup
消息队列
【RabbitMQ】Consumer之消费模式、消息确认与拒绝 - 基于AMQP 0-9-1
这篇文章主要和大家分享RabbitMQ Consumer端的知识点 主要包括Consumer的消费模式 消息是如何确认以及如何拒绝的 当消息拒绝之后 如何让消息重新进入队列 推模式 RabbitMQ支持推和拉两种消费模式 推模式就是由Bro
RabbitMQ
rabbitmq
消息队列
消息中间件
Rabbit消费者
rocketMq消息队列原生api使用以及rocketMq整合springboot
rocketMq消息队列 文章目录 rocketMq消息队列 一 RocketMQ原生API使用 1 测试环境搭建 2 RocketMQ的编程模型 3 RocketMQ的消息样例 3 1 基本样例 3 2 顺序消息 3 3 广播消息 3 4
消息队列
javarocketmq
RocketMQ
spring boot
java消息队列
非阻塞的connect使用方式
connect 函数的调用涉及到3次握手 默认connect函数为阻塞连接状态 通常connect 会阻塞到三次握手的完成和失败 而这个connect阻塞超时时间会依赖于系统 一般为75s到几分钟时间 一种方式可以通过该系统配置 proc
c语言
消息队列
源码
OSAL
OSAL为 Operating System Abstraction Layer 即操作系统抽象层 支持多任务运行 它并不是一个传统意义上的操作系统 但是实现了部分类似操作系统的功能 OSAL概念是由TI公司在ZIGBEE协议栈引入 他的意
RTOS
OSAL
消息队列
任务调度
系统抽象层
RabbitMQ中重试机制的坑
当我们消息消费失败的时候 可以进行重试 虽然SpringAMQP集成了retry机制 但是发现使用过程有点坑 等会细说 重试机制使用场景 1 如果是业务代码 比如空指针之类的异常那重试机制其实没什么用 2 如果是调用第三方系统 网络抖动之类
消息队列
rabbitmq
RabbitMQ:Queue的介绍和使用
1 声明 当前内容用于本人学习和使用当前的Queue 当前内容为RabbitMQ中对Queue的介绍 当前内容来源 RabbitMQ中的Queue 2 Queue的官方介绍 首先先分析以下前面的Queue的使用 其实这个东西就是一个队列 一
消息队列
使用RabbitMQ实现延时队列
之前公司是一个类电商公司 会有用户下单后未支付取消订单的场景 解决方案是使用RabbitMQ的死信队列来实现一个延时队列 下单时 将订单丢进消息队列 设置过期时间 订单失效时间 然后到时候检查订单状态 如果未支付则取消订单 1 什么是死信
消息队列
rabbitmq
MQ消息队列的重复消费问题的通用解决办法以及幂等性的原理
详细介绍了MQ消息队列重复消费的原因 以及通过保证幂等性来避免重复消费带来的问题 文章目录 1 至少一次 2 重复消费的原因 3 幂等性处理重复消费 1 至少一次 消息领域有一个对消息投递的QoS定义 Quality of Service
RocketMQ 学习
Java
消息队列
重复消费
幂等性
«
1
2
3
4
5
6
7
»