服务器中的topic是什么意思(服务器contact support)

Mqtt介绍一

1、MQTT服务器以称为消息代理（Broker），可以是一个应用程序或一台设备。它是位于消息发布者和订阅者之间，它可以：订阅包含主题筛选器（Topic Filter）和最大服务质量（QoS）。订阅会与一个会话（Session）关联。

2、MQTT规范定义了MQTT客户端实现和MQTT服务端实现的一致性要求 MQTT实现可以同时是MQTT客户端和MQTT服务端。接受入站连接和建立到其它服务端的出站连接的服务端必须同时符合MQTT客户端和MQTT服务端的要求 。

3、MQTT（消息队列遥测传输）最初由 IBM 于上世纪 90 年代晚期发明。

4、MQTT (Message Queuing Telemetry Transport，消息队列遥测传输) 是一种基于 TCP/IP 协议族的应用层协议。MQTT 协议是专门针对硬件性能低下 & 网络状况不稳定的场景设计的，这使得 MQTT 在物联网和移动应用等受限场景得到广泛应用。

5、MQTT设计了一套保证消息稳定传输的机制，包括消息应答、存储和重传。

6、MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议。它是一种发布/订阅，极其简单和轻量级的消息传递协议，专为受限设备和低带宽，高延迟或不可靠的网络而设计。

消息中间件之Kafka

Record： 写入kafka中的消息，每个消息包含了key、value和timestamp。生产者-消费者是一种设计模式，是在生产者和消费者之间添加一个中间件来达到解耦的目的。

这几个模式里边有个关键点—需要通过把领域事件发布给远程的其他服务，完成数据同步。这就需要消息中间件了，消息中间件这块我了解的也不深，公司里用RocketMQ，不过付费版和开源版差别很大。

Apache ActiveMQ：Apache ActiveMQ是一个基于Java的开源消息中间件，支持多种协议，包括AMQP和WebSocket。它提供了WebSocket连接和消息发布/订阅功能。

消息队列原理及选型

1、解耦： 如果使用多线程进行异步，这样会造成与下游系统耦合，每对接一个系统，会增加一个接口调用，然后重新发布系统。使用消息队列，将消息发布到消息队列中，下游系统直接监听审批过程消息来感知审批进度，达到解耦目的。

2、即消息的Ackownledge确认机制，为了保证消息不丢失，消息队列提供了消息Acknowledge机制，即ACK机制，当Consumer确认消息已经被消费处理，发送一个ACK给消息队列，此时消息队列便可以删除这个消息了。

3、ActiveMQ工作原理：首先来看本地通讯的情况，应用程序A和应用程序B运行于同一系统A，它们之间可以借助消息队列技术进行彼此的通讯：应用程序A向队列1发送一条信息，而当应用程序B需要时就可以得到该信息。

4、Redis实现消息队列原理 常用的消息队列有RabbitMQ，ActiveMQ，个人觉得这种消息队列太大太重，本文介绍下基于Redis的轻量级消息队列服务。 一般来说，消息队列有两种模式，一种是发布者订阅模式，另外一种是生产者和消费者模式。

kafka极简入门(三)--创建topic

1、回顾 kafka极简入门(二)--安装 topic是kafka的生产者和消费者最小交互的单位，我们先从topic入手，创建第一个topic.或 所以执行上面命令将会创建一个名为mytest的topic，该topic下面有1个分区，并且该分区只有1个副本。

2、在使用kafka发送消息和消费消息之前，必须先要创建topic，在kafka中创建topic的方式有以下3种：通过 kafka-topics.sh 脚本来创建一个名为 topic-test1 并且副本数为分区数为4的topic。

3、实际上 Topic 的创建在 Kafka 源码解析之 topic 创建过程（三） 中已经讲述过了，本篇与前面不同的是，本篇主要是从 Controller 角度来讲述，而且是把新建、扩容、删除这三个 Topic 级别的操作放在一起做一个总结。

4、Kafka创建topic命令很简单，一条命令足矣：bin/kafka-topics.sh --create --zookeeper localhost：2181 --replication-factor 3 --partitions 3 --topic test 。

SpringBoot整合RocketMQ

需要去管控台手工创建topic，或者将SpringBoot依赖的RocketMQ版本与服务端RocketMQ的版本改成一样的，也可以。例如我的pom.xml文件中，依赖的版本是0，而服务器上部署的RocketMQ版本是0，就不会自动创建topic。

RocketMQ创建多个消费者、同一个消费组消费同一Topic的不同tag的消息发生报错。实现RocketMQPushConsumerLifecycleListener接口，重写prepareStart，consumer.setInstanceName。设置唯一标识的instanceName即可。

[TOC]Spring Boot作为简化Spring开发的框架，已经为我们集成了ActiveMQ和RabbitMQ。只需在Spring Boot配置几个MQ的连接方式即可开箱即用。大大简化了开发配置过程。

RocketMQ：一直纠结kafka与rocketMQ，最终选择了RocketMQ 为了性能上面的考虑，尽量使用异步编程，比如注册送优惠券，那么注册成功就可以给用户返回注册成功了，但是送优惠券可以是异步调用的，不阻塞注册的线程。

RocketMQ基本概念介绍

1、如图所示为RocketMQ基本的部署结构，主要分为NameServer集群、Broker集群、Producer集群和Consumer集群四个部分。NameServer的作用是注册中心，类似于Zookeeper，但又有区别于它的地方。

2、RocketMQ在阿里内部叫做Metaq（最早名为Metamorphosis，中文意思 变形记 ，是作家卡夫卡的中篇小说代表作，可见是为了致敬Kafka）。RocketMQ是Metaq0之后的开源版本。

3、RocketMQ中有两个核心模块，remoting模块和store模块。remoting模块在NameServer，Produce，Consumer和Broker都用到。store只在Broker中用到，包含了存储文件操作的API，对消息实体的操作是通过DefaultMessageStore进行操作。

4、RocketMQ中的消息生产者都是以生产者组(Producer Group)的形式出现的。生产者组是同一类生产者的集合，这类Producer发送相同Topic类型的消息。一个生产者组可以同时发送多个主题的消息。消息消费者，负责消费消息。

5、常见消息中间件MQ介绍 1 RocketMQ 阿里系下开源的一款分布式、队列模型的消息中间件，原名Metaq，0版本名称改为RocketMQ，是阿里参照kafka设计思想使用java实现的一套mq。

6、如下介绍存储，rocketMQ可配置主备，形成主备复制。