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的原因，我们看到了写入控制台的日志消息。

也就是说，Eve​​ntStream不仅适合于记录。 它是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目录中。

从配置中，我们可以得出：

  1. loggers属性指示将要订阅日志事件的Actor。 Slf4jLogger所做的只是简单地使用日志消息，并将其委托给SLF4J Logger外观。
  2. loglevel属性仅指示记录日志时应考虑的最低级别。
  3. 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文件，我们配置看起来像这样。

SLF4J记录

测试Akka

请注意，这绝不是Test Akka的详尽介绍。 我们将在以下各部分中相应标题下的“测试”的更多功能上构建测试。 这些测试用例旨在覆盖我们之前编写的Actor。

当StudentSimulatorApp我们的需求时，您将同意应将其从测试用例中删除。

为了减轻测试的痛苦，Akka提出了一个了不起的测试工具包，使用它我们可以做一些神奇的事情，例如直接探查Actor实现的内部。

聊够了，让我们看看测试用例。

首先让我们尝试将StudentSimulatorApp映射到测试用例。

映射001

现在让我们单独看一下声明。 

class TeacherPreTest extends TestKit(ActorSystem("UniversityMessageSystem"))  with WordSpecLikewith MustMatcherswith BeforeAndAfterAll {

因此，从TestCase类的定义中，我们看到：

  1. TestKit特性接受一个ActorSystem通过它我们可以创建Actor。 在内部，TestKit装饰ActorSystem并替换默认的调度程序。
  2. 我们使用WordSpec ，这是使用ScalaTest编写测试用例的许多有趣方式之一。
  3. MustMatchers提供方便的方法来使测试用例看起来像自然语言
  4. 在测试用例完成之后，我们混入BeforeAndAfterAll以关闭ActorSystem。 特质提供的afterAll方法更像我们在JUnit中的tearDown

1、2 –向演员发送消息

  1. 第一个测试用例只是向PrintActor发送一条消息。 它没有断言！
  2. 第二种情况将消息发送到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并断言日志消息本身的存在？ 看起来我们也可以做到。

这涉及两个步骤：

