您当前的位置:首页 > 电脑百科 > 程序开发 > 架构

浅谈常用的架构模式

时间:2020-12-28 13:03:08  来源:  作者:

架构模式是软件架构中在给定环境下常遇到问题的通用的、可重用的解决方案。类似于软件设计模式但覆盖范围更广,致力于软件工程中不同问题,如计算机硬件性能限制、高可用性、业务风险极小化。一些架构模式在软件框架被实现。- 维基百科

说明

架构模式有很多种,本文只讨论工作中使用较多的几种:

  • 分层架构
  • Pipeline架构
  • 事件驱动架构

 

分层架构

浅谈常用的架构模式

分层架构模式

分层架构模式工作中用的比较多,常见的有MVC等,通过分层将职责划分到某一层上,层次清晰,架构明了。

我们以MVC来举例说明:controller -> service -> dao

@RestController
@RequestMApping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    /**
     * 新增订单
     * @param order
     * @return
     */
    @PostMapping("/add")
    public Response addOrder(Order order) {
        orderService.add(order);
        return Response.success();
    }
}
public interface OrderService {
    /**
     *  添加订单
     * @param order
     * @return
     */
    boolean add(Order order);
}
public interface OrderRepository {

    int save(Order order);
}

按照依赖方向,上层依次依赖下层,每一层处理不同到逻辑。

之前到文章有讨论过通过依赖反转来改变依赖关系,从而更少到减少耦合。

 

Pipeline架构

浅谈常用的架构模式

Pipeline架构模式

Pipeline架构也称为管道或流水线架构,处理流程成线性,各个环节有相应到组件处理,从前到后顺序执行。

概念说明:

source: 数据源,通常使用流数据为源,比如:KafkaSource;

channel:信道或管道,用于处理或转换数据,比如:JsonChannel;

Sink:数据落地,通常用于数据存储或转发,比如:DbSink, KafkaSink;

Component: 组件,用于执行逻辑的最小单元,source,channel,sink都是一个Component;

Pipeline: 管道或流水线,一个Pipeline由上面的组件组成,不同的业务可以组装成不同的Pipeline;

 

代码实现:数字数据源 -> 累加 -> 转成字符串 -> 落地

/**
 *  组件
 */
public interface Component<T> {
    /**
     *  组件名称
     * @return
     */
    String getName();

    /**
     *  获取下游组件
     * @return
     */
    Collection<Component> getDownStrems();

    /**
     *  组件执行
     */
    void execute(T o);
}
public abstract class AbstractComponent<T, R> implements Component<T>{

    @Override
    public void execute(T o) {
        // 当前组件执行
        R r = doExecute(o);
        System.out.println(getName() + " receive " + o + " return " + r);
        // 获取下游组件,并执行
        Collection<Component> downStreams = getDownStrems();
        if (!CollectionUtils.isEmpty(downStreams)) {
            downStreams.forEach(c -> c.execute(r));
        }
    }

    protected abstract R doExecute(T o);
}
/**
 *  数据来源
 */
public abstract class Source<T, R> extends AbstractComponent<T, R>{

}
/**
 *  管道/信道
 * @param <T>
 */
public abstract class Channel<T, R> extends AbstractComponent<T, R> {

}
/**
 *  数据落地
 * @param <T>
 */
public abstract class Sink<T, R> extends AbstractComponent<T, R> {

}
public class IntegerSource extends Source<Integer,  Integer>{

    @Override
    protected Integer doExecute(Integer o) {
        return o;
    }

    @Override
    public String getName() {
        return "Integer-Source";
    }

    @Override
    public Collection<Component> getDownStrems() {
        return Collections.singletonList(new IncrChannel());
    }

}
public class IncrChannel extends Channel<Integer, Integer> {

    @Override
    protected Integer doExecute(Integer o) {
        return o + 1;
    }

    @Override
    public String getName() {
        return "Incr-Channel";
    }

    @Override
    public Collection<Component> getDownStrems() {
        return Collections.singletonList(new StringChannel());
    }

}
public class StringChannel extends Channel<Integer, String> {

    @Override
    protected String doExecute(Integer o) {
        return "str" + o;
    }

    @Override
    public String getName() {
        return "String-Channel";
    }

    @Override
    public Collection<Component> getDownStrems() {
        return Collections.singletonList(new StringSink());
    }

}
public class StringSink extends Sink<String, Void>{

    @Override
    protected Void doExecute(String o) {
        return null;
    }

    @Override
    public String getName() {
        return "String-Sink";
    }

    @Override
    public Collection<Component> getDownStrems() {
        return null;
    }

}
/**
 *  流水线
 */
public class Pipeline {
    /**
     *  数据源
     */
    private Source source;

