设计模式-创建者模式总结

创建者模式的特点及使用场景

《Effective Java》—— 创建与销毁对象 一章中有写道:当一个类中有大量的构造参数时,静态方法和构造器已经不能满足对象的实例化,那么我们将考虑构建器。

构建器模式:

  • 1、重叠构造器模式
  • 2、javaBeans模式(自己常用的一种)
  • 3、builder模式

说明:

  • 重叠构造器模式:这种模式下,提供第一个只有必要参数的构造器,第二个构造器有一个可选参数,第三个有两个可选参数,以此类推,最后一个构造器包含所有可选参数。
  • javaBeans模式:调用在各分无参构造器创建对象,然后调用setter方法来设置每个必要的参数,以及每个相关的可选参数。
  • builder模式:builder像个构造器一样,可以对其参数强加约束条件。build方法可以检验这些约束条件。将参数从builder拷贝到对象中之后,并在对象域而不是builder域中对它们进行检验,这一点很重要。如果违反了人格约束条件,build方法就应该抛出IllegalStateException。异常的详细信息应该显示出违反哪个约束条件。

从上不难看出:

  • 重叠构造器模式在参数很多的情况下,客户端代码会很难写,并且难以阅读。
  • javaBeans模式因为构造过程分到了几个调用中,在构造过程中javaBean可能处于不一致的状态,类无法仅仅通过校验构造参数的* 有效性来保证一致性。这样程序员需要付出额外的努力来确保它的线程安全
  • builder模式技能保证像重叠构造器模式那样的安全性,也能保证像javaBeans模式那么好的可读性。

builder模式十分灵活,可以利用单个builder构建多个对象。builder的参数可以在创建对象期间进行调整,也可以随着不同的对象而改变。

代码示例

class DefaultHttpClientFactory {
    private static PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
    private static RequestConfig defaultRequestConfig = RequestConfig.custom().build();

    private static int mgrMaxTotal = DEFAULT_MAX_TOTAL;  //全局最大连接数
    private static int mgrDefaultMaxPerRoute = DEFAULT_MAX_PER_ROUTE; //每个主机最大连接数
    private static int connReqTimeout = DEFAULT_CONN_REQ_TIMEOUT;   //从连接池获取连接超时时间
    private static int connTimout = DEFAULT_CONN_TIMEOUT;   //发起连接超时时间
    private static int connSocketTimeout = DEFAULT_CONN_SOCKET_TIMEOUT;    //连接套接字等待时间

    public static class Builder {
        private int mgrMaxTotal = DEFAULT_MAX_TOTAL;  //全局最大连接数
        private int mgrDefaultMaxPerRoute = DEFAULT_MAX_PER_ROUTE; //每个主机最大连接数
        private int connReqTimeout = DEFAULT_CONN_REQ_TIMEOUT;   //从连接池获取连接超时时间
        private int connTimout = DEFAULT_CONN_TIMEOUT;   //发起连接超时时间
        private int connSocketTimeout = DEFAULT_CONN_SOCKET_TIMEOUT;    //连接套接字等待时间

        Builder() {
        }

        public Builder maxTotal(int maxTotal) {
            this.mgrMaxTotal = maxTotal;
            return this;
        }

        public Builder maxPerRoute(int maxPerRoute) {
            this.mgrDefaultMaxPerRoute = maxPerRoute;
            return this;
        }

        public Builder connReqTimeout(int connReqTimeout) {
            this.connReqTimeout = connReqTimeout;
            return this;
        }

        public Builder connTimout(int connTimout) {
            this.connTimout = connTimout;
            return this;
        }

        public Builder connSocketTimeout(int connSocketTimeout) {
            this.connSocketTimeout = connSocketTimeout;
            return this;
        }

        public DefaultHttpClientFactory build() {
            return new DefaultHttpClientFactory(this);
        }
    }