  1. 您需要像这样向您的TestKit添加额外的配置： 
    class TeacherTest extends TestKit(ActorSystem("UniversityMessageSystem", ConfigFactory.parseString("""akka.loggers = ["akka.testkit.TestEventListener"]""")))  with WordSpecLikewith MustMatcherswith BeforeAndAfterAll {
  2. 现在我们已经订阅了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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/362340.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

vue笔记（二）Vue-class与style、事件、计算属性、数据监听、指令+自定义指令、过滤器

vue笔记（二）Vue-class与style、事件、计算属性、数据监听、指令+自定义指令、过滤器

vue官网 一 、class、style操作 二、事件 三、计算属性 四、数据监听、观测 五、指令自定义指令 六、过滤器 一 、class、style操作 官网 1. class使用&#xff1a; &#xff08;1&#xff09;v-bind:class“数据|属性|变量|表达式” &#xff08;2&#xff09;v-bind:class“…
阅读更多...
oracle_linux_6_64（bit）上安装oracle11gR2数据库环境快速准备神器oracle-rdbms-server-11gR2-preinstall...

oracle_linux_6_64（bit）上安装oracle11gR2数据库环境快速准备神器oracle-rdbms-server-11gR2-preinstall...

https://blog.csdn.net/nalnait/article/details/81582637?tdsourcetags_pctim_aiomsg https://blog.csdn.net/ljunjie82/article/details/37373595?tdsourcetags_pctim_aiomsg 1、oracle linux上安装oracle数据库环境快速准备介绍 在Linux上安装oracle数据库&#xff0c;…
阅读更多...
DevExpress控件之GridControl控件

DevExpress控件之GridControl控件

DevExpress控件之GridControl控件http://blog.sina.com.cn/s/blog_6769068d0100iucx.html1. 设置数据源:string sql "select fid,fname from dual"; DataTable dt DALUse.Query(sql).Tables[0];gridControl1.DataSource dt;*:Daluse是项目数据库连接基类,不用特别…
阅读更多...
Vue 中computed 与 methods 区别

Vue 中computed 与 methods 区别

1、示例 <!DOCTYPE html><html lang"zh"><head><meta charset"UTF-8" /><meta name"viewport" content"widthdevice-width, initial-scale1.0" /><meta http-equiv"X-UA-Compatible" cont…
阅读更多...
Nsum问题

Nsum问题

题目 题解 暴力法 class Solution:def fourSum(self, nums: List[int], target: int) -> List[List[int]]:if len(nums) < 4:return []nums.sort()N len(nums)res []for i in range(N-3):for j in range(i1, N-2):for k in range(j1, N-1):for m in range(k1, N):tmp…
阅读更多...
Hazelcast入门指南第4部分

Hazelcast入门指南第4部分

这是我的Hazelcast系列的第四部分。 如果一个人没有看到其他三个人&#xff0c;我建议一个人去看第1 部分 &#xff0c; 第2 部分和第3部分 。 记录中 日志记录是任何应用程序的重要功能&#xff0c;我的示例也是如此。 System.out.println可以用作告诉用户控制台应用程序中正…
阅读更多...
js笔记（一）js基础、程序结构、函数

js笔记（一）js基础、程序结构、函数

大标题小节一、js 基础1. javascript的组成&#xff1b;2. 运行js&#xff1b;3. 打印信息&#xff1b;4. 关键字var&#xff1b;5. js中的数据类型&#xff1b;6. NaN&#xff08;not a number&#xff09;&#xff1b;7. js运算符&#xff1b;8. 数据类型转换&#xff1b;9. …
阅读更多...
DB2 9 底子（730 考试）认证指南，第 3 局部: 拜访 DB2 数据(3)

DB2 9 底子（730 考试）认证指南，第 3 局部: 拜访 DB2 数据(3)

建树第一个数据库First Steps在 DB2 的安顿进程中&#xff0c;会表示 First Steps 面板&#xff0c;它答运用户生成要操作的示例数据库&#xff1a; 选择 Database Creation 选项将表示一个附加菜单&#xff0c;可以建树 SAMPLE 数据库。 大大都用户希冀建树 SAMPLE 数据库并运…
阅读更多...
《学习之道》第十二章专注后打断

《学习之道》第十二章专注后打断

奥运健儿并不是周末慢跑几个小时就速度超群&#xff0c;也不是闲暇时举几次哑铃就力拔千斤&#xff1b; 象棋大师也不是靠临时跑佛脚就能构筑起自己的神经结构。相反&#xff0c;他们都是在日积月累中&#xff0c;伴随着大量练习&#xff0c;才慢慢建立起自己的知识库的&#x…
阅读更多...
vue class绑定方式

vue class绑定方式

1、对象语法 <div class"static"v-bind:class"{ active: isActive, text-danger: hasError }"></div>data: {isActive: true,hasError: false} 2、数组语法 <div v-bind:class"[isActive ? activeClass : , errorClass]"><…
阅读更多...
新的自定义控件：TaskProgressView

新的自定义控件：TaskProgressView

我已经编写了一个新的自定义控件&#xff0c;并将其提交到ControlsFX项目。 这是一个高度专业的控件&#xff0c;用于显示后台任务&#xff0c;其当前状态和进度的列表。 这实际上是我为ControlsFX编写的第一个控件&#xff0c;只是出于乐趣的考虑&#xff0c;这意味着我自己没…
阅读更多...
js笔记（三）ES5、ES5新增的数组的方法、字符串的方法、字符编码、对象的序列化和反序列化、bind

js笔记（三）ES5、ES5新增的数组的方法、字符串的方法、字符编码、对象的序列化和反序列化、bind

数组方法、字符串方法总结 大目录小目录一、ES5严格模式1. 严格模式&#xff1b;2. 严格模式的行为变更&#xff1b;二、ES5新增的数组的方法1. 判断是否为数组&#xff1a;Array.isArray()&#xff1b;2. 判断数组中是否存在某个值&#xff1a;indexOf(data, start)、lastInd…
阅读更多...
RabbitMQ消息队列帮助类

RabbitMQ消息队列帮助类

调用 //消息队列发消息MqConfigInfo config new MqConfigInfo();config.MQExChange "DrawingOutput";config.MQQueueName "DrawingOutput";config.MQRoutingKey "DrawingOutput";MqHelper heper new MqHelper(config);byte[] body Encodin…
阅读更多...
SVG入门

SVG入门

1、简介 使用xml描述的矢量文件。 2、兼容性 https://caniuse.com/#searchsvg 3、使用方式 &#xff08;1&#xff09;浏览器直接打开 &#xff08;2&#xff09;html中使用img引用 <p><img src"simple.svg" width"50" height"50"…
阅读更多...
红旗桌面版本最新运用方式和题目问题解答100例-4

红旗桌面版本最新运用方式和题目问题解答100例-4

33、RF4.0默许安装的软件有哪些&#xff1f; 默许安装的软件紧张有&#xff1a;KGhostView、Gimp、Pixie(图象阅读器)、屏幕截图挨次、扫描挨次、画图挨次&#xff1b;CD刻录 (cdbakeoven)、CD播放(kscd)、MP3播放(xmms)、kxine&#xff1b;星际译王、Mozilla、kmail、gftp、ga…
阅读更多...
Maven常见问题和陷阱

Maven常见问题和陷阱

喜欢它还是讨厌它&#xff08;很多人似乎都讨厌它&#xff09;&#xff0c; Maven是64&#xff05;的Java开发人员广泛使用的工具&#xff08;来源– 2014年Java工具和技术前景 &#xff09;。 大多数经验丰富的开发人员已经对Maven感到头疼。 通常以困难的方式&#xff0c;用…
阅读更多...
Oracl数据库中大数据的备份-1

Oracl数据库中大数据的备份-1

起原&#xff1a;chinaitlab　 问&#xff1a;公司里的oracle数据库有20G之大(这是一个方案的大小.原本这个方案有30G,我已经把能删的数据都删了),怎样备份?觉得备份一次好慢啊.专家有什么指导一下的吗?(另:20G的数据库是不是备份也要20G多么?)我搁浅能每周备份一次,最好天…
阅读更多...
js 值和引用

js 值和引用

1、概述 简单值&#xff08;基本类型&#xff09;通过值复制的方式来赋值/传递。 复合值&#xff08;对象&#xff09;通过引用复制的方式来赋值/传递。 <!DOCTYPE html><html lang"zh"><head><meta charset"UTF-8" /><title…
阅读更多...
js笔记（六）事件、正则

js笔记（六）事件、正则

数组方法、字符串方法总结 大标题小节一、事件1.1 事件&#xff1b;1.2 事件对象&#xff1b;1.3 键盘事件的keyCode&#xff1b;1.4 关于鼠标的尺寸&#xff1b;1.5 事件冒泡&#xff1b;1.6 事件的默认行为&#xff1b;1.7 事件监听&#xff1b;1.8 事件委托&#xff08;事件…
阅读更多...
Hazelcast入门指南第3部分

Hazelcast入门指南第3部分

这是从初学者的角度来看一系列有关如何使用Hazelcast的文章的延续。 如果您还没有阅读最后两个&#xff0c;我鼓励您阅读它们&#xff1a; Hazelcast入门指南第1部分 Hazelcast入门指南第2部分 原始人来了 在上一篇文章中&#xff0c;我提到将ILock与IList和ISet一起使用&am…
阅读更多...
最新文章

Copyright @ 2022~2023