    public Pipeline(Source source) {
        this.source = source;
    }

    /**
     *  启动
     */
    public void start() {
        source.execute(1);
    }
}

测试:

public class PipelineTest {

    @Test
    public void test() {
        Pipeline pipeline = new Pipeline(new IntegerSource());
        pipeline.start();
    }
}

执行结果:

Integer-Source receive 1 return 1

Incr-Channel receive 1 return 2

String-Channel receive 2 return str2

String-Sink receive str2 return null

 

事件驱动架构

浅谈常用的架构模式

事件驱动模式

事件驱动是以某个具体事件为触发条件,从而贯穿这个处理流程。通常事件驱动属于发布订阅模式或观察者模式, 用于异步处理,解耦业务逻辑。具体实现有进程内的和分布式的方式,比如:EventBus, MQ等等。

 

代码举例:

public class OrderEventListener implements Listener<OrderEvent> {

    @Override
    public void onEvent(OrderEvent event) {
        System.out.println("receive event: " + event);
    }
}
public class EventBus {

    private final static List<Listener> listeners = new ArrayList<>();

    /**
     *  注册监听器
     * @param listener
     */
    public static void registerListener(Listener listener) {
        listeners.add(listener);
    }

    /**
     *  发布事件
     * @param event
     */
    public void publishEvent(Event event) {
        // 收到并处理事件
        listeners.forEach(l -> {
            l.onEvent(event);
        });
    }
}

测试:

public class EventBusTest {

    @Test
    public void publish() {
        OrderEvent event = new OrderEvent("order_2", OrderState.PENDING_PAYMENT);
        EventBus.registerListener(new OrderEventListener());
        EventBus eventBus = new EventBus();
        eventBus.publishEvent(event);
    }
}

Spring中也有事件发布和监听(深入浅出Spring/SpringBoot 事件监听机制):

@Component
public class OrderEventListener  {

    @Async
    @EventListener(OrderEvent.class)
    public void onEvent(OrderEvent event) {
        System.out.println("receive event: " + event);
    }
}
public class EventTest {
    @Autowired
    private ApplicationContext context;

    @Test
    public void publishEvent() {
        OrderEvent event = new OrderEvent("order_1", OrderState.PENDING_PAYMENT);
        context.publishEvent(event);
    }
}

 

总结

以上通过代码实例简单说明了工作中常用到的架构模式,但是模式不是固定的,工作中需结合实际情况按需使用即可。



