前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >使用桥接模式设计复杂的消息系统

使用桥接模式设计复杂的消息系统

原创
作者头像
Tom弹架构
修改2021-11-15 10:34:21
5990
修改2021-11-15 10:34:21
举报
文章被收录于专栏:Tom弹架构Tom弹架构

本文节选自《设计模式就该这样学》

举个例子,我们在平时办公的时候经常通过邮件消息、短信消息或者系统内消息与同事进行沟通。尤其在走一些审批流程的时候,我们需要记录这些过程以备查。根据类型来划分,消息可以分为邮件消息、短信消息和系统内消息。但是,根据紧急程度来划分,消息可以分为普通消息、加急消息和特急消息。显然,整个消息系统可以划分为两个维度,如下图所示。

file
file

如果我们用继承,则情况就复杂了,而且也不利于扩展。邮件消息可以是普通的,也可以是加急的;短信消息可以是普通的,也可以是加急的。下面我们用桥接模式来解决这个问题。

首先创建一个IMessage接口担任桥接的角色。

代码语言:txt
复制
/**
 * 实现消息发送的统一接口
 */
public interface IMessage {
    //要发送的消息的内容和接收人
    void send(String message, String toUser);
}

创建邮件消息实现EmailMessage类。

代码语言:txt
复制
/**
 * 邮件消息的实现类
 */
public class EmailMessage implements IMessage {
    public void send(String message, String toUser) {
        System.out.println("使用邮件消息发送" + message + "给" + toUser);
    }
}

创建短信消息实现SmsMessage类。

代码语言:txt
复制
/**
 * 短信消息的实现类
 * SMS(Short IMessage Service)短信消息服务
 */
public class SmsMessage implements IMessage {
    public void send(String message, String toUser) {
        System.out.println("使用短信消息发送" + message + "给" + toUser);
    }
}

然后创建桥接抽象角色AbstractMessage类。

代码语言:txt
复制
/**
 * 抽象消息类
 */
public abstract class AbstractMessage {
    //持有一个实现部分的对象
    IMessage message;

    //构造方法,传入实现部分的对象
    public AbstractMessage(IMessage message) {
        this.message = message;
    }

    //发送消息,委派给实现部分的方法
    public void sendMessage(String message, String toUser) {
        this.message.send(message, toUser);
    }
}

创建具体实现普通消息NomalMessage类。

代码语言:txt
复制
/**
 * 普通消息类
 */
public class NomalMessage extends AbstractMessage {

    //构造方法,传入实现部分的对象
    public NomalMessage(IMessage message) {
        super(message);
    }

    @Override
    public void sendMessage(String message, String toUser) {
        //对于普通消息,直接调用父类方法发送消息即可
        super.sendMessage(message, toUser);
    }
}

创建具体实现加急消息UrgencyMessage类。

代码语言:txt
复制
/**
 * 加急消息类
 */
public class UrgencyMessage extends AbstractMessage {

    //构造方法
    public UrgencyMessage(IMessage message) {
        super(message);
    }

    @Override
    public void sendMessage(String message, String toUser) {
        message = "加急:" + message;
        super.sendMessage(message, toUser);
    }

    //扩展它功能,监控某个消息的处理状态
    public Object watch(String messageId) {
        //根据给出的消息编码(messageId)查询消息的处理状态
        //组织成监控的处理状态,然后返回
        return null;
    }
}

最后编写客户端测试代码。

代码语言:txt
复制
 public static void main(String[] args) {
        IMessage message = new SmsMessage();
        AbstractMessage abstractMessage = new NomalMessage(message);
        abstractMessage.sendMessage("加班申请速批", "王总");

        message = new EmailMessage();
        abstractMessage = new UrgencyMessage(message);
        abstractMessage.sendMessage("加班申请速批", "王总");
}

运行结果如下图所示。

file
file

在上面的案例中,我们采用桥接模式解耦了“消息类型”和“消息紧急程度”这两个独立变化的维度。后续如果有更多的消息类型,比如微信、钉钉等,则直接新建一个类继承IMessage即可;如果紧急程度需要新增,则同样只需新建一个类实现AbstractMessage类即可。

关注微信公众号『 Tom弹架构 』回复“设计模式”可获取完整源码。

【推荐】Tom弹架构:30个设计模式真实案例(附源码),挑战年薪60W不是梦

本文为“Tom弹架构”原创,转载请注明出处。技术在于分享,我分享我快乐!undefined如果本文对您有帮助,欢迎关注和点赞;如果您有任何建议也可留言评论或私信,您的支持是我坚持创作的动力。关注微信公众号『 Tom弹架构 』可获取更多技术干货!

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
短信
腾讯云短信(Short Message Service,SMS)可为广大企业级用户提供稳定可靠,安全合规的短信触达服务。用户可快速接入,调用 API / SDK 或者通过控制台即可发送,支持发送验证码、通知类短信和营销短信。国内验证短信秒级触达,99%到达率;国际/港澳台短信覆盖全球200+国家/地区,全球多服务站点,稳定可靠。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档