Java单例模式再加强——按组多单例

简介:   最近要使用alibaba的rocket mq(我们公司对其进行了封装,使其运行在dotNet平台上,Java还是和原生的差不多,涉及公司的内容本文不会提及),其中 在生产者组这一块,建议是用单例模式的。

  最近要使用alibaba的rocket mq(我们公司对其进行了封装,使其运行在dotNet平台上,Java还是和原生的差不多,涉及公司的内容本文不会提及),其中 在生产者组这一块,建议是用单例模式的。但是其中又建议一个组(group)使用一个实例,这样仅仅单例模式就不行了,所以要进行改动,我们的目标就是“一个group使用一个单例”。

  其实简单点,多封装几个不同的单例类就行了,一个组用一个类。但是这显然不是一个好主意,于是我们来考虑用另一种方式。

  首先要将 group 这个概念抽出来,它是变量,接下来封装不变的代码。

  我们先看看代码是什么样的:

/**
 * TurboMQ 消息生产者管理器
 */
public class MqProducer {

    private DefaultMQProducer currentMQProducer;

    private static Map<String, MqProducer> producerMap = new ConcurrentHashMap<>(3);
    private static final Object lock = new Object();

    private MqProducer(String group) throws MQClientException {
        if (!Validator.isNotNullAndVisible(group)) {
            throw new NullPointerException("Group名称不能为空!");
        }
      
        currentMQProducer = new DefaultMQProducer(group);
        currentMQProducer.setNamesrvAddr(“1.1.1.1”);
        currentMQProducer.start();
    }

    public static MqProducer instance(String group) throws MQClientException {
        if (!Validator.isNotNullAndVisible(group)) {
            throw new NullPointerException("Group名称不能为空!");
        }


        if (producerMap.get(group) == null) {
            synchronized (lock) {
                if (producerMap.get(group) == null) {
                    producerMap.put(group, new MqProducer(group));
                }
            }
        }
        return producerMap.get(group);
    }

    public SendResult send(String topic, String tag, String body) throws UnsupportedEncodingException, InterruptedException, RemotingException, MQClientException, MQBrokerException {
        if (!Validator.isNotNullAndVisible(topic, tag, body)) {
            throw new NullPointerException("请检查参数是否为空,topic,tag,body");
        }
        Message message = new Message(topic, tag, body.getBytes("UTF-8"));
        return currentMQProducer.send(message);
    }


    public static void shutdownAll() {
        producerMap.forEach((key, value) -> {
            value.shutdown();
        });
    }


    public void shutdown() {
        currentMQProducer.shutdown();
    }

}

  我们的解决思路,就是使用 Map 让 group 和实例一一对应起来。

  这些代码中你可能需要注意的点是:

    1 线程安全的 ConcurrentHashMap 以及要设置初始容量

private static Map<String, MqProducer> producerMap = new ConcurrentHashMap<>(3);

    2 instance方法中的两层 if 判断

       在 synchronized(lock)锁住之前可能有多个线程了解到当前组是null,都去请求锁,当第一个线程new了新生产者之后,下一个进程进来就不会再new一个新的生产者了。

 public static MqProducer instance(String group) throws MQClientException {
        if (producerMap.get(group) == null) {
            synchronized (lock) {
                if (producerMap.get(group) == null) {
                    producerMap.put(group, new MqProducer(group));
                }
            }
        }
        return producerMap.get(group);
    }

 

  题外话:

    为什么要抛异常?

    因为此处是通用代码,通用代码不应处理业务逻辑,而且不该隐蔽错误的发生,要让业务逻辑去确保参数没问题。

