个人简介

Echo Blog


江湖无名 安心练剑
  • RocketMQ-05-example 例子
    1 基本样例 在基本样例中我们提供如下的功能场景: 使用RocketMQ发送三种类型的消息:同步消息、异步消息和单向消息。 其中前两种消息是可靠的,因为会有发送是否成功的应答。 使用RocketMQ来消费接收到的消息。 引入依赖 <dependency> <groupId>org.apache.rocketmq</groupId> ...
    2022-03-18 13:01:55 | MQ
  • RocketMQ-04-设计
    1 消息存储 消息存储是RocketMQ中最为复杂和最为重要的一部分,本节将分别从RocketMQ的消息存储整体架构、PageCache与Mmap内存映射以及RocketMQ中两种不同的刷盘方式三方面来分别展开叙述。 1.1 消息存储整体架构 消息存储架构图中主要有下面三个跟消息存储相关的文件构成。 (1) CommitLog:消息主体以及元数据的存储主体,存储Producer端...
    2022-03-18 13:01:55 | MQ
  • RocketMQ-03-架构设计
    1 技术架构 RocketMQ架构上主要分为四部分,如上图所示: Producer:消息发布的角色,支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递,投递的过程支持快速失败并且低延迟。 Consumer:消息消费的角色,支持分布式集群方式部署。支持以push推,pull拉两种模式对消息进行消费。同时也支持集群方式和广播方式的消费,...
    2022-03-18 13:01:55 | MQ
  • RocketMQ-02-特性
    1 订阅与发布 消息的发布是指某个生产者向某个topic发送消息;消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息,进而从该topic消费数据。 2 消息顺序 消息有序指的是一类消息消费时,能按照发送的顺序来消费。 例如:一个订单产生了三条消息分别是订单创建、订单付款、订单完成。 消费时要按照这个顺序消费才能有意义,但是同时订单之间是可以并行消费的。RocketM...
    2022-03-18 13:01:55 | MQ
  • RocketMQ-01-基本概念
    1 消息模型(Message Model) RocketMQ主要由 Producer、Broker、Consumer 三部分组成,其中Producer 负责生产消息,Consumer 负责消费消息,Broker 负责存储消息。 Broker 在实际部署过程中对应一台服务器,每个 Broker 可以存储多个Topic的消息,每个Topic的消息也可以分片存储于不同的 Broker。 Me...
    2022-03-18 13:01:55 | MQ
  • SMS 中国网建之 java 如何实现短信发送?
    中国网建 官网:中国网建 java 例子 public static void main(String[] args) { //获得http链接对象 HttpClient httpClient = HttpClient.singleInstacne(); String url="http://utf8.api.smschinese.cn"; //中国网建...
    2022-03-18 13:01:55 | TOOL
  • SMS aliyun 华为云之 java 如何实现短信发送?
    java 例子 依赖包 httpclient、httpcore、commons-codec、commons-logging、org.json 发送短信(示例1) import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.Out...
    2022-03-18 13:01:55 | TOOL
  • SMS aliyun 阿里云之 java 如何实现短信发送?
    准备工作 本接口主要适用于短信单发场景,特殊场景下可支持群发(最多可向1000个手机号码发送同样内容的短信),但群发会有一定延迟。 步骤1:创建阿里云账号 为了访问短信服务,您需要有一个阿里云账号。如果没有,可首先按照如下步骤创建阿里云账号: 访问阿里云官方网站,单击页面上的免费注册按钮。 按照屏幕提示完成注册流程并进行实名认证, 短信服务只支持实名认证用户使用。 为了更好地使用阿...
    2022-03-18 13:01:55 | TOOL