    private DefaultHttpClientFactory(Builder builder) {
        mgrMaxTotal = builder.mgrMaxTotal;
        mgrDefaultMaxPerRoute = builder.mgrDefaultMaxPerRoute;
        connReqTimeout = builder.connReqTimeout;
        connTimout = builder.connTimout;
        connSocketTimeout = builder.connSocketTimeout;
    }

    public static DefaultHttpClientFactory.Builder custom() {
        return new DefaultHttpClientFactory.Builder();
    }

    public CloseableHttpClient getClient() {
        cm.setMaxTotal(mgrMaxTotal); // 设置最大连接数
        cm.setDefaultMaxPerRoute(mgrDefaultMaxPerRoute); // 设置每个路由最大连接数,每个独立的host为1个路由
        RequestConfig requestConfig = RequestConfig.copy(defaultRequestConfig)
                .setConnectionRequestTimeout(connReqTimeout)//从连接池获取连接超时时间
                .setConnectTimeout(connTimout)//发起连接超时时间
                .setSocketTimeout(connSocketTimeout)//连接套接字等待时间
                .setRedirectsEnabled(false)
                .build();

        HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
        httpClientBuilder.setConnectionManager(cm);
        httpClientBuilder.setDefaultRequestConfig(requestConfig);

        httpClientBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(0, false)); // 去掉默认的3次重试
        CloseableHttpClient httpClient = httpClientBuilder.build();
        return httpClient;
    }
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏信安之路

HCTF2017的三个WriteUp

解决方法就是先 undefine 掉函数,再右键选择 Code,最后 Create function 就可以正常反编译了。

1090
来自专栏分布式系统进阶

Influxdb 数据写入流程

因此对写入请求的处理就在函数 func (h *Handler) serveWrite(w http.ResponseWriter, r *http.Reque...

1783
来自专栏流柯技术学院

JMeter专题系列(三)元件的作用域与执行顺序

JMeter中共有8类可被执行的元件(测试计划与线程组不属于元件),这些元件中,取样器是典型的不与其它元件发生交互作用的元件,逻辑控制器只对其子节点的取样器有效...

1174
来自专栏分布式系统进阶

ReplicaManager源码解析1-消息同步线程管理

基本上就是作三件事: 构造FetchRequest, 同步发送FetchRequest并接收FetchResponse, 处理FetchResponse, 这三...

1492
来自专栏前端儿

前端实现文件的断点续传

以前文件无法分割,但随着HTML5新特性的引入,类似普通字符串、数组的分割,我们可以可以使用slice方法来分割文件。

5792
来自专栏熊二哥

快速入门系列--WebAPI--04在老版本MVC4下的调整

WebAPI是建立在MVC和WCF的基础上的,原来微软老是喜欢封装的很多,这次终于愿意将http编程模型的相关细节暴露给我们了。在之前的介绍中,基本上都基于.N...

2376
来自专栏Spark学习技巧

Kafka源码系列之分组消费的再平衡策略

一,Kafka消费模式 从kafka消费消息,kafka客户端提供两种模式: 分区消费,分组消费。 分区消费对应的就是我们的DirectKafkaInputDS...

8846
来自专栏圣杰的专栏

ASP.NET Core 中断请求了解一下(翻译)

假设有一个耗时的Action,在浏览器发出请求返回响应之前,如果刷新了页面,对于浏览器(客户端)来说前一个请求就会被终止。而对于服务端来说,又是怎样呢?前一个请...

1273
来自专栏逆向技术

x64内核HOOK技术之拦截进程.拦截线程.拦截模块

            x64内核HOOK技术之拦截进程.拦截线程.拦截模块 一丶为什么讲解HOOK技术. 在32系统下, 例如我们要HOOK SSDT表,那么...

4827
来自专栏有趣的django

37.Django1.11.6文档

第一步 入门 检查版本 python -m django --version 创建第一个项目 django-admin startproject mysite ...

4648

扫码关注云+社区

领取腾讯云代金券