Tags:架构   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
为了构建高并发、高可用的系统架构,压测、容量预估必不可少,在发现系统瓶颈后,需要有针对性地扩容、优化。结合楼主的经验和知识,本文做一个简单的总结,欢迎探讨。1、QPS保障目标...【详细内容】
2021-12-27  Tags: 架构  点击:(3)  评论:(0)  加入收藏
前言 单片机开发中,我们往往首先接触裸机系统,然后到RTOS,那么它们的软件架构是什么?这是我们开发人员必须认真考虑的问题。在实际项目中,首先选择软件架构是非常重要的,接下来我...【详细内容】
2021-12-23  Tags: 架构  点击:(7)  评论:(0)  加入收藏
现有数据架构难以支撑现代化应用的实现。 随着云计算产业的快速崛起,带动着各行各业开始自己的基于云的业务创新和信息架构现代化,云计算的可靠性、灵活性、按需计费的高性价...【详细内容】
2021-12-22  Tags: 架构  点击:(10)  评论:(0)  加入收藏
我是一名程序员关注我们吧,我们会多多分享技术和资源。进来的朋友,可以多了解下青锋的产品,已开源多个产品的架构版本。Thymeleaf版(开源)1、采用技术: springboot、layui、Thymel...【详细内容】
2021-12-14  Tags: 架构  点击:(20)  评论:(0)  加入收藏
本系列为 Netty 学习笔记,本篇介绍总结Java NIO 网络编程。Netty 作为一个异步的、事件驱动的网络应用程序框架,也是基于NIO的客户、服务器端的编程框架。其对 Java NIO 底层...【详细内容】
2021-12-07  Tags: 架构  点击:(16)  评论:(0)  加入收藏
前面谈过很多关于数字化转型,云原生,微服务方面的文章。虽然自己一直做大集团的SOA集成平台咨询规划和建设项目,但是当前传统企业数字化转型,国产化和自主可控,云原生,微服务是不...【详细内容】
2021-12-06  Tags: 架构  点击:(23)  评论:(0)  加入收藏
背景在日常工作中,我们通常需要存储一些日志,譬如用户请求的出入参、系统运行时打印的一些info、error之类的日志,从而对系统在运行时出现的问题有排查的依据。日志存储和检索...【详细内容】
2021-11-23  Tags: 架构  点击:(20)  评论:(0)  加入收藏
zookeeper动物管理员,是一个很形象的名字,是一个分布式协调服务。它可以用来做分布式配置管理,服务注册及发现,分布式锁。在CAP中,属于CP型。下图是zookeeper的架构图: 图中,绿色的...【详细内容】
2021-11-16  Tags: 架构  点击:(38)  评论:(0)  加入收藏
如何设计一个好的软件架构,如何提高软件的扩展性,移植性,复用性和可读性?很多做嵌入式开发的朋友经常会遇到这种情况:一个项目软件设计完成了,客户提出了一些新的功能需求。这时侯...【详细内容】
2021-11-08  Tags: 架构  点击:(35)  评论:(0)  加入收藏
架构是数据仓库建设的总体规划,从整体视角描述了解决方案的高层模型,描述了各个子系统的功能以及关系,描述了数据从源系统到决策系统的数据流程。业务需求回答了要做什么,架构就...【详细内容】
2021-11-03  Tags: 架构  点击:(35)  评论:(0)  加入收藏
▌简易百科推荐
为了构建高并发、高可用的系统架构,压测、容量预估必不可少,在发现系统瓶颈后,需要有针对性地扩容、优化。结合楼主的经验和知识,本文做一个简单的总结,欢迎探讨。1、QPS保障目标...【详细内容】
2021-12-27  大数据架构师    Tags:架构   点击:(3)  评论:(0)  加入收藏
前言 单片机开发中,我们往往首先接触裸机系统,然后到RTOS,那么它们的软件架构是什么?这是我们开发人员必须认真考虑的问题。在实际项目中,首先选择软件架构是非常重要的,接下来我...【详细内容】
2021-12-23  正点原子原子哥    Tags:架构   点击:(7)  评论:(0)  加入收藏
现有数据架构难以支撑现代化应用的实现。 随着云计算产业的快速崛起,带动着各行各业开始自己的基于云的业务创新和信息架构现代化,云计算的可靠性、灵活性、按需计费的高性价...【详细内容】
2021-12-22    CSDN  Tags:数据架构   点击:(10)  评论:(0)  加入收藏
▶ 企业级项目结构封装释义 如果你刚毕业,作为Java新手程序员进入一家企业,拿到代码之后,你有什么感觉呢?如果你没有听过多模块、分布式这类的概念,那么多半会傻眼。为什么一个项...【详细内容】
2021-12-20  蜗牛学苑    Tags:微服务   点击:(8)  评论:(0)  加入收藏
我是一名程序员关注我们吧,我们会多多分享技术和资源。进来的朋友,可以多了解下青锋的产品,已开源多个产品的架构版本。Thymeleaf版(开源)1、采用技术: springboot、layui、Thymel...【详细内容】
2021-12-14  青锋爱编程    Tags:后台架构   点击:(20)  评论:(0)  加入收藏
在了解连接池之前,我们需要对长、短链接建立初步认识。我们都知道,网络通信大部分都是基于TCP/IP协议,数据传输之前,双方通过“三次握手”建立连接,当数据传输完成之后,又通过“四次挥手”释放连接,以下是“三次握手”与“四...【详细内容】
2021-12-14  架构即人生    Tags:连接池   点击:(16)  评论:(0)  加入收藏
随着移动互联网技术的快速发展,在新业务、新领域、新场景的驱动下,基于传统大型机的服务部署方式,不仅难以适应快速增长的业务需求,而且持续耗费高昂的成本,从而使得各大生产厂商...【详细内容】
2021-12-08  架构驿站    Tags:分布式系统   点击:(23)  评论:(0)  加入收藏
本系列为 Netty 学习笔记,本篇介绍总结Java NIO 网络编程。Netty 作为一个异步的、事件驱动的网络应用程序框架,也是基于NIO的客户、服务器端的编程框架。其对 Java NIO 底层...【详细内容】
2021-12-07  大数据架构师    Tags:Netty   点击:(16)  评论:(0)  加入收藏
前面谈过很多关于数字化转型,云原生,微服务方面的文章。虽然自己一直做大集团的SOA集成平台咨询规划和建设项目,但是当前传统企业数字化转型,国产化和自主可控,云原生,微服务是不...【详细内容】
2021-12-06  人月聊IT    Tags:架构   点击:(23)  评论:(0)  加入收藏
微服务看似是完美的解决方案。从理论上来说,微服务提高了开发速度,而且还可以单独扩展应用的某个部分。但实际上,微服务带有一定的隐形成本。我认为,没有亲自动手构建微服务的经历,就无法真正了解其复杂性。...【详细内容】
2021-11-26  GreekDataGuy  CSDN  Tags:单体应用   点击:(35)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条