Hystrix是Netflix开源的限流、熔断降级组件,去年发现Hystrix已经不再更新了,而在github主页上将我引导到了另一个替代项目——resilience4j,这个项目是基于Java 8开发的,并且只使用了vavr库,也就是我们今天要介绍的主角。
image.png
既然要谈vavr,那么先要谈为什么要使用vavr,vavr是为了增强Java的函数式编程体验的,那么这里先介绍下Java中的函数式编程。
Java 8引入了函数式编程范式,思路是:将函数作为其他函数的参数传递,其实在Java 8之前,Java也支持类似的功能,但是需要使用接口实现多态,或者使用匿名类实现。不管是接口还是匿名类,都有很多模板代码,因此Java 8引入了Lambda表达式,正式支持函数式编程。
比方说,我们要实现一个比较器来比较两个对象的大小,在Java 8之前,只能使用下面的代码:
Compartor<Apple> byWeight = new Comparator<Apple>() {
public int compare(Apple a1, Apple a2) {
return a1.getWeight().compareTo(a2.getWeight());
}
}
上面的代码使用Lambda表达式可以写成下面这样(IDEA会提示你做代码的简化):
Comparator<Apple> byWeight = (Apple a1, Apple a2) -> a1.getWeight().compareTo(a2.getWeight());
关于Lambda表达式,你需要掌握的知识点有:
java.util.function
包里,包括Predicate<T>、Function<T,R>、Supplier<T>、Consumer<T>和BinaryOperator<T>等等;受限于 Java 标准库的通用性要求和二进制文件大小,Java 标准库对函数式编程的 API 支持相对比较有限。函数的声明只提供了 Function 和 BiFunction 两种,流上所支持的操作的数量也较少。基于这些原因,你也许需要vavr 来帮助你更好得使用Java 8进行函数式开发。
vavr是在尝试让Java拥有跟Scala类似的语法。vavr提供了不可变的集合框架;更好的函数式编程特性;元组。
image.png
Vavr实现了一套新的Java集合框架来匹配函数式编程范式,vavr提供的集合都是不可变的。在Java中使用Stream,需要显示得将集合转成steam的步骤,而在vavr中则免去了这样的步骤。
Arrays.asList(1, 2, 3).stream().reduce((i, j) -> i + j);
IntStream.of(1, 2, 3).sum();
使用vavr实现相同的功能,则更加直接:
//io.vavr.collection.List
List.of(1, 2, 3).sum();
Java 8提供了接受一个参数的函数式接口Function和接受两个参数的函数式接口BiFunction,vavr则提供了最多可以接受8个参数的函数式接口:Function0、Function1、Function2、Function3、Function4……Function8。
image.png
vavr还提供了更多函数式编程的特性:
public class VavrFunctionExample {
@Test
public void testCompose() {
//使用andThen
Function1<Integer, Integer> plusOne = a -> a + 1;
Function1<Integer, Integer> multiplyByTwo = a -> a * 2;
Function1<Integer, Integer> add1AndMultiplyBy2 = plusOne.andThen(multiplyByTwo);
Assert.assertEquals(6, add1AndMultiplyBy2.apply(2).intValue());
//使用compose
Function1<Integer, Integer> add1AndMultiplyBy2WithCompose = multiplyByTwo.compose(plusOne);
Assert.assertEquals(6, add1AndMultiplyBy2WithCompose.apply(2).intValue());
}
}
public class VavrFunctionExample {
@Test
public void testLifting() {
Function2<Integer, Integer, Integer> divide = (a, b) -> a / b;
Function2<Integer, Integer, Option<Integer>> safeDivide = Function2.lift(divide);
// = None
Option<Integer> i1 = safeDivide.apply(1, 0);
Assert.assertEquals("None", i1.toString());
// = Some(2)
Option<Integer> i2 = safeDivide.apply(4, 2);
Assert.assertEquals(2, i2.get().intValue());
}
}
public class VavrFunctionExample {
@Test
public void testCurried() {
Function2<Integer, Integer, Integer> sum = (a, b) -> a + b;
Function1<Integer, Integer> add2 = sum.curried().apply(2);
Assert.assertEquals(6, add2.apply(4).intValue());
}
}
public class VavrFunctionExample {
@Test
public void testMemorize() {
Function0<Double> hashCache =
Function0.of(Math::random).memoized();
double randomValue1 = hashCache.apply();
double randomValue2 = hashCache.apply();
Assert.assertTrue(randomValue1 == randomValue1);
}
}
模式匹配是函数式编程语言中的概念,目前Java中还不支持这个特性,使用vavr可以用Java写模式匹配的代码。Java中的switch...case语句只能针对常量起作用,而使用模式匹配则可以对另一个函数的返回结果起作用,功能非常抢到。下面的例子分别给出了使用if、switch...case、模式匹配三个语法实现同样功能的例子,可以看出,模式匹配有助于减少代码行数。
import org.junit.Test;
import static io.vavr.API.$;
import static io.vavr.API.Case;
import static io.vavr.API.Match;
import static org.junit.Assert.assertEquals;
public class VavrPatternExample {
@Test
public void whenIfWorksAsMatcher_thenCorrect() {
int input = 3;
String output;
if (input == 0) {
output = "zero";
}
if (input == 1) {
output = "one";
}
if (input == 2) {
output = "two";
}
if (input == 3) {
output = "three";
} else {
output = "unknown";
}
assertEquals("three", output);
}
@Test
public void whenSwitchWorksAsMatcher_thenCorrect() {
int input = 2;
String output;
switch (input) {
case 0:
output = "zero";
break;
case 1:
output = "one";
break;
case 2:
output = "two";
break;
case 3:
output = "three";
break;
default:
output = "unknown";
break;
}
assertEquals("two", output);
}
@Test
public void whenMatchworks_thenCorrect() {
int input = 2;
String output = Match(input).of(
Case($(1), "one"),
Case($(2), "two"),
Case($(3), "three"),
Case($(), "?"));
assertEquals("two", output);
}
}
javaadu