查看原文
其他

JDK9新特性实战:简化流关闭新姿势。

2018-03-06 R哥 Java技术栈

(点击上方公众号,可快速关注)


做Java开发的都知道,每个资源的打开都需要对应的关闭操作,不然就会使资源一直占用而造成资源浪费,从而降低系统性能。

关于资源的关闭操作,从JDK7-JDK9有了不少的提升及简化。

JDK6

在JDK6及之前,每个资源都需要我们手动写代码关闭,如:

  1. FileInputStream fis = null;

  2. byte[] buffer = new byte[1024];

  3. try {

  4.    fis = new FileInputStream(new File("E:\\Java技术栈.txt"));

  5.    while (fis.read(buffer) > 0) {

  6.        System.out.println(new String(buffer));

  7.    }

  8. } catch (Exception e) {

  9.    e.printStackTrace();

  10. } finally {

  11.    if (fis != null) {

  12.        try {

  13.            fis.close();

  14.        } catch (IOException e) {

  15.            e.printStackTrace();

  16.        }

  17.    }

  18. }

资源打开使用完后,必须在finally块中进行手动关闭!我们有的同事,做一个查询功能点,打开了连接查询完后没有手动关闭,最后造成连接池超出最大连接数而使系统功能堵塞。

JDK7

JDK7发布后,添加了新特性:try-with-resources语句。所有需要关闭的资源只要实现了 java.lang.AutoCloseable(java.io.Closeable就实现了这个接口)接口就在会程序结束后自动关闭。

如上面的读取文件的流程序用JDK7来写:

  1. byte[] buffer = new byte[1024];

  2. try (FileInputStream fis = new FileInputStream(new File("E:\\Java技术栈.txt"))) {

  3.    while (fis.read(buffer) > 0) {

  4.        System.out.println(new String(buffer));

  5.    }

  6. } catch (Exception e) {

  7.    e.printStackTrace();

  8. }

所有的资源在 try()里面定义,并去掉了finally模块。

下面我们来写一个自定义的流来看看是否自动关闭了。

定义一个自定义输入输出流

  1. class MyInputStream implements AutoCloseable {

  2.    void read(String content) {

  3.        System.out.println("read content " + content);

  4.    }

  5.    @Override

  6.    public void close() throws Exception {

  7.        System.out.println("input stream is closed.");

  8.    }

  9. }

  10. class MyOutputStream implements AutoCloseable {

  11.    void write(String content) {

  12.        System.out.println("write content " + content);

  13.    }

  14.    @Override

  15.    public void close() throws Exception {

  16.        System.out.println("out stream is closed.");

  17.    }

  18. }

单个资源自动关闭

  1. try (MyInputStream mis = new MyInputStream()) {

  2.    mis.read("7_2");

  3. } catch (Exception e) {

  4.    e.printStackTrace();

  5. }

输出:

read content 7_2

input stream is closed.

多个资源自动关闭

try()里面可以定义多个资源,它们的关闭顺序是最后在 try()定义的资源先关闭。

  1. try (MyInputStream mis = new MyInputStream(); MyOutputStream mos = new MyOutputStream()) {

  2.    mis.read("7_3");

  3.    mos.write("7_3");

  4. } catch (Exception e) {

  5.    e.printStackTrace();

  6. }

输出:

read content 73

write content 73

out stream is closed.

input stream is closed.

JDK9

JDK9发布后,又简化了try-with-resources语句的用法。

try()里面可以是一个变量,但必须是final的或者等同final才行。如下面的mis,mos定义成局部变量可以不用final,局部变量可以等同于final,但定义成成员变量就必须是用final修饰的,不然会编译错误。

  1. MyInputStream mis = new MyInputStream();

  2. MyOutputStream mos = new MyOutputStream();

  3. try (mis; mos) {

  4.    mis.read("1.9");

  5.    mos.write("1.9");

  6. } catch (Exception e) {

  7.    e.printStackTrace();

  8. }

输出:

read content 1.9

write content 1.9

out stream is closed.

input stream is closed.

再来看个例子:

  1. Connection dbCon = DriverManager.getConnection("url", "user", "password");

  2. try (dbCon; ResultSet rs = dbCon.createStatement().executeQuery("select * from emp")) {

  3.    while (rs.next()) {

  4.        System.out.println("In loadDataFromDB() =====>>>>>>>>>>>> " + rs.getString(1));

  5.    }

  6. } catch (SQLException e) {

  7.    System.out.println("Exception occurs while reading the data from DB ->" + e.getMessage());

  8. }

dbCon和rs都能被自动关闭。

JKD9虽然简化了,但感觉还是没有什么质的变化,实际用途我们可能不希望关心资源的关闭,或者在方法结束之后如果是局部变量它就能自动关闭。或许是我站的高度不够,官方有其他的考量,但JDK9的这一点变化还是非常有用的。

更多JDK9的新功能实战陆续更新,如果觉得有用,分享到朋友圈给更多的人吧!

推荐:成为架构师的四阶段学习资料

推荐:分享18道Java面试笔试题(面试实拍)

推荐:春节跳槽最新Java面试题及答案整理

如果对你有用,欢迎分享到朋友圈

长按关注,更多精彩!

点击阅读原文,更多技术干货!

您可能也对以下帖子感兴趣

文章有问题?点此查看未经处理的缓存