认识模块化的好处,如何建立模块与模块之间的访问
咱就是说,为啥咋好端端的要引入模块化的概念?
模块独立、化繁为简
模块化(以 Java 平台模块系统的形式)将 JDK 分成一组模块,可以在编译时,运行时或者构建时进行组合
主要目的在于减少内存的开销
只须必要模块,而非全部jdk模块,可简化各种类库和大型应用的开发和维护
改进其安全性,可维护性,提高性能咱就是讲,模块(module)的概念,其实就是package外再裹一层,也就是说,用模块来管理各个package,通过声明某个package暴露,不声明默认就是隐藏。因此,模块化使得代码组织上更安全,因为它可以指定哪些部分可以暴露,哪些部分隐藏。
下面就来具体演示一下如何玩转模块化系统
如何让MoudleB指定A的存在呢? 首先,在模块A中将Utils类暴露出来:
module MoudleA {
//暴露com文件夹下面所有类
exports com;
}
java的编程模式是:编辑,保存,编译,运行和调试。
有时候我们需要快速看到某个语句的结果的时候,还需要写上public static void main(String[] args)这些无谓的语句,减低我们的开发效率。
JDK9引入了交互式编程,通过jshell工具即可实现,交互式编程就是指我们不需要编写类我们即可直接声明变量,方法,执行语句,不需要编译即可马上看到效果。
交互式编程的作用:即时反馈
前提配置了系统环境变量,jdk版本为9+
交互编程是什么,其作用是什么?
即时反馈, 马上能够看到语句的执行结果
多版本JAR(MR JAR)可能包含同一类的多个变体,每个变体都针对特定的Java版本。 在运行时,类的正确变体将被自动加载,这取决于所使用的Java版本
。这允许库作者在早期利用新的Java版本,同时保持与旧版本的兼容性。
在Java 9增强了JAR多版本字节码文件格式的支持,同一个Jar包可以包含多个Java版本的class文件。使用这个功能,我们可以将应用程序/库升级到新的Java版本,而不必强迫用户升级到相同的Java版本。
应用场景
:比如某个架构师开发了一个工具类MyUtils,该工具类里面使用了jdk9的新特性,这时候该工具在推广的时候会遇到很大的阻力,因为很多用户还没有升级jdk版本,JDK9推出了多版本兼用jar的特性就允许该架构师编写一个同类名的工具MyUtils,并在该工具类中不使用jdk9的新特性,然后两个同类名的类一起打包成为一个jar,提供给用户去使用,这时候即可根据用户当前使用的jdk版本而选择不同的工具类了。
简言之:该jar包在java 8中可以执行最上层的MyUtils.class,在Java 9中自动选择执行目录9下的MyUtils.class。
多版本的字节码发行jar包,需要在其MANIFEST.MF中做以下的声明:
Multi-Release: true
在jar
包的META-INF/versions
文件目录里面可以包含多个版本的class
文件,编译结果目录结构如下:
jar root
- A.class
- B.class
- META-INF
- versions
- 9
- A.class
假设上文中的根目录是使用java 8 或之前版本编译的字节码文件A.calss。META-INF/versions/9/是使用java 9 编写的java代码的编译结果A.class。
META-INF/versions/9/
下面的class文件进行程序运行。假设未来这个项目升级JDK 10,决定在A.java中使用Java 10的一些新特性,可以单独针对A.class进行语法升级,并将编译结果a.class放置在META-INF/versions/10/
下面
jar root
- A.class
- B.class
- META-INF
- versions
- 9
- A.class
- 10
- A.class
现在,上面的jar包含了可以以三种Java版本运行的字节码文件,A.class兼容JDK 8、9、10。
下面的类文件代码我们让它运行在Java 8的环境下
package com.example;
public class IOUtil {
public static String convertToString(InputStream inputStream) throws IOException {
System.out.println("IOUtil 使用java 8 版本");
Scanner scanner = new Scanner(inputStream, "UTF-8");
String str = scanner.useDelimiter("\\A").next();
scanner.close();
return str;
}
}
增加一个Main.java的应用程序入口文件,调用IOUtil.convertToString方法将InputStream转换成String。
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
public class Main {
public static void main(String[] args) throws IOException {
InputStream inputStream = new ByteArrayInputStream("测试字符串".getBytes());
String result = IOUtil.convertToString(inputStream);
System.out.println(result);
}
}
在Java 9 发布之后,我们决定使用Java 9 的新的语法重写IOUtil.convertToString方法。
public class IOUtil {
public static String convertToString(InputStream inputStream) throws IOException {
System.out.println("IOUtil 使用java 9 版本");
try (inputStream) { //Java9版本的增强try-with-resources
String str = new String(inputStream.readAllBytes());
return str;
}
}
}
如上的代码所示,我们使用了Java 9的两个新特性带有inputStream引用的try-with-resource块和新的InputStream.readAllBytes()方法。
将Java8 、Java9的IOUtil.java代码分别在JDK8、JDK9的版本下分别编译成class字节码文件,并将class文件按照如下的目录结构打成保存,并打jar包。(先按java8版本打成jar包,然后修改MANIFEST.MF文件,添加java 9字节码class文件即可)
D:\multi-release-jar-example\my-lib-jar>tree /A /F
+---com
| \---example
| IOUtil.class
| Main.class
|
\---META-INF
| MANIFEST.MF
|
\---versions
\---9
\---com
\---example
IOUtil.class
在JDK 9的环境下运行这个jar包
D:\multi-release-jar-example>java -cp my-lib.jar com.example.Main
IOUtil 使用java 9 版本
测试字符串
在JDK 8的环境下运行这个jar包
D:\multi-release-jar-example>C:\jdk1.8.0_151\bin\java -cp my-lib.jar com.example.Main
IOUtil 使用java 8 版本
测试字符串
多版本兼用jar的作用。
根据当前用户安装的jdk版本选择性的使用具体类。
当我们在一个接口里写多个默认方法或者静态方法的时候,可能会遇到程序重复的问题。我们可以把这些重复的程序提取出来,创建一个新的方法,用private进行修饰,这样就创造了一个只有接口可以调用的私有方法。
这些私有方法将改善接口内部的代码可重用性。例如,如果需要两个默认方法来共享代码,则私有接口方法将允许它们共享代码,但不将该私有方法暴露给它的实现类调用(后文中会给大家举一个例子)。
在接口中使用私有方法有四个规则:
接口中private方法不能是abstract抽象方法。因为abstract抽象方法是公开的用于给接口实现类实现的方法,所以不能是private。
接口中私有方法只能在接口内部的方法里面被调用。
接口中私有静态方法可以在其他静态和非静态接口方法中使用。
接口中私有非静态方法不能在私有静态方法内部使用。
interface CustomInterface {
public abstract void abstractMethod(); //抽象方法不能是私有的
public default void defaultMethod() {
privateMethod(); //可以调用接口中的私有方法
privateStaticMethod(); //可以调用接口中的私有静态方法
System.out.println("普通方法被调用");
}
public static void staticMethod() {
privateStaticMethod(); //public静态方法可以调用private静态方法
System.out.println("静态方法被调用");
}
private void privateMethod() {
System.out.println("private私有方法被调用");
}
private static void privateStaticMethod() {
System.out.println("private私有静态方法被调用");
}
}
按照上面四个规则,上面的代码定义都是正确的
public interface UserDao {
default void methodA() {
System.out.println("methodA...");
System.out.println("A....");
System.out.println("B....");
System.out.println("C....");
}
default void methodB() {
System.out.println("methodB...");
System.out.println("A....");
System.out.println("B....");
System.out.println("C....");
}
}
存在的问题: 以上代码的methodA与methodB存在着代码冗余问题,我们可以把这部分公共的方法抽取成私有的方法提供给接口内部去使用。
接口私有方法的作用:解决接口中默认方法与静态方法代码重复的问题
public interface UserDao {
default void methodA() {
System.out.println("methodA...");
commons();
}
default void methodB() {
System.out.println("methodB...");
commons();
}
//定一个私有的方法,把重复部分的代码抽离出来。然后在methodA与methodB方法内部去调 用。
// 私有方法只能在本类中调用,这里包括接口的实现类也不能调用。
private void commons() {
System.out.println("A....");
System.out.println("B....");
System.out.println("C....");
}
}
测试代码
public class UserDaoImpl implements UserDao {
public static void main(String[] args) {
UserDaoImpl userDao = new UserDaoImpl();
userDao.methodA();
userDao.methodB();
}
}
接口定义如下,下文中add方法采用了java8 的Stream流操作,分别使用lambda表达式作为过滤条件,并求和。
核心是:addEvenNumbers偶数求和函数和addOddNumbers奇数求和函数,都调用了add
接口私有方法。
import java.util.function.IntPredicate;
import java.util.stream.IntStream;
public interface CustomCalculator {
default int addEvenNumbers(int... nums) { //非抽象,java8 开始可以定义default方法
return add(n -> n % 2 == 0, nums); //过滤偶数并求和,调用private私有方法
}
default int addOddNumbers(int... nums) { //非抽象,java8 开始可以定义default方法
return add(n -> n % 2 != 0, nums); //过滤奇数并求和,调用private私有方法
}
//按照过滤条件过滤奇数或偶数并sum求和:java9开始可以定义private私有方法
private int add(IntPredicate predicate, int... nums) {
return IntStream.of(nums) //java8 Stream流
.filter(predicate) //java8 predicate及过滤器
.sum(); //sum求和
}
}
接口实现类MainCalculator 实现CustomCalculator接口
public class MainCalculator implements CustomCalculator {
public static void main(String[] args) {
CustomCalculator demo = new MainCalculator ();
int sumOfEvens = demo.addEvenNumbers(1,2,3,4,5,6,7,8,9);
System.out.println(sumOfEvens); //过滤所有偶数并求和,结果是20
int sumOfOdds = demo.addOddNumbers(1,2,3,4,5,6,7,8,9);
System.out.println(sumOfOdds); //过滤所有奇数并求和,结果是25
}
}
清楚接口方法私有化的目的?
如何在接口中定义私有化的方法以及调用?
在Java 7
之前没有try-with-resources
语法,所有的流的销毁动作,全都需要自己在finally
方法中手动的写代码进行关闭。
如下文中的代码,将一个字符串写入到一个文件里面。
public class ResourcesTest {
@Test
void testStream() throws IOException {
String fileName="D:\\data\\test\\testStream.txt";
FileOutputStream fos = new FileOutputStream(fileName); //创建IO管道流
OutputStreamWriter osw = new OutputStreamWriter(fos);
BufferedWriter bw = new BufferedWriter(osw);
try{
bw.write("手写代码进行Stream流的关闭");
bw.flush();
}finally{
bw.close(); //手动关闭IO管道流
osw.close();
fos.close();
}
}
}
从Java 7
版本开始提供了try-with-resources
语法,我们只需要把管道流用try()
包含起来,在try
代码段执行完成之后,IO
管道流就会自动的关闭,不需要我们手写代码去关闭,这很简洁!
@Test
void testTry() throws IOException {
String fileName = "D:\\data\\test\\testStream.txt";
try (FileOutputStream fos = new FileOutputStream(fileName);
OutputStreamWriter osw = new OutputStreamWriter(fos);
BufferedWriter bw = new BufferedWriter(osw);) {
bw.write("IO管道流被自动调用close()方法");
bw.flush();
}
}
注意:JDK8开始已经不需要我们再手动关闭资源,只需要把要关闭资源的代码放入try语句中即可,但是要求初始化资源的语句必须位于try语句中
很多小伙伴在知道try-with-resources
语法之后,容易陷入误区
IO
管道流才能使用try-with-resources
语法,进行自动的资源关闭close()
方法的类对象,都会自动的调用close()
方法进行资源关闭误区一把实践范围缩小了,而误区二把实践范围夸大了。那么什么样的资源可以被自动关闭呢?答案就是实现了AutoCloseable或Closeable接口的类可以自动的进行资源关闭。
public interface Closeable extends AutoCloseable {
public void close() throws IOException;
}
Closeable
接口继承自AutoCloseable
接口,二者都包含close()
方法。
如果你自定义的占用系统资源的类需要进行资源回收,请实现这两个接口之一,并在close()
方法中进行资源回收与关闭。这样你自定义的类,也可以使用try-with-resources
语法进行资源回收与关闭。
try-with-resources
语法在java 9
中进行了改进,try-with-resources
语法的try()
可以包含变量,多个变量用分号隔开。
\这样的改进目的是让语义更加明确,将资源创建代码与尝试资源回收的语法分离。
try()
包含的变量@Test
void testJava9Try() throws IOException {
String fileName = "D:\\data\\test\\testStream.txt";
FileOutputStream fos = new FileOutputStream(fileName);
OutputStreamWriter osw = new OutputStreamWriter(fos);
BufferedWriter bw = new BufferedWriter(osw);
try(bw;osw;fos){ //注意这里:尝试去回收这三个对象对应的资源,和上文中的java 7代码对比
bw.write("Java9-可以被自动调用close()方法");
bw.flush();
}
}
public class Demo1 {
public static void main(String[] args) {
String _ = "hello";
System.out.println(_);
}
}
以上代码不会报错,允许_作为标识符
public class Demo1 {
public static void main(String[] args) {
String _ = "hello";
System.out.println(_);
}
}
以上代码报错,jdk9开始不允许_作为标识符
jdk9为标识符定义了什么的新规则
原文:
The current implementation of the String class stores characters in a char array, using two bytes
(sixteen bits) for each character. Data gathered from many different applications indicates that
strings are a major component of heap usage and, moreover, that most String objects contain
only Latin-1 characters. Such characters require only one byte of storage, hence half of the space
in the internal char arrays of such String objects is going unused.
翻译:
string类的当前实现将字符存储在char数组中,每个字符使用两个字节(16位)。
从许多不同的应用程序收集的数据表明,字符串是堆使用的主要组成部分,而且,大多数字符串对象只包含拉丁-1字符。
这样的字符只需要一个字节的存储空间,因此这样的字符串对象的内部字符数组中的一半空间将被闲置
。
节省内存空间。
Stirng类内部维护一个字符数组变化为维护一个字节数组。
由于String类底层已经发生变化,所以StringBuilder与StringBuffer底层也相应的发生了改变。
String-related classes such as AbstractStringBuilder, StringBuilder, and StringBuffer will be
调用集合中静态方法 of()
,可以将不同数量的参数传输到此工厂方法中。
此功能可用于 Set 和 List,也可用于 Map 的类似形式。此时得到 的集合,是不可变的:
List.of
Set.of
Map.of
Java 9 提供了一系列的工厂方法of()来更加简便的构建Set集合对象。使用of()方法构建java.util.Set我们就不用一个元素一个元素的add()数据了。但需要注意的是:这种方法构建的Set集合类对象一旦构建就不能更改,不能再新增集合元素。
Set<Integer> integers = Set.of(2, 6, 7, 10);
//顺序改变是因为set底层是hash桶
System.out.println(integers); //[2, 10, 6, 7]
还有许多重载的of()工厂方法供我们使用
of()//空的set
of(E)
of(E, E)
of(E, E, E)
//更多 ......
of(E, E, E, E, E, E, E, E, E, E )// 一直到十个元素
of(E...)//更多参数
和Set集合类似,List集合类也新增了一系列的of()工厂函数,创建不可变的List集合对象。
List<Integer> integers = List.of(2, 6, 7, 10);
System.out.println(integers); // [2, 6, 7, 10]
虽然Map不是Colleaction的子类,但是我们一般也把它当作集合类学习。
Map类同样新增了一系列的of()工厂函数,创建不可变的Map对象。
唯一的区别是使用Key/Value的形式传递参数。
Map<Integer, String> map = Map.of(2, "two", 6, "six");
System.out.println(map); // {2=two, 6=six}
工厂方法Map.ofEntries
接受Map.Entry
作为varargs
。还有另一个相关的新静态方法Map.entry(K, V)
来创建Entry
实例。
Map<Integer, String> map = Map.ofEntries(Map.entry(2, "two"), Map.entry(4, "four"));
System.out.println(map); //{2=two, 4=four}
通过of方法创建的集合对象是不能修改集合中的元素的,如果强行修改就会出现 UnsupportedOperationException
Arrays是我们进行集合操作的工具类,在Java 9 版本中也进行了增强。
这些新方法用于查找两个数组之间的第一个不匹配索引
。
例如,下面的代码查找两个整数数组之间的第一个不匹配项。如果没有不匹配,则此方法将返回-1。
int[] ints1 = {1, 3, 5, 7, 9};
int[] ints2 = {1, 3, 5, 6, 7};
int i = Arrays.mismatch(ints1, ints2);
System.out.println(i); //3
另一个这样的方法接受fromIndex
和toIndex
参数来查找相对不匹配的索引。例如:
int mismatch(int[] a, int aFromIndex, int aToIndex,
int[] b, int bFromIndex, int bToIndex)
从arrayA的索引第1个元素,arrayB索引第2个元素开始的区间内,进行第一个不匹配项目的查找。
int[] arrayA = {-2, 1, 3, 5, 7, 9};
int[] arrayB = {-1, 0, 1, 3, 5, 7, 10};
int j = Arrays.mismatch(arrayA, 1, arrayA.length, arrayB, 2, arrayB.length);
System.out.println(j);
和Arrays.mismatch()
有些相似,Arrays.equals()
用来判断两个数组区间内的元素是否相等。
新方法为两个被比较的数组新增了fromIndex和toIndex
参数。
这些方法根据两个数组的相对索引位置检查两个数组的相等性。
String[] sa = {"d", "e", "f", "g", "h"};
String[] sb = {"a", "b", "c", "d", "e", "f"};
boolean b = Arrays.equals(sa, 0, 2, sb, 3, 5);
System.out.println(b); //true
从sa数组的索引0-2,与sb数组的索引3-5的元素进行比对。结果为true相等。
在Java 9中对Java Util Stream的语法进行了优化和增强,下面我就和大家一起看一下有哪些比较有价值的使用方法。
翻译名字:保留集合中的元素直到不满足指定条件为止,保留所有满足条件的元素
在进行Stream
流的管道数据处理的时候,提供的Predicate
条件返回false
之后,将跳过剩余的数据元素直接返回。
在下面的示例中,一旦Predicate
条件!"orange" .equals(s)
返回false
,则将跳过其他元素:
String[] fruits = {"apple", "banana", "orange", "mango", "peach"};
Stream<String> stream = Arrays.stream(fruits)
.takeWhile(s -> !"orange".equals(s));
stream.forEach(System.out::println);
控制台输出结果为,依次对数组中元素过滤,到orange
元素满足了!"orange" .equals(s) === false
,流式处理不再继续直接返回。
apple
banana
需要注意的是:对于无序Stream,如果存在多个与提供的Predicate匹配的元素(多个orange),则此操作返回值是不确定的。
这种方法看上去和Java 8
中的Stream.filter()
很相似,但是它们的不同之处在于filter()
方法只是跳过了不匹配的元素,然后继续进行处理。
然而takeWhile()
方法在存在不匹配项之后会跳过所有剩余的元素,有点像continue和break
的区别。以下是具有相同流和Predicate的filter()方法示例:
String[] fruits = {"apple", "banana", "orange", "mango", "peach"};
Stream<String> stream = Arrays.stream(fruits).filter(s -> !"orange".equals(s));
stream.forEach(System.out::println);
控制台输出如下,只是把orange过滤掉了。
apple
banana
mango
peach
翻译名字:删除集合中的元素直到不满足指定条件为止,即删除掉所有满足条件的元素
提供的Predicate条件在管道流中返回false之后,此元素后面的所有数据元素作为返回值返回。
String[] fruits = {"apple", "banana", "orange", "mango", "peach"};
Stream<String> stream = Arrays.stream(fruits)
.dropWhile(s -> !"orange".equals(s));
stream.forEach(System.out::println);
在上面示例中,一旦Predicate
条件!"orange".equals(s)
返回false
,管道流中剩余的元素将被接受(不被过滤),作为返回值返回
:
orange
mango
peach
循环遍历一直对种子进行处理,直到不满足条件为止,遍历过程中对种子的处理过程交给UnaryOperator(单元素处理器)处理
一旦Predicate条件返回false,此方法将返回一个顺序流,该顺序流将停止迭代操作。T为初始值,迭代操作由UnaryOperator来提供
功能其实下面这样
//第一个对应T,第二个对应Predicate,第三个对应UnaryOperator
for (T index=seed; hasNext.test(index); index = next.apply(index)) { ... }
Stream<String> iterate = Stream.iterate("-",
s -> s.length() < 5, //Predicate条件
s -> s + "-"); //迭代操作
iterate.forEach(System.out::println);
控制台打印输出的结果,只输出四个横杠,到第五个的时候停止。这是由Predicate条件决定的。
-
--
---
----
ofNullable()
: Java 8 中 Stream 不能完全为 null(一个元素不能为 null 多个元素是可以存在 null),否则会报空指针异常。而 Java 9 中的 ofNullable 方法允许我们创建一个单元素 Stream,可以包含一个非空元素,也可 以创建一个空 Stream。
此方法返回一个包含单个元素的顺序Stream。如果提供的元素为null,则此方法返回空Stream。当我们要将非空单个元素附加到流时,此方法很有用。例如:
String nullableItem = "peach";
Stream<String> stream = Stream.of("apple", "banana", "orange");
Stream<String> stream2 = Stream.concat(stream, Stream.ofNullable(nullableItem));
stream2.forEach(System.out::println);
控制台打印输出结果如下:
apple
banana
orange
peach
下面的这些XxxStream类也具有与Stream类等效的方法(ofNullable()方法除外)。
IntStream.of(2, 4, 6, 8, 9, 10, 11)
.takeWhile(i -> i % 2 == 0)
.forEach(System.out::println); //2,4,6,8
IntStream.of(2, 4, 6, 8, 9, 10, 11)
.dropWhile(i -> i % 2 == 0)
.forEach(System.out::println); // 9,10,11
IntStream.iterate(0, i -> i < 10, i -> i + 1)
.forEach(System.out::print); // 0123456789
在 java.awt.image
包下新增了支持多分辨率图片的API
,用于支持多分辨率的图片。
getResolutionVariant(double destImageWidth, double destImageHeight)
方法,这里只做简单使用演示,后续会出对HTTPClinet使用详细解析篇
httpClient的作用就是用于获取网络资源的
,Java 9 中有新的方式来处理 HTTP 调用。
它提供了一个新的 HTTP 客户端(HttpClient ), 它 将替代仅适用于 blocking 模式的 HttpURLConnection(HttpURLConnection是在HTTP 1.0的时代创建的, 并使用了协议无关的方法),并提供对WebSocket 和 HTTP/2 的支持。
全新的HTTP客户端API可以从jdk.incubator.httpclient
模块中获取。
因为在默认情况下,这个模块是不能根据 classpath 获取的,需要使 用 add modules 命令选项配置这个模块,将这个模块添加到classpath 中。
因为我这里使用的是jdk11,所以讲一下jdk11中对httpClient的改变
变化:
一: 从java9的jdk.incubator.httpclient模块迁移到java.net.http模块,包名由jdk.incubator.http改为java.net.http
二: 原来的诸如HttpResponse.BodyHandler.asString()方法变更为HttpResponse.BodyHandlers.ofString(),变化一为BodyHandler改为BodyHandlers,变化二为asXXX()之类的方法改为ofXXX(),由as改为of
public class DhyHttpClient {
public static void main(String[] args) throws URISyntaxException, IOException, InterruptedException {
//1.创建HttpClient对象
HttpClient httpClient = HttpClient.newHttpClient();
//2.创建请求的构造器
HttpRequest request = HttpRequest.newBuilder(new URI("http://www.baidu.com"))
//设置请求头
.header("user-agent", "dhy")
//设置请求方式
.GET()
.build();
//发送请求,并设置返回值处理器
HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
System.out.println("响应状态码: "+response.statusCode());
System.out.println("响应的信息: "+response.body());
}
}
HttpClient发送请求的步骤
并且随着对安全要求的提高,主流浏览器已经取消对 Java 浏览器插件的支持。HTML5 的出现也进一步加速了它的消亡。开发者现在可以使用像 Java Web Start 这样的技术来代替 Applet,它可以实现从浏览器启动应用程序或者安装应用程序。
JDK8 生成的java帮助文档是在 HTML4 中。而HTML4 已经是很久的标准了。
JDK9 的javadoc,现支持HTML5 标准。
下图是JDK8 API的HTML页面
动态编译器出现的目的就是为了提高编译的效率。 sjavac(smarter java compilation)最早在openjdk8中提供了初级版本,其初衷是用来加速jdk自己的编译。在9中进行过一版优化,使其更加稳定可靠,能够用来编译任意的大型java项目。sjavac在javac的基础上实现了:
钻石操作符是在 java 7 中引入的,可以让代码更易读,但它不能用于匿名的内部类。
在 java 9 中, 它可以与匿名的内部类一起使用,从而提高代码的可读性。
考虑以下 Java 9 之前的代码:
public class Tester {
public static void main(String[] args) {
Handler<Integer> intHandler = new Handler<Integer>(1) {
@Override
public void handle() {
System.out.println(content);
}
};
intHandler.handle();
Handler<? extends Number> intHandler1 = new Handler<Number>(2) {
@Override
public void handle() {
System.out.println(content);
}
};
intHandler1.handle();
Handler<?> handler = new Handler<Object>("test") {
@Override
public void handle() {
System.out.println(content);
}
};
handler.handle();
}
}
abstract class Handler<T> {
public T content;
public Handler(T content) {
this.content = content;
}
abstract void handle();
}
在 Java 9 中,我们可以在匿名类中使用 <> 操作符,如下所示:
public class Tester {
public static void main(String[] args) {
Handler<Integer> intHandler = new Handler<>(1) {
@Override
public void handle() {
System.out.println(content);
}
};
intHandler.handle();
Handler<? extends Number> intHandler1 = new Handler<>(2) {
@Override
public void handle() {
System.out.println(content);
}
};
intHandler1.handle();
Handler<?> handler = new Handler<>("test") {
@Override
public void handle() {
System.out.println(content);
}
};
handler.handle();
}
}
abstract class Handler<T> {
public T content;
public Handler(T content) {
this.content = content;
}
abstract void handle();
}
如果存在值,则此新方法将执行给定的Consumer操作,否则运行给定的Runnable操作。下面的代码先使用Java 8的的Stream流过滤3的倍数,然后通过findFirst找到第一个3的倍数。如果找到一个这样的值,就print控制台打印出来;如果没找到一个这样的值,就输出"没有找到3的倍数"ifPresentOrElse(Consumer,Runnable)的语义可以解释为:ifPresent就Consumer,OrElse就Runnable。这是Java 9 才有的增强方法。
IntStream.of(1, 2, 4)
.filter(i -> i % 3 == 0)
.findFirst()
.ifPresentOrElse(System.out::println, () -> {
System.out.println("没有找到3的倍数");
});
在1、2、4中没有3的倍数,所以输出结果如下
没有找到3的倍数
如果是下面的2、6、8数组被过滤,最终控制台输出结果为:6
IntStream.of(2, 6, 8)
.filter(i -> i % 3 == 0)
.findFirst()
.ifPresentOrElse(System.out::println, () -> {
System.out.println("没有找到3的倍数");
}); // 6
Java 8 Optional.isPresent():
如果使用Java 8 ,没有ifPresentOrElse(Consumer,Runnable)
方法,上文中同样的代码你应该是这样写的:自己去写if和else进行判断。同样输出:没有找到3的倍数
OptionalInt opt = IntStream.of(1, 2, 4)
.filter(i -> i % 3 == 0)
.findFirst();
if (opt.isPresent()) {
System.out.println(opt.getAsInt());
} else {
System.out.println("没有找到3的倍数");
}
Java 8 Optional.ifPresent():
ifPresent()
方法在值不存在的时候,没有提供一个可选的操作。所以下面的代码在执行之后,没有orElse动作,没有任何输出,这样不是很友好。
IntStream.of(1, 2, 4)
.filter(i -> i % 3 == 0)
.findFirst()
.ifPresent(System.out::println);
Java 8 Optional.orElse():
orElse()
方法在value返回值为空的之后,给出一个默认值。下文代码中给出一个默认值-1。
int result = IntStream.of(1, 2, 4)
.filter(i -> i % 3 == 0)
.findFirst()
.orElse(-1);
System.out.println(result); //-1
该方法在找不到值的时候,生成一个新的Optional
出来。下文代码过滤数组['a', 'b', 'c'],isDigit
判断数组中是否有数字字符,明显没有,所以findFirst
找不到一个这样的值。所以生成一个默认值: Optional.of('0')
char digit = Stream.of('a', 'b', 'c')
.filter(e -> Character.isDigit(e))
.findFirst()
.or(() -> Optional.of('0')).get();
System.out.println(digit); //0
Java8 中的 orElseGet()
Java 8中的Optional.orElseGet()
方法也具备同样的功能。下文代码过滤数组[‘a’, ‘b’, ‘c’],isDigit判断数组中是否有数字字符,明显没有,所以findFirst找不到一个这样的值。所以通过orElseGet获取一个默认值: ‘0’
char result = Stream.of('a', 'b', 'c')
.filter(c -> Character.isDigit(c))
.findFirst()
.orElseGet(()->'0');
System.out.println(result); //0
在本例中Optional.stream()
方法返回仅包含一个最大值元素的Stream流。如果该值不存在,则返回空Stream:
OptionalInt opt1 = IntStream.of(2, 5, 6).max(); //求最大值
OptionalInt opt2 = IntStream.of(1, 3, 7).max(); //求最大值
IntStream.concat(opt1.stream(), opt2.stream()) //将2个流合并
.forEach(System.out::println); //将合并后的流数据打印
控制台输出的结果如下:
6
7
Java 9的 Reactive Streams是对异步流式编程的一种实现。它基于异步发布和订阅模
型,具有非阻塞“背压”数据处理
的特点。
Non-blocking Back Pressure(非阻塞背压):它是一种机制,让发布订阅模型中的订阅者避免接收大量数据(超出其处理能力),订阅者可以异步通知发布者降低或提升数据生产发布的速率。它是响应式编程实现效果的核心特点!
Java 9提供了一组定义响应式流编程的接口。所有这些接口都作为静态内部接口定义在java.util.concurrent.Flow类里面。
下面是Java 响应式编程中的一些重要角色和概念,先简单理解一下
public static interface Subscriber<T> {
public void onSubscribe(Subscription subscription);
public void onNext(T item);
public void onError(Throwable throwable);
public void onComplete();
}
Subscription
订阅令牌对象通过此方法传递给订阅者。订阅令牌对象通过Subscriber.onSubscribe()
方法传递
public static interface Subscription {
public void request(long n);
public void cancel();
}
request(long n)
是无阻塞背压概念背后的关键方法。订阅者使用它来请求n个以上的消费项目。这样,订阅者控制了它当前能够接收多少个数据。cancel()
由订阅者主动来取消其订阅,取消后将不会在接收到任何数据消息。@FunctionalInterface
public static interface Publisher<T> {
public void subscribe(Subscriber<? super T> subscriber);
}
调用该方法,建立订阅者Subscriber与发布者Publisher之间的消息订阅关系。
处理者Processor 可以同时充当订阅者和发布者,起到转换发布者——订阅者管道中的元素的作用。用于将发布者T类型的数据元素,接收并转换为类型R的数据并发布。
public static interface Processor<T,R> extends Subscriber<T>, Publisher<R> {
}
现在我们要去实现上面的四个接口来完成响应式编程
Subscription Interface
订阅令牌接口通常不需要我们自己编程去实现,我们只需要在知道request()
方法和cancle()
方法含义即可。Publisher Interface
发布者接口,Java 9
已经默认为我们提供了实现SubmissionPublisher
,该实现类除了实现Publisher
接口的方法外,提供了一个方法叫做submit()
来完成消息数据的发送。Subscriber Interface
订阅者接口,通常需要我们自己去实现。因为在数据订阅接收之后,不同的业务有不同的处理逻辑。Processor
实际上是 Publisher Interface和Subscriber Interface
的集合体,有需要数据类型转换及数据处理的需求才去实现这个接口下面的例子实现的式字符串的数据消息订阅处理
import java.util.concurrent.Flow;
public class MySubscriber implements Flow.Subscriber<String> {
private Flow.Subscription subscription; //订阅令牌
@Override
public void onSubscribe(Flow.Subscription subscription) {
System.out.println("订阅关系建立onSubscribe: " + subscription);
this.subscription = subscription;
subscription.request(2);
}
@Override
public void onNext(String item) {
System.out.println("item: " + item);
// 一个消息处理完成之后,可以继续调用subscription.request(n);向发布者要求数据发送
//subscription.request(n);
}
@Override
public void onError(Throwable throwable) {
System.out.println("onError: " + throwable);
}
@Override
public void onComplete() {
System.out.println("onComplete");
}
}
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Flow;
import java.util.concurrent.SubmissionPublisher;
public class SubmissionPublisherExample {
public static void main(String[] args) throws InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(1);
SubmissionPublisher<String> sb = new SubmissionPublisher<>(executor, Flow.defaultBufferSize());
sb.subscribe(new MySubscriber()); //建立订阅关系,可以有多个订阅者
sb.submit("数据 1"); //发送消息1
sb.submit("数据 2"); //发送消息2
sb.submit("数据 3"); //发送消息3
executor.shutdown();
}
}
控制台打印输出结果
订阅关系建立
onSubscribe: java.util.concurrent.SubmissionPublisher$BufferedSubscription@27e81a39
item: 数据 1
item: 数据 2
请注意:即使发布者submit了3条数据,MySubscriber也仅收到了2条数据进行了处理。是因为我们在MySubscriber#onSubscribe()方法中使用了subscription.request(2);
。这就是“背压”的响应式编程效果,我有能力处理多少数据,就会通知消息发布者给多少数据
。
注解 @Deprecated 可以标记 Java API 状态,可以是以下几种:
Java 9 中注解增加了两个新元素:since 和 forRemoval。
以下实例为 Java 9 中关于 Boolean 类的说明文档,文档中 @Deprecated 注解使用了 since 属性:Boolean Class。
以下实例为在 Java 9 中关于系统类的说明文档,文档中 @Deprecated 注解使用了 forRemoval 属性:System Class。
Java 8
引入了 CompletableFuture<T>
类,可能是 java.util.concurrent.Future<T>
明确的完成版(设置了它的值和状态),也可能被用作java.util.concurrent.CompleteStage
。支持 future
完成时触发一些依赖的函数和动作。
Java 9
引入了一些CompletableFuture
的改进:
public CompletableFuture<T> completeOnTimeout(T value, long timeout, TimeUnit unit)
在 timeout
(单位在 java.util.concurrent.Timeunits units
中,比如 MILLISECONDS
)前以给定的 value 完成这个 CompletableFutrue
。返回这个 CompletableFutrue
。
public CompletableFuture<T> orTimeout(long timeout, TimeUnit unit)
如果没有在给定的 timeout 内完成,就以 java.util.concurrent.TimeoutException 完成这个 CompletableFutrue,并返回这个 CompletableFutrue。
做了许多改进使得 CompletableFuture
可以被更简单的继承。比如,你也许想重写新的 public Executor defaultExecutor()
方法来代替默认的 executor
。
另一个新的使子类化更容易的方法是:
public <U> CompletableFuture<U> newIncompleteFuture()
Java 8引入了 <U> CompletableFuture<U> completedFuture(U value)
工厂方法来返回一个已经以给定 value
完成了的 CompletableFuture
。Java 9
以 一个新的 <U> CompletableFuture<U> failedFuture(Throwable ex)
来补充了这个方法,可以返回一个以给定异常完成的 CompletableFuture
。
除此以外,Java 9 引入了下面这对 stage-oriented
工厂方法,返回完成的或异常完成的 completion stages:
<U> CompletionStage<U> completedStage(U value)
: 返回一个新的以指定 value
完成的CompletionStage
,并且只支持 CompletionStage
里的接口。<U> CompletionStage<U> failedStage(Throwable ex)
:返回一个新的以指定异常完成的CompletionStage
,并且只支持 CompletionStage
里的接口。版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://cjdhy.blog.csdn.net/article/details/122791312
内容来源于网络,如有侵权,请联系作者删除!