Akka Notes –演员记录和测试
在前两部分( 一 , 二 )中,我们简要讨论了Actor以及消息传递的工作方式。 在这一部分中,让我们看一下如何修复并记录我们的TeacherActor
。
概括
这就是我们上一部分中的Actor的样子:
class TeacherActor extends Actor {val quotes = List("Moderation is for cowards","Anything worth doing is worth overdoing","The trouble is you think you have time","You never gonna know if you never even try")def receive = {case QuoteRequest => {import util.Random//Get a random Quote from the list and construct a responseval quoteResponse=QuoteResponse(quotes(Random.nextInt(quotes.size)))println (quoteResponse)}}
}
使用SLF4J记录Akka
您会注意到,在代码中,我们正在将quoteResponse
打印到标准输出,您显然会认为这是一个坏主意。 让我们通过启用SLF4J Facade日志进行修复。
1.修复类以使用日志记录
Akka提供了一个很好的小特征ActorLogging
来实现它。 让我们混合:
class TeacherLogActor extends Actor with ActorLogging {val quotes = List("Moderation is for cowards","Anything worth doing is worth overdoing","The trouble is you think you have time","You never gonna know if you never even try")def receive = {case QuoteRequest => {import util.Random//get a random element (for now)val quoteResponse=QuoteResponse(quotes(Random.nextInt(quotes.size)))log.info(quoteResponse.toString())}}//We'll cover the purpose of this method in the Testing sectiondef quoteList=quotes}
绕道走一圈:
在内部,当我们记录一条消息时,ActorLogging中的记录方法(最终)将日志消息发布到EventStream 。 是的,我确实说过publish
。 那么,EventStream实际上是什么?
EventStream和记录
EventStream
行为就像我们可以向其发布和接收消息的消息代理一样。 与常规MOM的一个细微区别是EventStream的订阅者只能是Actor。
在记录消息的情况下,所有日志消息都将发布到EventStream。 默认情况下,订阅这些消息的Actor是DefaultLogger ,它仅将消息打印到标准输出中。
class DefaultLogger extends Actor with StdOutLogger { override def receive: Receive = {...case event: LogEvent ⇒ print(event)}
}
因此,这就是我们尝试启动StudentSimulatorApp的原因,我们看到了写入控制台的日志消息。
也就是说,EventStream不仅适合于记录。 它是VM内ActorWorld内部可用的通用发布-订阅机制(稍后会详细介绍)。
返回SLF4J设置:
2.将Akka配置为使用SLF4J
akka{ loggers = ["akka.event.slf4j.Slf4jLogger"]loglevel = "DEBUG"logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
}
我们将此信息存储在一个名为application.conf
的文件中,该文件应该在您的类路径中。 在我们的sbt文件夹结构中,我们会将其放在您的main/resources
目录中。
从配置中,我们可以得出:
loggers
属性指示将要订阅日志事件的Actor。 Slf4jLogger所做的只是简单地使用日志消息,并将其委托给SLF4J Logger外观。loglevel
属性仅指示记录日志时应考虑的最低级别。logging-filter
比较当前配置的日志loglevel
和传入的日志消息级别,并在发布到EventStream之前剔除配置的日志级别以下的任何日志消息。
但是,为什么前面的示例没有提供application.conf?
仅仅是因为Akka提供了一些合理的默认值,所以我们在开始使用它之前不需要构建配置文件。 为了自定义各种内容,我们将在这里经常重新访问该文件。 您可以在application.conf
内部使用一堆很棒的参数来单独记录日志。 它们在这里详细解释。
3.放入logback.xml
现在,我们将配置一个由logback支持的SLF4J记录器。
<?xml version="1.0" encoding="UTF-8"?>
<configuration> <appender name="FILE"class="ch.qos.logback.core.rolling.RollingFileAppender"><encoder><pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern></encoder><rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><fileNamePattern>logs\akka.%d{yyyy-MM-dd}.%i.log</fileNamePattern><timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"><maxFileSize>50MB</maxFileSize></timeBasedFileNamingAndTriggeringPolicy></rollingPolicy></appender><root level="DEBUG"><appender-ref ref="FILE" /></root>
</configuration>
我也将它与application.conf
一起放入了main/resources
文件夹中。 请确保main/resources
现在位于Eclipse或其他IDE的类路径中。 还应将logback和slf4j-api包含到build.sbt中 。
而当我们揭开序幕我们StudentSimulatorApp
和发送邮件到我们的新TeacherLogActor
,该akkaxxxxx.log
文件,我们配置看起来像这样。
测试Akka
请注意,这绝不是Test Akka的详尽介绍。 我们将在以下各部分中相应标题下的“测试”的更多功能上构建测试。 这些测试用例旨在覆盖我们之前编写的Actor。
当StudentSimulatorApp
我们的需求时,您将同意应将其从测试用例中删除。
为了减轻测试的痛苦,Akka提出了一个了不起的测试工具包,使用它我们可以做一些神奇的事情,例如直接探查Actor实现的内部。
聊够了,让我们看看测试用例。
首先让我们尝试将StudentSimulatorApp映射到测试用例。
现在让我们单独看一下声明。
class TeacherPreTest extends TestKit(ActorSystem("UniversityMessageSystem")) with WordSpecLikewith MustMatcherswith BeforeAndAfterAll {
因此,从TestCase类的定义中,我们看到:
TestKit
特性接受一个ActorSystem
通过它我们可以创建Actor。 在内部,TestKit装饰ActorSystem并替换默认的调度程序。- 我们使用WordSpec ,这是使用ScalaTest编写测试用例的许多有趣方式之一。
- MustMatchers提供方便的方法来使测试用例看起来像自然语言
- 在测试用例完成之后,我们混入
BeforeAndAfterAll
以关闭ActorSystem。 特质提供的afterAll
方法更像我们在JUnit中的tearDown
1、2 –向演员发送消息
- 第一个测试用例只是向PrintActor发送一条消息。 它没有断言!
- 第二种情况将消息发送到Log actor,后者使用ActorLogging的
log
字段将消息发布到EventStream。 这也没有断言!
//1. Sends message to the Print Actor. Not even a testcase actually"A teacher" must {"print a quote when a QuoteRequest message is sent" in {val teacherRef = TestActorRef[TeacherActor]teacherRef ! QuoteRequest}}//2. Sends message to the Log Actor. Again, not a testcase per se"A teacher with ActorLogging" must {"log a quote when a QuoteRequest message is sent" in {val teacherRef = TestActorRef[TeacherLogActor]teacherRef ! QuoteRequest}
3 –维护参与者的内部状态
第三种情况使用TestActorRef
的underlyingActor
quoteList
方法,并调用TeacherActor
的quoteList
方法。 quoteList
方法返回引号列表。 我们使用此列表来声明其大小。
如果对quoteList
引用使您退缩,请参考上面列出的TeacherLogActor代码,并查找:
//From TeacherLogActor
//We'll cover the purpose of this method in the Testing sectiondef quoteList=quotes
//3. Asserts the internal State of the Log Actor. "have a quote list of size 4" in {val teacherRef = TestActorRef[TeacherLogActor]teacherRef.underlyingActor.quoteList must have size (4)teacherRef.underlyingActor.quoteList must have size (4)}
4 –声明日志消息
正如我们前面在EventStream和Logging部分(上文)中所讨论的,所有日志消息都发送到EventStream
,并且SLF4JLogger
订阅并使用其附加程序将其写入日志文件/控制台等。直接在我们的测试用例中使用EventStream并断言日志消息本身的存在? 看起来我们也可以做到。
这涉及两个步骤:
- 您需要像这样向您的
TestKit
添加额外的配置:class TeacherTest extends TestKit(ActorSystem("UniversityMessageSystem", ConfigFactory.parseString("""akka.loggers = ["akka.testkit.TestEventListener"]"""))) with WordSpecLikewith MustMatcherswith BeforeAndAfterAll {
- 现在我们已经订阅了EventStream,我们可以从测试用例中将其声明为:
//4. Verifying log messages from eventStream"be verifiable via EventFilter in response to a QuoteRequest that is sent" in {val teacherRef = TestActorRef[TeacherLogActor]EventFilter.info(pattern = "QuoteResponse*", occurrences = 1) intercept {teacherRef ! QuoteRequest}}
EventFilter.info
块仅拦截1条以QuoteResponse( pattern='QuoteResponse*
)开头的日志消息。 (您也可以通过使用start='QuoteResponse'
。如果没有消息发送给TeacherLogActor,则该测试用例将失败。
5 –使用构造函数参数测试Actor
请注意,我们在测试用例中创建Actor的方式是通过TestActorRef[TeacherLogActor]
而不是通过system.actorOf
。 这只是为了使我们可以通过TeacherActorRef中的underlyingActor
Actor方法访问Actor的内部。 我们将无法通过在常规运行时可以访问的ActorRef
来实现此ActorRef
。 (这并没有给我们在生产中使用TestActorRef的任何借口。您会被追捕的)。
如果Actor接受参数,那么我们创建TestActorRef的方式将是:
val teacherRef = TestActorRef(new TeacherLogParameterActor(quotes))
整个测试用例将如下所示:
//5. have a quote list of the same size as the input parameter" have a quote list of the same size as the input parameter" in {val quotes = List("Moderation is for cowards","Anything worth doing is worth overdoing","The trouble is you think you have time","You never gonna know if you never even try")val teacherRef = TestActorRef(new TeacherLogParameterActor(quotes))//val teacherRef = TestActorRef(Props(new TeacherLogParameterActor(quotes)))teacherRef.underlyingActor.quoteList must have size (4)EventFilter.info(pattern = "QuoteResponse*", occurrences = 1) intercept {teacherRef ! QuoteRequest}}
关闭ActorSystem
最后, afterAll
生命周期方法:
override def afterAll() { super.afterAll()system.shutdown()}
码
- 与往常一样,可以从github这里下载整个项目。
翻译自: https://www.javacodegeeks.com/2014/10/akka-notes-actor-logging-and-testing.html
Akka Notes –演员记录和测试相关推荐
- akka和rabbitmq_Akka Notes –演员记录和测试
akka和rabbitmq 在前两部分( 一 , 二 )中,我们简要讨论了Actor以及消息传递的工作方式. 在这一部分中,让我们看一下如何修复并记录我们的TeacherActor . 回顾 这就是我 ...
- Akka笔记–演员介绍
过去做过多线程的任何人都不会否认管理多线程应用程序有多么艰辛和痛苦. 我说管理是因为它一开始很简单,一旦您开始看到性能改进,它就会变得非常有趣. 但是,当您发现没有一种简单的方法可以从子任务中的错误或 ...
- Release Notes --版本记录
Release Notes 一.Release 14 Release Notes 版本14发布记录 These release notes highlight what's new in Releas ...
- Akka型演员:探索接收器模式
在上一篇文章中,我们研究了Akka Typed提供的一些基本功能. 在本文和下一篇文章中,我们将更进一步地了解一些其他功能,并通过查看Akka Typed提供的两种不同模式来做到这一点:Receive ...
- JS逆向笔记-记录某测试论坛的js逆向练习
这个网站应该是专门练习的,因为有个地方说不太通,在此只能算是练习,记录下,方便以后进行查阅. 首先访问主页: 他会设置一个cookie值,并且会把加密的salt 带出来.还有个叫lt的东西也会用htm ...
- macOS Big Sur 11 Beta 8 Release Notes 更新记录
更新云图 总览 macOS 11 SDK支持为运行macOS Big Sur 11的Mac开发应用程序.该SDK与Xcode 12.2 beta捆绑在一起,可从Beta软件下载处获得.有关Xcode ...
- 《Python编程从入门到实践》记录之测试代码(unitttest模块)
unittest模块提供了测试代码工具. 单元测试:用于核实函数的某个方面没有问题 测试用例:一组单元测试,这些单元测试一起核实函数在各种情形下的行为都符合要求. 函数编写测试用例时,要导入模块uni ...
- 记录从站测试的一件糗事
近期为一件尴尬的事苦恼.今天终于解决了,记录一下. 我选择LAN9252从站和AX58100从站连接在一起,用TwinCAT软件做主站通信,遇到一个问题:单个从站连接在主站上是可以正常工作的.但是串联 ...
- android 记录ip 日志,Linux 实现rsyslog日志里面的IP地址记录 未测试
[读书笔记]iOS-ARC-Xcode检测循环引用 一,在桌面上新建立一个工程,在ViewController.m中输入如下代码: - (void)viewDidLoad { [super viewD ...
最新文章
- iOS App上架流程
- 腾讯大数据回答2019:鹅厂开源先锋,日均计算量超30万亿,全力打破数据墙
- php 运行外部程序_PHP实现执行外部程序的方法详解
- python是不是特别垃圾-【转】python是垃圾吗?
- 使用sizeof计算类的大小
- Dataset之谷歌地图数据集:谷歌地图数据集的简介、安装、使用方法之详细攻略
- 【原创】源智工作流-Silverlight流程设计器
- Tomcat服务安全加固和优化
- 证书格式简介及不同格式之间的转换方式
- 几种主流热修复方案分析
- 处理网页上的字符溢出的方法
- 最全Android UVC Camera 闪退问题修复
- web前端开发工程师面试题大全
- 车间数据监控可视化大屏实操来啦
- 怎样挑选鱼头 鱼头怎么做好吃
- Redhat 7.9安装db2 11.1.4.6 DBT3514错误
- RabbitMQ可视化界面登录不了,报错:Login failed
- 袋鼠云数据中台专栏2.0 | 数据中台之数据源
- 真正中文攻略之 SAKURA~雪月華~ 花鳥風月プレミアムエディション 汉化、攻略...
- 单片机实例6——报警产生器(硬件电路图+汇编程序+C语言程序)
热门文章
- 八皇后问题判断此位置是否需合适
- sql server 2008安装_性能不够?基于时序数据库的Zabbix 5.2安装指南
- 直方图 帕累托图_如何发现现象背后的关键因素?帕累托图,质量管理的利器...
- 转:Spring Boot 获取 HttpServletRequest 的方法
- mysql8.0.11 zip安装教程
- 一文理清HashMap的实现及细节
- 移除指定的session
- SonarQube 8.3.x中的Maven项目的测试覆盖率报告
- 程序员面试算法_程序员的前20个搜索和排序算法面试问题
- jvm体系结构_JVM体系结构:JVM中的执行引擎