业务场景

公司采购了一台新的硬件服务器，领导说用tomcat搭建一台web服务器吧，这个任务看起来简单，但是很繁琐

• 安装linux系统
• 下载jdk,tomcat,
• 安装jdk，配环境变量
• 安装tomcat

即使对于一个老司机，也要花挺长时间，但是使用docker可以很大的简化这个过程

查看可用镜像

在docker官网搜索tomcat组件，在每个tag中可以看到具体使用的JDK版本和Tomcat版本
tocmat可用版本

一、Rabbit 概述

RabbitMQ 是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用中间共享数据，RabbitMQ 是使用 Erlang 语言来编写的，并且 RabbitMQ 是基于 AMQP 协议的。

特点：

• 开源、性能优秀

  Erlang 语言最初用在交换机的架构模式，这样使得 RabbitMQ 在 Broker 之间进行数据交互的性能时非常优秀的。Erlang 的优点：Erlang 有着和原生 Socket 一样的延迟。

环境准备

1. 安装docker持久化包和yum工具包

   1 2 3 4 5

   install -y yum-utils device-mapper-persistent-data lvm2```- yum-utils 简化yum安装的工具包，后面会用到相关命令修改镜像加速，非必选 - device-mapper-persistent-data lvm2：安装docker数据存储的驱动包,必须安装 2. 修改镜像安装源到阿里云加速,默认是国外的下载比较慢 ```yum-config-manager --add-repo http://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo

事务消息的原理

下面来看 RocketMQ 的事务消息是如何来发送“可靠消息”的，只需要以下三步：

RocketMQ原生API收发消息代码样例

pom文件

新建 maven 项目或 module，添加 rocketmq-client 依赖。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.tedu</groupId>
    <artifactId>demo1</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>4.7.1</version>
        </dependency>

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-store</artifactId>
            <version>4.7.1</version>
        </dependency>

    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

安装配置 jdk8

1. 上传jdk压缩文件

将文件jdk-8u212-linux-x64.tar.gz上传到 /root 目录

2. 解压缩

执行解压命令

1
2
3
4
5
6

# 将jdk解压到 /usr/local/ 目录
tar -xf jdk-8u212-linux-x64.tar.gz -C /usr/local/

# 切换到 /usr/local/ 目录, 显示列表, 查看解压缩的jdk目录
cd /usr/local
ll

kafka 的索引文件以稀疏索引的方式构造消息的索引，每个 segmentfault 文件，对应 2 个索引文件。偏移量索引文件(xx.index)用于建立消息偏移量到物理地址之间的映射关系；时间戳索引文件(xx.timeindex)根据指定的时间戳查找对应的偏移量信息。

.index、.timeindex 均保持严格单调递增，在查找时，都使用二分查找法，如果查不到，均返回比查找值要小的最大值。

日志切分

当日志分段文件满足以下几个条件任意之一，便会切分索引文件

优先副本的选举

当我们输入以下命令，

1

kafka-topics.sh  --zookeeper zookeeper:2181  --describe  --topic test4

1、日志文件布局

__consumer_offset 存储着消费者提交的消费位移

kafka 允许通过配置 partition.assignment.strategy 来改变消费组的分区策略。
kafka 提供了以下几个分区策略

• RangeAssignor
• RoundRobinAssignor
• StickyAssignor

默认使用的是 RangeAssignor

同时，kafka 也允许我们自定义分区策略，只需要继承 AbstractPartitionAssignor 抽象类即可。