目录
相关文章
|
14天前
|
设计模式 安全 Java
Java编程中的单例模式:理解与实践
【10月更文挑战第31天】在Java的世界里,单例模式是一种优雅的解决方案,它确保一个类只有一个实例,并提供一个全局访问点。本文将深入探讨单例模式的实现方式、使用场景及其优缺点,同时提供代码示例以加深理解。无论你是Java新手还是有经验的开发者,掌握单例模式都将是你技能库中的宝贵财富。
20 2
|
25天前
|
设计模式 安全 Java
Java编程中的单例模式深入剖析
【10月更文挑战第21天】在Java的世界里,单例模式是设计模式中一个常见而又强大的存在。它确保了一个类只有一个实例,并提供一个全局访问点。本文将深入探讨如何正确实现单例模式,包括常见的实现方式、优缺点分析以及最佳实践,同时也会通过实际代码示例来加深理解。无论你是Java新手还是资深开发者,这篇文章都将为你提供宝贵的见解和技巧。
92 65
|
14天前
|
设计模式 安全 Java
Java编程中的单例模式深入解析
【10月更文挑战第31天】在编程世界中,设计模式就像是建筑中的蓝图,它们定义了解决常见问题的最佳实践。本文将通过浅显易懂的语言带你深入了解Java中广泛应用的单例模式,并展示如何实现它。
|
22天前
|
设计模式 SQL 安全
Java编程中的单例模式深入解析
【10月更文挑战第24天】在软件工程中,单例模式是设计模式的一种,它确保一个类只有一个实例,并提供一个全局访问点。本文将探讨如何在Java中使用单例模式,并分析其优缺点以及适用场景。
11 0
|
26天前
|
SQL 设计模式 Java
[Java]单例模式
本文介绍了单例模式的概念及其实现方式,包括饿汉式和懒汉式两种形式,并详细探讨了懒汉式中可能出现的线程安全问题及其解决方案,如锁方法、锁代码块和双重检查锁(DCL)。文章通过示例代码帮助读者更好地理解和应用单例模式。
28 0
|
2月前
|
设计模式 安全 Java
Java 编程中的设计模式:单例模式的深度解析
【9月更文挑战第22天】在Java的世界里,单例模式就像是一位老练的舞者,轻盈地穿梭在对象创建的舞台上。它确保了一个类仅有一个实例,并提供全局访问点。这不仅仅是代码优雅的体现,更是资源管理的高手。我们将一起探索单例模式的奥秘,从基础实现到高级应用,再到它与现代Java版本的舞蹈,让我们揭开单例模式的面纱,一探究竟。
40 11
|
1月前
|
设计模式 SQL 安全
【编程进阶知识】Java单例模式深度解析:饿汉式与懒汉式实现技巧
本文深入解析了Java单例模式中的饿汉式和懒汉式实现方法,包括它们的特点、实现代码和适用场景。通过静态常量、枚举类、静态代码块等方式实现饿汉式,通过非线程安全、同步方法、同步代码块、双重检查锁定和静态内部类等方式实现懒汉式。文章还对比了各种实现方式的优缺点,帮助读者在实际项目中做出更好的设计决策。
42 0
|
2月前
|
设计模式 Java 安全
Java设计模式-单例模式(2)
Java设计模式-单例模式(2)
|
3月前
|
设计模式 安全 Java
Java编程中的单例模式深度解析
【8月更文挑战第31天】 单例模式,作为设计模式中的经典之一,在Java编程实践中扮演着重要的角色。本文将通过简洁易懂的语言,逐步引导读者理解单例模式的本质、实现方法及其在实际应用中的重要性。从基础概念出发,到代码示例,再到高级应用,我们将一起探索这一模式如何优雅地解决资源共享和性能优化的问题。
|
3月前
|
设计模式 安全 Java
Java中的单例模式:理解与实践
【8月更文挑战第31天】在软件设计中,单例模式是一种常用的设计模式,它确保一个类只有一个实例,并提供一个全局访问点。本文将深入探讨Java中实现单例模式的不同方法,包括懒汉式、饿汉式、双重校验锁以及静态内部类等方法。每种方法都有其适用场景和潜在问题,我们将通过代码示例来展示如何根据具体需求选择合适的实现方式。