首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

快速学习-RocketMQ

1 基本 在基本中我们提供如下的功能场景: 使用RocketMQ发送三种类型的消息:同步消息、异步消息和单向消息。其中前两种消息是可靠的,因为会有发送是否成功的应答。...%n"); } } 2 顺序消息 消息有序指的是可以按照消息的发送顺序来消费(FIFO)。RocketMQ可以严格的保证消息有序,可以分为分区有序或者全局有序。...6.1 发送事务消息 1、创建事务性生产者 使用 TransactionMQProducer类创建生产者,并指定唯一的 ProducerGroup,就可以设置自定义线程池来处理这些检查请求。...7 Logappender RocketMQ日志提供log4j、log4j2和logback日志框架作为业务应用,下面是配置 7.1 log4j 按下面使用log4j属性配置 log4j.appender.mq...8.1 OMSProducer 下面的示例演示如何在同步、异步或单向传输中向RocketMQ代理发送消息。

1.5K20

scala快速入门系列【类】

---- 类是一种特殊的类,它可以用来快速定义一个用于保存数据的类(类似于Java POJO类),在后续的学习并发编程和spark,flink这些框架也都会经常使用它。...定义类 语法 ?...如果要实现某个成员变量可以被修改,可以添加var 默认为val,可以省略 示例 | 定义一个类 定义一个Person类,包含姓名和年龄成员变量 创建类的对象实例(“张三”、20),并打印它...示例 | 可变成员变量 定义一个Person类,包含姓名和年龄成员变量 创建类的对象实例(“张三”、20) 修改张三的年龄为23岁,并打印 参考代码 ?...equals 方法 类自动实现了equals方法,可以直接使用==比较两个类是否相等,即所有的成员变量是否相等。

34220
领券