Java8 的 Stream 写是写的爽，但是一遇到抛异常的货，就感觉咯噔一下。。
yuankui · 2019-05-22 15:21:13 +08:00 · 6350 次点击这是一个创建于 2017 天前的主题，其中的信息可能已经有所发展或是发生改变。
什么优雅，干净都不复存在了。
我 TMD 明明是个有追求的人，怎会写出这样的代码？
我 TMD 明明是个有追求的人，怎会写出这样的代码？
第 1 条附言 · 2019-05-22 16:26:31 +08:00
https://www.vavr.io/ == javaslang
第 2 条附言 · 2019-05-23 15:36:36 +08:00
用 Reactor 写了一把，这不就好起来了吗
```java
Flux.range(1, 20)
.map(n -> "http://adr.meizitu.net/wp-json/wp/v2/posts?page=" + n + "&per_page=100")
.flatMap(url -> HttpClient.create()
.baseUrl(url)
.get()
.responseContent()
.aggregate()
.asString()
)
.map(JSON::parseArray)
.flatMap(Flux::fromIterable)
.map(obj -> (JSONObject) obj)
.map(obj -> obj.getString("thumb_src"))
.doOnError(e -> {})
.subscribe(System.out::println);
```
```java
Flux.range(1, 20)
.map(n -> "http://adr.meizitu.net/wp-json/wp/v2/posts?page=" + n + "&per_page=100")
.flatMap(url -> HttpClient.create()
.baseUrl(url)
.get()
.responseContent()
.aggregate()
.asString()
)
.map(JSON::parseArray)
.flatMap(Flux::fromIterable)
.map(obj -> (JSONObject) obj)
.map(obj -> obj.getString("thumb_src"))
.doOnError(e -> {})
.subscribe(System.out::println);
```
 |
1
theTd 2019-05-22 15:31:19 +08:00
用 Callable 的话是可以吃掉受检性异常的吧？
|
 |
2
xiaoidea 2019-05-22 15:33:05 +08:00
|
 |
3
airfling 2019-05-22 15:39:42 +08:00 via Android
你至少要把那三个出现可能异常的的点解决掉，不太建议代码都写在这一块。每个方法的代码尽量不超过 10 行
|
 |
4
mritd 2019-05-22 15:42:06 +08:00
如果线上这一串出现了空指针啥的...
 |
 |
5
yuankui OP @xiaoidea 大意就是用一个不跑出 checkedException 的 lambda 去封装已有的咯？感觉还是咯噔。。
|
 |
7
mooncakejs 2019-05-22 15:45:15 +08:00  1
io 相关感觉不太适合 stream，CompletableFuture 感觉更适合
|
 |
8
xinyewdz 2019-05-22 15:46:05 +08:00
这代码，看的人也是头大。
|
 |
9
BBCCBB 2019-05-22 15:47:06 +08:00
封装成一个方法,然后流里调该方法也许可破.
|
|
10
BBCCBB 2019-05-22 15:47:52 +08:00
或者将相应的 Function, Consumer 放到外面声明
|
 |
11
chocotan 2019-05-22 15:50:36 +08:00
可以试下下 Try
javaslang 里的 |
 |
12
passerbytiny 2019-05-22 15:52:20 +08:00
这是受检异常造成的，跟 Stream 有什么关系。而且你这个流干的东西也太多了吧，都要跨系统调用来获取数据了，这应该是高级流干的事，不应该是 API 级别的低级流干得事。
|
 |
13
HuasLeung 2019-05-22 15:52:24 +08:00
java 8 的新特性 lambda 也是搞得我懵逼，一堆箭头函数跟写 es6 一样……
|
 |
14
jinhan13789991 2019-05-22 15:57:26 +08:00 via Android
要不～试试 rxjava ？ 对异常处理友好～
|
 |
15
Sharuru 2019-05-22 15:59:59 +08:00
流略长……不要把以前的宽度问题转换成高度问题啊- -
|
 |
16
x66 2019-05-22 16:11:26 +08:00
最怕的难道不是写了一大串，突然线上出一个空指针，根本找不到是哪一行的问题，那感觉简直绝望。
|
|
17
yuankui OP 不要吐槽太长嘛，我就算是短成俩行，他遇到异常，还是得咯噔一下
|
 |
18
syhan 2019-05-22 16:16:40 +08:00
Try+1
|
 |
19
reeco 2019-05-22 16:23:38 +08:00
用 JOOL 处理 checked exception
https://github.com/jOOQ/jOOL before: ``` Arrays.stream(dir.listFiles()).forEach(file -> { try { System.out.println(file.getCanonicalPath()); } catch (IOException e) { throw new RuntimeException(e); } // Ouch, my fingers hurt! All this typing! }); ``` after: ``` Arrays.stream(dir.listFiles()).forEach( Unchecked.consumer(file -> { System.out.println(file.getCanonicalPath()); }) ); ``` |
 |
21
guyeu 2019-05-22 16:55:23 +08:00
代码组织有问题，流并不是所有地方都适用的。
|
 |
22
art2cat 2019-05-22 17:00:09 +08:00
effective java 里说不要超过三行，楼主这是入了魔啊
|
|
24
yuankui OP @passerbytiny 当然跟流有关系。
`Stream.map(Function func)` 拿 map 来说，map 方法签名中的 Function.apply 签名没有 throws Exception，所以就要求 function 实现必须把异常 catch 住。 |
 |
25
SoloCompany 2019-05-22 21:39:47 +08:00
java 自己给自己埋坑导致的, 语言层面的 checked exception 和 fp 就天然水土不服
虽然这个坑完全是编译器造成的, 但为了兼容不得不一直坑下去 fp 还是用 kotilin 吧 |
 |
26
ppaapc 2019-05-22 22:58:56 +08:00
优化下格式 好好分割下还可以 stream 写着处理异常确实感觉有点蛋疼
|
 |
27
qiyuey 2019-05-23 09:28:38 +08:00 via Android
没办法，上 Kotlin 吧
|
 |
28
encounter2017 2019-05-23 14:23:36 +08:00
来学 scala 啊
|
|
29
yuankui OP 附言格式乱了，还是截图好看些
 |
Select Language