akka设计模式系列-While模式

简介:   While模式严格来说是while循环在Akka中的合理实现。while是开发过程中经常用到的语句之一,也是绝大部分编程语言都支持的语法。但while语句是一个循环,如果循环条件没有达到会一直执行while语句体的代码,且会阻塞while语句外的代码。

  While模式严格来说是while循环在Akka中的合理实现。while是开发过程中经常用到的语句之一,也是绝大部分编程语言都支持的语法。但while语句是一个循环,如果循环条件没有达到会一直执行while语句体的代码,且会阻塞while语句外的代码。如果在Akka中简单的使用while语句会极大的限制当前actor的功能。

object GeneralWhile {
  def main(args: Array[String]): Unit = {
    var i=0
    val maxLine = 10
    while(i<maxLine){
      println(i)
      i += 1
    }
  }
}

 输出:

0
1
2
3
4
5
6
7
8
9

   上图是while语句的常规用法,打印了从0-9的数字。如果这段代码出现在了actor对某个消息的处理过程中,就会带来其他的问题和不便。

class WhileActor extends Actor{
  override def receive: Receive = {
    case "start" =>
      println("do start work")
      var i=0
      val maxLine = 10
      while(i<maxLine){
        println(i)
        i += 1
      }
      println("start work done")
    case "others" =>
      println("do other work")
  }
}
object WhilePattern1 {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("WhilePattern1",ConfigFactory.load())
    val whileActor = system.actorOf(Props(new WhileActor),"WhilePattern1")
    whileActor ! "start"
    whileActor ! "others"
  }
}

 输出:

do start work
0
1
2
3
4
5
6
7
8
9
start work done
do other work

   上面代码是actor中简单使用while的例子。其实在简单的业务场景下,这种实现并没有太大问题,只不过while可能会阻塞当前actor而已。不过while有一个极端的情况,那就是while死循环。虽然死循环不能轻易出现,不过也非常有用。比如有以下场景:循环读取数据库做某种操作。在Akka的消息处理过程中是绝对不能出现死循环的,一旦出现死循环这个actor基本就废了(因为阻塞到了这个方法处理)!

  其实如果你的业务需求需要在Akka中使用死循环,而且你也的确这么用了,那只能说明对Actor模型不熟悉,因为Actor模型本身对消息的处理就是“死循环”。为什么说actor本身就是一个“死循环"呢?actor在收到消息会进行对应的处理,死循环也就意味着一直收到消息,那么如何一直收到消息呢?其他actor给它发消息或者自己给自己发消息,很显然,actor内部的循环逻辑跟其他actor关系不大,发消息给自己是比较合理的。

  

class WhileForeverActor extends Actor{
  var condition = true
  override def preStart(): Unit = {
    super.preStart()
    self ! "doWork"
  }
  override def receive: Receive = {
    case "doWork" =>
      println("从数据库获取n条数据循环处理")
      Thread.sleep(1000)
      println("处理完毕")
      if(condition){
        self ! "doWork"
      }
    case "otherWork" =>
      println("处理其他消息")
  }
}
object WhilePattern2 {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("WhilePattern2",ConfigFactory.load())
    val whileActor: ActorRef = system.actorOf(Props(new WhileForeverActor),"WhilePattern2")
    Thread.sleep(3*1000)
    whileActor ! "otherWork"
    whileActor ! "otherWork"
  }
}

  输出:

从数据库获取n条数据循环处理
处理完毕
从数据库获取n条数据循环处理
处理完毕
从数据库获取n条数据循环处理
处理完毕
处理其他消息
处理其他消息
从数据库获取n条数据循环处理
处理完毕
从数据库获取n条数据循环处理
处理完毕
从数据库获取n条数据循环处理
处理完毕
从数据库获取n条数据循环处理

   上面是Akka中的while模式。简单点说,就是用自身消息驱动acotor的循环处理。这样做的好处就是可以在某次循环结束后及时的处理其他类型的消息,而不至于阻塞当前的actor,而且可以随时通过发消息的形式中断循环或修改循环条件。

   本文介绍了Akka中的while设计模式,该模式虽然简单,但也都是Akka初学者经常会遇到也最容易设计不当的情形。希望大家好好掌握该设计模式,设计出更优秀的代码。

 

目录
相关文章
|
1月前
|
设计模式 安全 Java
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
|
3月前
|
设计模式 数据库连接 PHP
PHP中的设计模式:提升代码的可维护性与扩展性在软件开发过程中,设计模式是开发者们经常用到的工具之一。它们提供了经过验证的解决方案,可以帮助我们解决常见的软件设计问题。本文将介绍PHP中常用的设计模式,以及如何利用这些模式来提高代码的可维护性和扩展性。我们将从基础的设计模式入手,逐步深入到更复杂的应用场景。通过实际案例分析,读者可以更好地理解如何在PHP开发中应用这些设计模式,从而写出更加高效、灵活和易于维护的代码。
本文探讨了PHP中常用的设计模式及其在实际项目中的应用。内容涵盖设计模式的基本概念、分类和具体使用场景,重点介绍了单例模式、工厂模式和观察者模式等常见模式。通过具体的代码示例,展示了如何在PHP项目中有效利用设计模式来提升代码的可维护性和扩展性。文章还讨论了设计模式的选择原则和注意事项,帮助开发者在不同情境下做出最佳决策。
|
1月前
|
设计模式 开发者 Python
Python编程中的设计模式:工厂方法模式###
本文深入浅出地探讨了Python编程中的一种重要设计模式——工厂方法模式。通过具体案例和代码示例,我们将了解工厂方法模式的定义、应用场景、实现步骤以及其优势与潜在缺点。无论你是Python新手还是有经验的开发者,都能从本文中获得关于如何在实际项目中有效应用工厂方法模式的启发。 ###
|
1月前
|
设计模式 安全 Java
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
39 1
|
2月前
|
设计模式 Java Kotlin
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
本教程详细讲解Kotlin语法,适合希望深入了解Kotlin的开发者。对于快速学习Kotlin语法,推荐查看“简洁”系列教程。本文重点介绍了构建者模式在Kotlin中的应用与改良,包括如何使用具名可选参数简化复杂对象的创建过程,以及如何在初始化代码块中对参数进行约束和校验。
28 3
|
3月前
|
设计模式 算法 安全
设计模式——模板模式
模板方法模式、钩子方法、Spring源码AbstractApplicationContext类用到的模板方法
设计模式——模板模式
|
3月前
|
设计模式 数据库连接 PHP
PHP中的设计模式:如何提高代码的可维护性与扩展性在软件开发领域,PHP 是一种广泛使用的服务器端脚本语言。随着项目规模的扩大和复杂性的增加,保持代码的可维护性和可扩展性变得越来越重要。本文将探讨 PHP 中的设计模式,并通过实例展示如何应用这些模式来提高代码质量。
设计模式是经过验证的解决软件设计问题的方法。它们不是具体的代码,而是一种编码和设计经验的总结。在PHP开发中,合理地使用设计模式可以显著提高代码的可维护性、复用性和扩展性。本文将介绍几种常见的设计模式,包括单例模式、工厂模式和观察者模式,并通过具体的例子展示如何在PHP项目中应用这些模式。
|
3月前
|
设计模式 Java Spring
spring源码设计模式分析-代理设计模式(二)
spring源码设计模式分析-代理设计模式(二)
|
2月前
|
设计模式 安全 Java
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
Kotlin教程笔记(51) - 改良设计模式 - 构建者模式
41 0
|
3月前
|
设计模式 Java
Java设计模式-工厂方法模式(4)
Java设计模式-工厂方法模式(4)