RocketMQ学习Api

生成者

DefaultMQProducer

发送消息失败，消息重试。

　　　　produce.send(msg,10)

　　　　可以指定重试的次数

消费者（先订阅服务，在发送消息）

DefaultMQPushConsumer

　　setConsumerMessageBatchMaxsize(10); 看情况，不会一次性拉取10条数据。如果生成者先生产数据，有数据积累，可能会部分10条，10条的拉取。

消费数据失败，重试。(可以得到重试的次数 )

　　　　timeout重试(无限次数的重试)

　　　　exception重试（理论性的重试，指定重试策略）

消费群组

　　　　当有多个消费者组成一个组之后，当a消费者，消费b数据失败了，然后会将消息交给c消费者。

Broker

　　　　多slave配置，主节点挂了，不会主从切换，slave节点主要用来提供消费数据（写入，同步数据是主节点干）

原文地址：https://www.cnblogs.com/xiaotao13725566749/p/9030339.html

时间： 2024-10-12 07:59:27

RocketMQ学习Api的相关文章

Jqgrid学习API

JQGrid是一个在jquery基础上做的一个表格控件,以ajax的方式和服务器端通信. JQGrid Demo 是一个在线的演示项目.在这里,可以知道jqgrid可以做什么事情. 下面是转自其他人blog的一个学习资料,与其说是学习资料,说成查询帮助文档更加合适. jqGrid学习之 ------------- 安装 jqGrid安装很简单,只需把相应的css.js文件加入到页面中即可. 按照官网文档: /myproject/css/ ui.jqgrid.css

RocketMq 学习记录

最近因为工作需求,领导让我安装一下RocketMQ 这里简单记录一下这里我的操作系统是centos 6.5 64位我们看一下官网的RocketMQ安装要求 Prerequisite The following softwares are assumed installed: (1)64bit OS, Linux/Unix/Mac is recommended; (2)64bit JDK 1.7+; (3)Maven 3.2.x (4)Git 所以这里我按照官网的要求 [[email prot

JBPM4.4学习API

一.流程引擎API org.jbpm.api.ProcessEngine是jbpm4所有的Service API 之源. 既所有的Service API(服务接口)都从ProcessEngine中获取. ProcessEngine由配置文件获取 ProcessEngine processEngine = Configuration.getProcessEngine(); 并且是线程安全的,可以保存在静态变量中.所有的线程和请求都可以使用同一个ProcessEngine对象. 二.其余API 1.

Sklearn -PCA 人脸识别百度网盘sklearn学习API

PCA脸部识别现在让我们用PCA来解决一个脸部识别问题.脸部识别是一个监督分类任务,用于从照片中认出某个人.本例中,我们用剑桥大学AT&T实验室的Our Database of Faces数据集(http://www.cl.cam.ac.uk/research/dtg/attarchive/facedatabase.html),这个数据集包含40个人每个人10张照片.这些照片是在不同的光照条件下拍摄的,每张照片的表情也不同.照片都是黑白的,尺寸为92 x 112像素.虽然这些图片都不大,但是每张

学习API之获取磁盘信息

#include <windows.h>#include <stdio.h> /************************************* BOOL GetDiskSpaceInfo(LPSTR pszDrive)* 功能:根据输入磁盘驱动器,获取磁盘信息* 参数:LPSTR pszDrive 驱动器根路径,如 D:************************************/ BOOL GetDiskSpaceInfo(LPSTR pszDrive){

学习API使用FindFirstVolume系列函数遍历驱动器，获取驱动器信息

#define _WIN32_WINNT 0x0501#include <windows.h>#include <stdlib.h>#include <stdio.h>#define BUFSIZE MAX_PATH BOOL GetDirverInfo(LPSTR szDrive); int main(void){ TCHAR buf[BUFSIZE]; HANDLE hVol; BOOL bFlag; /******************************

学习API之文件（已存在）操作

#include <windows.h>#include <stdio.h>/** int main(int argc,PCHAR argv[])* 功能:主函数,根据输入的参数不同-删除.复制.移动文件* 参数:删除文件 -d 文件路径(绝对路径或相对路径) 复制文件-将文件从路径1复制到路径2 -c 文件路径1 文件路径2 移动(重名民)文件 -m 文件路径1 文件路径2 */int main(int argc, PCHAR argv[]){ if (0 == lstrcmp(

学习API 设置卷的挂载点，列举指定卷中具有的挂载点和路径

#define _WIN32_WINNT 0x0501#include <windows.h>#include <stdio.h>#include <tchar.h>#define BUFSIZE MAX_PATH#define FILESYSNAMEBUFSIZE MAX_PATH/*************************************** ProcessVolumeMountPoint* 功能:列举挂载点*********************

canvas学习api

1.canvas.getContext():获取渲染上下文和绘画功能: 一.绘制矩形 2.ctx.fillRect(x,y,width,height):绘制矩形: 3.ctx.strokeRect(x,y,width,height):绘制矩形边框: 4.ctx.clearRect(x,y,width,height):清除矩形: 二.绘制路径 5.ctx.beginPath():新建路径开始命令: 6.ctx.closePath():路径闭合之后绘制命令重新回到上下文: 7.stroke():通过