BigDecimal 介绍

BigDecimal 可以实现对浮点数的运算，不会造成精度丢失。

通常情况下，大部分需要浮点数精确运算结果的业务场景（比如涉及到钱的场景）都是通过 BigDecimal 来做的。

《阿里巴巴 Java 开发手册》中提到：浮点数之间的等值判断，基本数据类型不能用 == 来比较，包装数据类型不能用 equals 来判断。

基础概念与常识

Java 语言有哪些特点?

1. 简单易学；
2. 面向对象（封装，继承，多态）；
3. 平台无关性（ Java 虚拟机实现平台无关性）；
4. 支持多线程（ C++ (C++11，2011年引入多线程库)语言没有内置的多线程机制，因此必须调用操作系统的多线程功能来进行多线程程序设计，而 Java 语言却提供了多线程支持）；

一、前言

主要介绍Java 9平台模块系统(JPMS: Java 9 Platform Module System)，它是Java自诞生以来最重要的新软件工程技术。是模块化项目Jigsaw的产物，帮助开发人员在构建、维护和扩展软件系统(尤其是大型系统)时提高生产力。

二、历史

Java SE自1995年诞生以来，从用于资源受限设备的小型应用程序（如物联网（IoT）和其他嵌入式设备中的应用程序）到关键业务和关键任务系统等大型应用程序，一应俱全。随着发展，java有大量的遗留代码，但是直到现在，Java平台一直提供一站式的解决方案。但很多时候很多功能并没有被广泛使用，但是Java平台也没能使用模块化，因此诞生了Project Jigsaw^1。

1. 基础

1.1. 正确使用 equals 方法

Object的equals方法容易抛空指针异常，应使用常量或确定有值的对象来调用 equals。

举个例子：

1
2
3
4
5
6
7

// 不能使用一个值为null的引用类型变量来调用非静态方法，否则会抛出异常
String str = null;
if (str.equals("SnailClimb")) {
  ...
} else {
  ..
}

自定义消息通道

上篇文章我们提到了Sink和Source两个接口，这两个接口中分别定义了输入通道和输出通道，而Processor通过继承Source和Sink，同时具有输入通道和输出通道。这里我们就模仿Sink和Source，来定义一个自己的消息通道。

首先我们定义一个接口叫做MySink，如下：

1
2
3
4
5
6

public interface MySink {
    String INPUT = "mychannel";

    @Input(INPUT)
    SubscribableChannel input();
}

创建工程

首先我们创建一个普通的Spring Boot工程，名为stream-hello，然后添加如下依赖：

1
2
3
4
5
6
7
8

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

结合RabbitMQ，可以实现配置文件动态刷新。我们先来看下面一张架构图：

整张图的工作流程我们之前也详细的说过，当我的微服务A/微服务B启动的时候，会从Config-Server中加载配置文件，而Config-Server则会通过git clone命令将配置中心的配置文件先clone下来在本地保存一份，然后再返回给微服务A/微服务B。
这是我们之前的工作流程，现在我们结合Spring Cloud Bus来实现配置文件的动态更新。使用Spring Cloud Bus来实现配置文件的动态更新原理很简单，如上图，当我的配置文件更新后，我向Config-Server中发送一个/bus/refresh请求，Config-Server收到这个请求之后，会将这个请求广播出去，这样所有的微服务就都收到这个请求了，微服务收到这个请求之后就会自动去更新自己的配置文件。在这个系统中，从RabbitMQ的角度来看，所有的微服务都是一样的，所以这个/bus/refresh请求我们也可以在微服务节点上发出，一样能够实现配置文件动态更新的效果，但是这样做就破坏了我们微服务的结构，使得微服务节点之间有了区别，所以刷新配置的请求我们还是放在Config-Server上来做比较合适，好了，下面我们就来看看如何实现这一需求。

Arrays

Arrays 是针对数组进行操作的工具类。

常用成员方法

1
2
3

public static String toString(int[] a) //把数组转成字符串
public static void sort(int[] a) //对数组进行排序
public static int binarySearch(int[] a,int key) //二分查找

Kafka下载

Kafka现在是Apache上的开源项目，直接到官网下载即可(http://kafka.apache.org/)，这个不用我多说。

启动

下载成功之后，是一个压缩文件，解压该文件，我们可以看到一个bin目录，进入到bin目录中，bin目录下的.sh文件都是Linux/Unix下的shell脚本，在Linux/Unix环境下直接运行这些脚本即可，bin目录中还有一个windows目录，该目录下存储的都是windows中的批处理文件。我们在运行时根据自己的操作系统选择合适的命令去执行，本文以windows为例。解压后为了后面的命令操作方便，我将windows文件配置到环境变量中，我的是D:\Program\kafka_2.11-0.11.0.1\bin\windows,然后在cmd中进入到解压目录下，执行zookeeper-server-start.bat .\config\zookeeper.properties命令，表示启动zookeeper（由于Kafka依赖的zookeeper，所以我们要先启动zookeeper再启动Kafka），如下：

一、配置虚拟机和 zookeeper

首先关闭 Linux 的防火墙：systemctl stop firewalld 然后可以使用 systemctl status firewalld 进行确认。

如果本机和虚拟机之间的网络连接方式为：NAT，则注意实际上连接

• 虚拟机终端输入ifconfig查看 ens33 下的端口号

• 查看主机与虚拟机之间通信是否畅通