模式说明

建造者模式旨在创建一个对象,而且是一个复杂对象,那么什么是复杂对象呢?我个人认为,该对象的属性比较多(5 个或更多),同时,某些属性之间还存在依赖关系。如果一个对象存在多个属性,但每个属性并不存在依赖关系,那这种对象就类似于 DTO(Data Transfer Object)了,仅仅只是数据的搬运工。

应用场景

只要一个对象的构造方法上的参数过多,或将来可能会过多的情况下就应该引起注意了,往往这些都可能引入建造者模式的信号或者先兆。接下来,我将通过一个例子的全过程来说明建造者模式解决的是程序上的哪些设计痛点。

现在,项目中的使用了原始的 JDBC 操作数据库,导致大量重复创建数据库连接对象的代码。为了解决这个问题,项目组决定将创建数据库连接对象的代码搬迁到 DataSource 类中,代码如下所示。

  1. public class DataSource {
  2. private String jdbcUrl;
  3. private String username;
  4. private String password;
  5. public DataSource(String jdbcUrl, String username, String password) {
  6. Objects.requireNonNull(jdbcUrl);
  7. Objects.requireNonNull(username);
  8. Objects.requireNonNull(password);
  9. this.jdbcUrl = jdbcUrl;
  10. this.username = username;
  11. this.password = password;
  12. }
  13. public Connection getConnection() {
  14. try {
  15. return DriverManager.getConnection(jdbcUrl, username, password);
  16. } catch (SQLException e) {
  17. throw new GetConnectionException(e); // RuntimeException
  18. }
  19. }
  20. public void closeConnection(Connection conn) {
  21. try {
  22. if (conn != null)
  23. conn.close();
  24. } catch (SQLException e) {
  25. throw new CloseException(e); // RuntimeException
  26. }
  27. }
  28. }

上述代码在低版本的 JDK(1.2) 上还是不能正常使用,或者没有按照 JDBC 2.0 规范来实现的 Driver 注册方式也不能正常使用,所以,为了兼容,还需要引入 DriverClass 的参数,具体的构造方法代码将如下所示。

  1. public class DataSource {
  2. public DataSource(String jdbcUrl, String username,
  3. String password, String driverClass) {
  4. // ... ...
  5. this.driverClass = driverClass;
  6. try {
  7. Class.forName(driverClass);
  8. } catch (ClassNotFoundException e) {
  9. throw new DataSourceException("Driver class initialize error", e);
  10. }
  11. }
  12. }

JDBC 2.0 规范中提到 JDBC 驱动实现程序,需要在 /META-INF/services/java.sql.Driver 文件内写入具体的 Driver Class 全称,DriverManager 会通过 SPI 技术将其自动注册到应用内部,更多说明可参考 DriverManager 的类注释。

针对 4 个参数,利用静态工厂就能很好的满足设计要求,代码如下。

  1. public class DataSource {
  2. public static DataSource fromMySql(String jdbcUrl,
  3. String username, String password) {
  4. return new DataSource(jdbcUrl, username, password,
  5. "com.mysql.jdbc.Driver");
  6. }
  7. public static DataSource fromOracle(String jdbcUrl,
  8. String username, String password) {
  9. return new DataSource(jdbcUrl, username, password,
  10. "oracle.jdbc.driver.OracleDriver");
  11. }
  12. }

后来,程序创建太多的数据库短连接,导致数据库拒绝服务,因此,我们考虑引入数据库连接池,但连接池里涉及非常多的配置,此时的 DataSource 构造方法的参数已经放不下了,于是可以尝试新增一些 setter 方法对连接池的属性进行设置。

  1. public class DataSource {
  2. private int initialSize;
  3. private int maxTotal;
  4. private int maxIdle;
  5. private int minIdle;
  6. private long maxWaitMillis;
  7. public void setInitialSize(int initialSize) {
  8. this.initialSize = initialSize;
  9. }
  10. // ... 其它 setter 方法 ...
  11. }

那么,现在创建 DataSource 将会是如下代码所示。

  1. DataSource source = DataSource.fromMySql(jdbcUrl, username, password);
  2. source.setInitialSize(2);
  3. source.setMaxTotal(16);
  4. source.setMaxIdle(16);
  5. source.setMinIdle(8);

不过,setter 方法难以处理以下问题

  1. initialSize 必须小于等于 maxTotal
  2. minIdle 必须小于等于 maxIdle
  3. maxIdle 必须小于等于 maxTotal
  4. setter 方法还可以被重复调用

幸运的是,我们可以使用建造者模式,即所谓的 Builder Design Pattern,在 代码实现 一节,我们就可以看到建造者模式的魅力所在。可以看到上面代码演变的过程中,我们遇到了构造方法参数不多的情况下可以使用静态工厂就能很好的满足设计要求,而且也不会造成过度设计。但后来因为引入了数据连接池,构造方法的参数一下子膨胀了很多,于是想要通过 setter 方法对连接池的属性进行设置,可惜的是 setter 方法无法校验属性之间的关系,这个就是建造者模式出场的时机了,也是该模式要解决的程序设计痛点。

