首页 > 其他分享 >AKKA消息传递

AKKA消息传递

时间:2023-10-26 12:03:20浏览次数:28  
标签:返回 sender Actor 响应 Future 消息 消息传递 AKKA


1.消息处理的一些基本机制:


将消息定义为不可变;


向Actor 请求响应;


转发消息;


Future 管道


2.有4种核心的Actor消息模式:tell、ask、forward和pipe


Ask:向Actor 发送一条消息,返回一个Future。当Actor 返回响应时,会完成


Future。不会向消息发送者的邮箱返回任何消息。


Tell: 向Actor 发送一条消息。所有发送至sender()的响应都会返回给发送消息的


Actor。


Forward:将接收到的消息再发送给另一个Actor。所有发送至sender()的响应都


会返回给原始消息的发送者。


Pipe:用于将Future 的结果返回给sender()或另一个Actor。如果正在使用Ask


或是处理一个Future,那么使用Pipe 可以正确地返回Future 的结果。


3.消息是不可变的


有2种方法可以用来定义可变消息:可变引用以及可变类型

标签:返回,sender,Actor,响应,Future,消息,消息传递,AKKA
From: https://blog.51cto.com/u_15834920/8032022

相关文章

  • Kafka的消息传递保证和一致性
    前言通过前面的文章,相信大家对Kafka有了一定的了解了,那接下来问题就来了,Kafka既然作为一个分布式的消息队列系统,那它会不会出现消息丢失或者重复消费的情况呢?今天咱们就来一探。实现机制Kafka采用了一系列机制来实现消息传递的保证和一致性,关键点:至少一次的消息传递(AtLeastOnceD......
  • Kafka的消息传递保证和一致性
    前言通过前面的文章,相信大家对Kafka有了一定的了解了,那接下来问题就来了,Kafka既然作为一个分布式的消息队列系统,那它会不会出现消息丢失或者重复消费的情况呢?今天咱们就来一探。实现机制Kafka采用了一系列机制来实现消息传递的保证和一致性,关键点:至少一次的消息传递(AtLeas......
  • 大数据开发-从Scala到Akka并发编程_jDW32G3c87fjEBtYNE7Z7f
    大数据开发-从Scala到Akka并发编程大数据开发-从Scala到Akka并发编程[4-1Scala作业.pdf](file/4-1Scala作业_UVqqJLwoIp.pdf)1.递归实现瓶盖,瓶子换酒瓶的算法1.1需求描述每瓶啤酒2元,3个空酒瓶或者5个瓶盖可换1瓶啤酒。100元最多可喝多少瓶啤酒?(不允许借啤酒)思路:利用递归算......
  • 大数据开发-从Scala到Akka并发编程_jDW32G3c87fjEBtYNE7Z7f
    大数据开发-从Scala到Akka并发编程大数据开发-从Scala到Akka并发编程[4-1Scala作业.pdf](file/4-1Scala作业_UVqqJLwoIp.pdf)1.递归实现瓶盖,瓶子换酒瓶的算法1.1需求描述每瓶啤酒2元,3个空酒瓶或者5个瓶盖可换1瓶啤酒。100元最多可喝多少瓶啤酒?(不允许借啤酒)思路:利用递归算......
  • 大数据开发-从Scala到Akka并发编程_jDW32G3c87fjEBtYNE7Z7f
    大数据开发-从Scala到Akka并发编程大数据开发-从Scala到Akka并发编程[4-1Scala作业.pdf](file/4-1Scala作业_UVqqJLwoIp.pdf)1.递归实现瓶盖,瓶子换酒瓶的算法1.1需求描述每瓶啤酒2元,3个空酒瓶或者5个瓶盖可换1瓶啤酒。100元最多可喝多少瓶啤酒?(不允许借啤酒)思路:利用递归算......
  • 成品直播源码平台消息传递的协议:MMS协议
    一、成品直播源码平台MMS协议是什么?    MMS协议中文全称为多媒体短信协议,是一种消息传递协议,MMS协议在成品直播源码平台中,MMS协议会利用自身的多媒体消息传输的机制,来实现成品直播源码平台的多媒体内容的高效传输,并呈现给用户。  二、MMS协议在成品直播源码平台的......
  • MFC视频教学第一课,做一个简单的界面,理解应用程序和操作系统之间的消息传递机制
     #include<windows.h>#include<stdio.h>LRESULTCALLBACKWinSunProc(HWNDhwnd,UINTuMsg,WPARAMwParam,LPARAMlParam);//WinMain是操作系统调用的,是系统的入口函数intWINAPIWinMain(HINSTANCEhInstance,//当前应运程序......
  • 深入解析 Kafka 消息传递机制及其在 Spring Boot 中的应用
    Kafka作为一款高性能的分布式消息中间件,被广泛用于构建实时数据流处理和事件驱动的架构。在本篇博客中,我们将深入探讨Kafka的消息传递机制,并结合SpringBoot框架,演示如何在应用中使用Kafka进行消息传递。1.Kafka消息传递机制Kafka使用发布-订阅模型来实现消息传递。核心......
  • Kafka 消息传递机制与 Spring Boot 集成实践
    Kafka作为一款强大的分布式消息中间件,被广泛应用于实时数据流处理和事件驱动的架构。在本篇博客中,我们将深入探讨Kafka的消息传递机制,并结合SpringBoot框架,演示如何在应用中集成和使用Kafka进行消息传递。1.Kafka消息传递机制概述Kafka使用发布-订阅模型来实现高效的消......
  • Kafka 消息传递原理及在 Spring Boot 中的应用实践
    Kafka作为一款强大的分布式消息中间件,在实时数据流处理和事件驱动架构中扮演着重要角色。在本篇博客中,我们将深入探讨Kafka的消息传递原理,并结合SpringBoot框架,演示如何在应用中使用Kafka进行消息传递。1.Kafka消息传递原理Kafka采用发布-订阅模型实现消息传递,核心概念......