那么 Java 中的哪些类库使用了建造者模式呢?在 Java 11 中正式投入使用的 HttpClient / HttpRequest 构建方式正是建造者模式,样例代码参考如下。

  1. HttpClient client = HttpClient.newBuilder()
  2. .version(Version.HTTP_2)
  3. .followRedirects(Redirect.SAME_PROTOCOL)
  4. .proxy(ProxySelector.of(new InetSocketAddress("www-proxy.com", 8080)))
  5. .authenticator(Authenticator.getDefault())
  6. .build();
  7. HttpRequest request = HttpRequest.newBuilder()
  8. .uri(URI.create("https://openjdk.java.net/groups/net/httpclient/"))
  9. .timeout(Duration.ofMinutes(1))
  10. .header("Content-Type", "application/json")
  11. .POST(BodyPublisher.fromFile(Paths.get("file.json")))
  12. .build();
  13. HttpResponse<String> response = client.send(request, BodyHandler.asString());
  14. System.out.println(response.statusCode());
  15. System.out.println(response.body());

那么,我们该如何判断是否需要建造者模式,可参考如下准则

  1. 构造方法的参数过多(等于或多于 5 个)
  2. 无法单纯通过 setter 来满足属性之间的校验逻辑(区别于 DTO 对象)
  3. 对象内部属性存在依赖关系,或部分属性属于必选项

代码实现

最后,根据建造者模式改造 DataSource,以下是具体代码,注意并未实现 ConnectionPool,这里的代码类似于脚手架,大部分的建造者模式实现都与下面代码大同小异。

  1. public class DataSource implements AutoCloseable {
  2. private final ConnectionPool pool;
  3. private DataSource(Builder builder) {
  4. pool = new ConnectionPool(builder.jdbcUrl,
  5. builder.username,
  6. builder.password);
  7. pool.setInitialSize(builder.initialSize);
  8. pool.setMaxTotal(builder.maxTotal);
  9. pool.setMaxIdle(builder.maxIdle);
  10. pool.setMinIdle(builder.minIdle);
  11. pool.setMaxWaitMillis(builder.maxWaitMillis);
  12. }
  13. public Connection getConnection() {
  14. return pool.borrowConnection();
  15. }
  16. public void closeConnection(Connection conn) {
  17. pool.returnConnection(conn);
  18. }
  19. @Override
  20. public void close() throws Exception {
  21. pool.close();
  22. }
  23. public static class Builder {
  24. private String jdbcUrl;
  25. private String username;
  26. private String password;
  27. private int initialSize;
  28. private int maxTotal;
  29. private int maxIdle;
  30. private int minIdle;
  31. private long maxWaitMillis;
  32. public Builder jdbcUrl(String jdbcUrl) {
  33. this.jdbcUrl = jdbcUrl;
  34. }
  35. public Builder username(String username) {
  36. this.username = username;
  37. }
  38. public Builder password(String password) {
  39. this.password = password;
  40. }
  41. public Builder poolInitialSize(int initialSize) {
  42. this.initialSize = initialSize;
  43. }
  44. public Builder poolMaxTotal(int maxTotal) {
  45. this.maxTotal = maxTotal;
  46. }
  47. public Builder poolMaxIdle(int maxIdle) {
  48. this.maxIdle = maxIdle;
  49. }
  50. public Builder poolMinIdle(int minIdle) {
  51. this.minIdle = minIdle;
  52. }
  53. public Builder poolMaxWaitMillis(long maxWaitMillis) {
  54. this.maxWaitMillis = maxWaitMillis;
  55. }
  56. public DataSource build() {
  57. Objects.requireNonNull(jdbcUrl);
  58. Objects.requireNonNull(username);
  59. Objects.requireNonNull(password);
  60. if (initialSize > maxTotal) throw new IllegalArgumentException();
  61. if (maxIdle > maxTotal) throw new IllegalArgumentException();
  62. if (minIdle > maxIdle) throw new IllegalArgumentException();
  63. return new DataSource(this);
  64. }
  65. }
  66. }

再来看如何在客户端代码中使用,如下所示。

  1. DataSource source = new DataSource.Builder()
  2. .jdbcUrl("jdbc:mysql:...").username("root").password("xxxx")
  3. .poolMaxTotal(36)
  4. .poolMaxIdle(24)
  5. .poolMinIdle(0)
  6. .poolInitialSize(0)
  7. .poolMaxWaitMillis(5000L)
  8. .build();
  9. Connection conn = source.getConnection();
  10. try {
  11. ... ...
  12. } finally {
  13. source.closeConnection(conn);
  14. }