通过事件总线发布发布对象
是一种在分布式系统中实现异步通信的机制。事件总线是一种消息传递系统，它允许不同组件之间通过发布和订阅事件来进行解耦和通信。
发布对象是指将一个对象发布到事件总线上，以便其他组件可以订阅并接收该对象。发布对象可以是任何类型的数据，例如消息、状态更新、通知等。
事件总线的优势包括：
- 解耦性：通过事件总线，组件之间可以松耦合地进行通信，不需要直接依赖或了解彼此的存在。
- 异步通信：发布对象到事件总线上是异步的，发布者不需要等待接收者处理完毕，可以继续执行其他任务。
- 可扩展性：事件总线可以支持多个发布者和订阅者，使系统更具可扩展性。
- 灵活性：通过事件总线，可以轻松地添加、移除或修改组件之间的通信方式，而不会影响其他组件。
发布对象的应用场景包括：
- 分布式系统：在分布式系统中，不同的服务可以通过事件总线发布对象来进行通信，实现解耦和异步处理。
- 微服务架构：在微服务架构中，各个微服务可以通过事件总线发布对象来进行事件驱动的通信，实现松耦合和可扩展性。
- 实时数据处理：通过事件总线发布实时数据对象，可以使订阅者实时获取数据更新，例如实时监控系统、实时报警系统等。
腾讯云提供了一种事件总线服务，称为腾讯云消息队列 CMQ。CMQ 是一种高可用、高可靠、高性能的分布式消息队列服务，可以实现发布-订阅模式的消息通信。您可以通过腾讯云消息队列 CMQ 来实现事件总线的功能。
腾讯云消息队列 CMQ 产品介绍链接地址：https://cloud.tencent.com/product/cmq
相关·内容
1回答
在我的安卓应用程序中，我使用作为事件总线，使用进行依赖注入。
在Otto的用户指南和许多博客文章中，建议使用注入来获得总线单例。我这样做已经有一段时间了，但最近我越来越怀疑注入总线是否比使用简单的静态单例有任何优势。
通过注入，我必须注入所有我希望能够在总线上发布UI事件的自定义视图或ViewHolder。尤其是用匕首，在我需要公共汽车的地方注射每一节课似乎有点笨拙。当然，我可以通过构造函数或setter方法传递总线，但如果您考虑一个具有许多不同视图类型的适配器，也可能会有些笨拙。
我看不出注射巴士有什么好处。在Otto的情况下，注入一个具体的实现(总线的一个实例)，这种情况永远不会改变。如果
浏览 2提问于2015-07-16得票数 7
1回答
Hy，我对android开发非常陌生，我尝试在扩展DialogFragment并包含四个按钮的自定义对话框片段和视图寻呼机的片段之间建立通信。
我的视图寻呼机适配器扩展了FragmentStatePagerAdapter并包含了7个选项卡，但是对于每个选项卡，我创建了相同的片段，其中包含一个recyclerView但列表的不同数据。这个想法是，如果我单击对话框片段中的一个按钮，它将根据按下的按钮来排序我的recyclerViews。
我正在考虑在对话框中使用惰性面，将数据发送到活动中，然后从这里更新片段回收视图。我的解决方案中唯一的问题是，在活动中，我必须通过标记调用片段，而且由于我的片段在视
浏览 2提问于2016-10-29得票数 1
回答已采纳
1回答
我已经看过了，但是它并没有为我想要做的事情提供一个解决方案。
我正在使用EventBus (绿色机器人)通过我的应用程序发送消息。我想要能够单元测试我的应用程序，以确认消息已张贴到公共汽车。就是这样。
下面是我想用一个发布消息的方法来测试的类：
public class CxManager {
public void postMessage(JsonObject data) {
EventBus.getDefault().post(new MyCustomEvent(data));
}
}
下面是我试过但不起作用的测试：
@RunWith(MockitoJUni
浏览 1提问于2018-09-10得票数 0
回答已采纳
2回答
我有一个windows应用程序，它有三种形式: Form1,2,3。
--Form 1，有两个按钮: openform2、openform3。--Form2有一个textbox form2_textbox，按钮form2_button --Form3有一个textbox form3_textbox
现在，单击form1上的openform2按钮，Form2将打开，在Form2的文本框form2_textbox中输入一个字符串，现在单击此表单的form2_button时，我希望Form1接收此字符串值并将其存储在string receivefromform2中，然后将此字符串值显示到form3_
浏览 2提问于2011-02-18得票数 0
回答已采纳
在过去两年中一直使用堆栈溢出，但这是我的第一篇文章。我构建了一个从db (RPC调用)填充的CellTree，其中树的每个级别都是不同的对象(类)。宿主->组->对象->元素。我要做的是在表单上填充一个“详细信息”部分，允许用户编辑单击的节点的详细信息，最终显示类的属性。在我的getNodeInfo部分的TreeViewModel中，我为每个类/对象创建了一个AbstractCell。然后，我向每个单元格添加了一个单击处理程序，以捕获用户单击的值/对象。我能够看到有"System.out.println“行代码的正确值。我被困的地方就是能够把那个物体传回表单。
这是我
浏览 4提问于2014-04-02得票数 0
回答已采纳
我在这里使用Axon & Spring实现了一个相当简单的CQRS设置。
这是配置类。
@AnnotationDriven
@Configuration
public class AxonConfig {
@Bean
public EventStore eventStore() {
...
}
@Bean
public CommandBus commandBus() {
return new SimpleCommandBus();
}
@Bean
public EventBus eve
浏览 0提问于2017-04-20得票数 1
回答已采纳
1回答
奥托和截击方向
、、、
我正在将Volley和Otto集成到一个项目中，以处理所有的服务呼叫，同时考虑改变方向。通过使用Otto，我可以在改变方向时取消注册和重新注册总线，然后当Volley返回响应时，我可以将结果回发到活动中，这是完美的。但是我相信我有一个我还没有处理的空白，那就是，如果我在暂停的时候注销我的巴士，然后在活动仍然被破坏的时候返回来自volley的响应，volley然后发布响应，(但是没有活动会得到它)，然后活动被恢复，总线被重新注册，并且不会收到响应，因为广播已经发布了。
有什么办法解决这个问题吗？我的第一个想法是实现类似Android粘性广播的工作方式？还有其他更好的想法或想法吗？
浏览 1提问于2014-05-03得票数 2
回答已采纳
3回答
我试着使用。我认为到目前为止，这是可行的，但我收到了两次事件。
这就是我所拥有的(我跟踪了)：
制片人：
public class NetworkChangeReceiver extends BroadcastReceiver
{
@Override
public void onReceive(final Context context, final Intent intent)
{
Log.i("ralphs", "onReceive");
// .... more stuff
fin
浏览 1提问于2014-12-23得票数 1
回答已采纳
1回答
我在我的MAINACTIVITY.java中使用了MAINACTIVITY.java。当它打开时，从另一个类GPSLOCATION.java获取当前位置并更新到服务器。
<ToggleButton
android:id="@+id/switch1"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:gravity="center
浏览 3提问于2015-03-19得票数 0
1回答
对于像Otto和EventBus这样的库，我想知道使用是否仍然有意义
Handler允许您发送和处理与线程的MessageQueue相关联的消息和可运行对象。每个Handler实例都与单个线程和该线程的消息队列相关联。
除了事件总线库之外，如何使用处理程序？我发现使用普通线程并直接在事件总线上发送消息就足够了，还是这里遗漏了什么？
浏览 10提问于2014-05-19得票数 2
回答已采纳
在您的应用程序中使用全局事件总线是不是一个糟糕的设计？
如何确保您不会在整个应用程序中使用一组紧密耦合的组件相互通信？
你能想到Java世界中的一种机制/工具/库来对它进行一些约束吗？
浏览 0提问于2012-07-24得票数 3
回答已采纳
我已经使用了otto event bus作为这里的解释。它工作得很好。
今天我意识到，如果我创建事件并在两个地方订阅它，这两个都会被调用。
为了更清楚地说明这一点：
我有jar，它使用事件总线进行内部通信。当我在我的应用程序中使用这个jar时，我可以在事件总线上注册并捕获事件。
如何避免这种情况？
浏览 6提问于2014-07-25得票数 2
1回答
将值从服务传递到许多活动
、、、
我需要将值从服务传递到许多活动，其中有些活动甚至还没有初始化，但我希望这些活动在初始化时得到值。我知道广播可能是一种有用的方式，但它相对缓慢。有没有办法达到这个目标呢？谢谢!
浏览 3提问于2016-09-12得票数 0
回答已采纳
我想知道我是不是无意中使用了设计模式？请帮帮我。
我有一个应用程序，它将生成事件(event1，事件2，...事件n)。
我还有另一个库(Event Hanlder Library)，其中编写了事件处理方法。
我使用一个接口(通信器)，它的方法是由事件处理程序库实现的"GenerateEvent“。
最后，生成事件的主应用程序...使用反射来加载事件处理程序库，并在运行时根据event no，挂钩( event handler的)特定于事件的类。主应用程序使用接口方法GenerateEvent发送事件
这是一种设计模式，因为在两个程序集之间使用接口来共同工作吗？我可以在伪代码方面提供更
浏览 0提问于2012-08-01得票数 1
我是Android的新手，我有一个设计问题。所以我知道建议使用片段。我也明白一个活动“拥有”一个片段。
因此，我的问题如下：
假设我们想要对服务器进行长时间运行的后台调用，例如HTTP。
结果应该显示在UI中。
那么，最佳/标准实践是什么呢？
1)执行长时间运行的调用的对象是否应该由活动“拥有”，并且结果应该返回到活动，然后从活动发送到片段，以便更新UI？
( 2)还是应该将执行长时间运行的对象称为“属于”片段，并将结果发送回片段，以便更新UI？所以这个活动完全没有意识到这一点？
浏览 7提问于2015-03-06得票数 0
回答已采纳
我目前正在使用Django开发一个网页。本网站旨在显示不同模拟的结果。我不能直接在Django后端使用一些模拟代码。但是代码所有者允许我使用他们自己的服务器进行黑匣子模拟。因此，我们的想法是首先向服务器发送一些带有数据的请求。用户先前输入了数据，并保存在django数据库中。然后，服务器接收数据并使用该数据进行模拟( python脚本)。模拟完成后，数据将被发送回我的django后端，因此，我的django后端会收到某种响应。我在这个话题上做了很多研究，但是找不到我能用的东西。我看到了类似python、socket.io、websockets、django rest框架和django通道之类的
浏览 4提问于2022-03-31得票数 0
我试图弄清楚Bluez的DBus API，并且我很难理解其中的一些概念。
我所见过的最彻底的Bluez示例都使用了Python的dbus-python库。例如，演示了如何创建BLE广告。很多内容都在Advertisement类中，它扩展了dbus.service.Object。Advertisement类实现了一个GetAll方法(来自org.freedesktop.DBus.Properties接口)和一个Release方法(来自org.bluez.LEAdvertisement1接口)。为了注册该广告，它从RegisterAdvertisement接口调用org.bluez.LEAdver
浏览 2提问于2021-08-04得票数 0
我正在尝试将我的nestjs应用程序的cqrs设置与诸如Redis这样的外部消息服务集成起来。我在 github上找到了一个和一个nestJS github，说明我应该能够将查询/事件/命令总线与外部服务集成在一起，因为cqrs的版本为7.0。
我一直在尝试实现这一点，但是我在nestjs中找不到关于这个问题的很多信息。我唯一能找到的是github上的和，用于创建关于如何实现这个问题的教程。我在github上找到了关于这个主题的有限帮助，从而成功地替换了默认发行者和订阅者，但我不太明白如何使用它连接到外部服务，或者这是否是解决这个问题的最佳方法。
EventBus
import { Redis
浏览 1提问于2020-11-10得票数 3
回答已采纳
在我的应用程序中，在创建任务时，我需要对Google进行API调用，以创建google日历事件。
我决定在一个单独的线程上调用API，这样我们的客户端就不必等待更长时间的响应。
@Override
@Transactional( rollbackFor = DataException.class )
public TaskResponseBean createTask( TaskCreationBean taskCreationBean, UserAccessDetails accessDetails )
throws DataException
{
String go
浏览 0提问于2019-06-28得票数 8
1回答
我熟悉这里定义的Akka测试方法：
我理解如何使用TestKit、TestActorRef、TestProbe等，我也知道我的核心域逻辑应该从Akka中分离出来并进行测试。
我的问题是关于在Akka持久性角色上执行TDD的策略，即PersistentActor和PersistentView。
我希望能够以合理的低开销、高效的方式测试以下类型的场景，即尽可能接近单元测试：
持久化参与者是否持久化了一个具有正确id的事件？
快照恢复是否正确？
我的观点是正确的事件吗？
如果有人知道一个项目，可以帮助我看到这方面的行动，我将不胜感激。
我能想到的一种方法是有一个测试Persis
浏览 3提问于2015-06-16得票数 1
回答已采纳
1回答
我有APIHelper类，其静态方法异步向服务器发出请求、接收json字符串、解析和返回对象或ArrayList：
...
public static ArrayList<Item> getItemsInCategory(int id_category) throws ExecutionException, InterruptedException, JSONException {
DoRequest doRequest = new DoRequest();
String jsonString = doRequest.execute(API_
浏览 5提问于2014-07-12得票数 2
回答已采纳
我一直在尝试使用Angular，并一直试图找到一种在整个组件树中使用发布/订阅机制的方法。
看起来EventEmitter只会发出一个可以订阅更高级别的事件--但不能更多。类似地，它只在树上发出事件，但现在向下发出事件。
相关代码如下：
class App {
onAncestor($event) {
console.log('in ancestor, decendent clicked',$event);
}
}
...
class Entities {
....
onParent($event) {
console.log(
浏览 2提问于2015-09-22得票数 8
在实现域事件时，事件处理程序是否应该仅用于纯粹的域问题；您将与业务专家讨论的内容，或者对域模型感兴趣的任何事物都可以使用它们？
这可能最好用一个简单的例子来解释，考虑一个用于为员工安排工作的Calendar应用程序。
我们可能有以下域事件...
AppointmentAdded AppointmentRemoved AppointmentContentChanged AppointmentMoved
我们为这些事件设置了处理程序，例如，当约会被移至员工工作时间之外的时间时，我们将设置警告标志。
当然，也有一些应用程序对这些事件感兴趣，例如，当将约会添加到日历中时，我们应该将其添加到工作单元中，
浏览 3提问于2011-01-08得票数 8
回答已采纳
4回答
编辑:请不要建议界面。
我有一个活动，里面有一个RecyclerView。我希望通过otto发布一个从Adapter到Activity的事件，然后创建Adapter。我使用了以下代码：
ShoppingCardAdapter
public class ShoppingCardAdapter extends RecyclerView.Adapter<ShoppingCardAdapter.ViewHolder> {
private Activity activity;
private CardBook cardbook;
public class ViewHolder exte
浏览 6提问于2015-01-13得票数 3
我有一个活动，它托管多个片段，为用户定义注册流中的每个步骤。流程很复杂，下一个步骤是由前面步骤中的用户操作定义的。
流动情况如下：
MainActivity | Fragment1 --> Fragment2 --> Fragment3 --> Fragment4
\
--> Fragment5 --> Fragment6
在MVP之后，我有每个片段的视图和演示器。我关心的是如何以MVP的方式在片段和活动之间
浏览 6提问于2017-01-11得票数 7
回答已采纳
影响广播接收器内部组件的选项有哪些？
当用户点击一个按钮时，我会生成一个进程，并等待广播接收器捕获结果。一旦发生这种情况，我希望按钮更改其标题。除了定义一个全局变量来保存按钮组件并在广播接收器中使用它之外，我还能做什么呢？我想知道是否有更干净/更聪明的方法来做这件事。
浏览 1提问于2015-03-13得票数 0
1回答
我试着遵循代码来查看/捕获死信，但它不能以它应该工作的方式工作。What I am missing.exactly？我的目标只是查看所有正在传递给deadletters actor的死信。
let system = ActorSystem.Create("FSharp")
let echoServer =
spawn system "EchoServer"
<| fun mailbox ->
let rec loop() =
actor {
let! message = mailbox.Receiv
浏览 1提问于2016-05-25得票数 0
1回答
通过直接将事件从客户端推送到服务器端的利弊是什么？换句话说，在客户端应用程序和服务器参与者之间共享事件总线有什么好处？
如您所知，是一个事件循环，它促使您使用类似于smth的演员模型。不同的演员(眩晕)可以在的帮助下相互交流。
共同方法
AFAIK，常用的安排客户端-服务器通信的方法是使用下一个方案：
公开将接受客户端请求的web服务(路由器)
Web服务将事件发送到垂直/参与者。
垂直/参与者进行计算并返回结果
Web服务获取计算结果并将其发送回客户端
Vert.x事件总线桥方法
让我困惑的是，客户端Javascript可以在服务器端与每个参与者/顶点直接通信：
浏览 2提问于2016-04-21得票数 2
回答已采纳
我非常有经验的团结和iOS，我可以部署我的团结应用程序的安卓。但我对本土的Android产品一无所知。
我的问题是接收到GCM消息，并在android应用程序的背景下显示通知。我实现了它，当应用程序处于前台时，它工作得很好，但是当应用程序处于后台时，我的GCM消息侦听器不会被触发，我无法显示通知。
我使用这个插件来接收GCM消息：我用它来显示通知：
我试图联系这些插件的作者，但他们很长时间没有回复.
浏览 3提问于2014-07-24得票数 3
回答已采纳
Google的pub/sub服务为消息的订阅者提供了一个端点，以显式地确认消息的成功传递。如果未使用此端点，则subscriber必须在超时之前返回200响应，否则发布/订阅会认为消息传递不成功，并将在超时后重试发送消息。因此，对于长时间运行的订阅者进程，可以在运行主进程之前先发送确认，而不是等到进程完成。
我没有在Azure Event Grid中找到类似的机制，所以如果事件处理程序花费了很长时间(根据，超时只有30秒)，那么在过程的中间，event grid会重试向同一个订阅者发送更多的事件：
“事件网格在传递消息后等待30秒的响应。30秒后，如果终结点没有响应，消息将排队等待重试。事件网
浏览 1提问于2020-06-25得票数 1
我希望看到Micronaut中对类似于番石榴或Spring中的EventBus力学的支持。
这将是一个带有给定注释的bean方法，即(@Subscribe)将自动注册为侦听器，用于通过Micronaut容器提供的EventBus实现触发的事件。
另外，如果这将被异步处理，或者使用相当于一个弹性I/O执行器服务的方法，那将是很酷的。
谢谢你，奥斯卡
浏览 0提问于2018-09-22得票数 1
回答已采纳
1回答
我正在从事一个项目，其中有几个模块。我有一个模块，这是在基础上，这是所有模块的共同。我在基本模块中有一个业务对象(这是一个单例类)，它可以触发一个事件，表明已经做了一些事情。
我希望每个模块都能够监听这个事件，并做一些特定的事情。
做这件事最好的方法是什么？
公共模块是在应用程序启动时执行的第一个代码，因为这是基础，所以它不能调用它上面的模块。
编辑:考虑到我的场景，我认为这个问题有点不完整。下面是一个解释。
我有一个单例类(我将其设置为不可变的)。这个类存在于基本模块中。它有一个静态方法getInstance()，该方法将根据表中存储的数据初始化一个新对象。有一个后台调度程序，它会定期用来自
浏览 1提问于2014-04-12得票数 0
2回答
我脑子里想不出来的是：
CQRS模型告诉我，写和读模型是相互独立的。
聚合只写入事件表，并发布事件通知投影机。
投影仪只使用这些事件并更新读取的表。
设想情况：
在系统中引入了一个新的读取模型，或者需要重建一个现有的模型。
如何做到这一点，如果聚合/投影机的责任是分开的？
投影仪应该读取事件表吗？这要求它“了解”这个表/db，而且它并不总是可行的。
放映机是否应该“要求”集合重放(重播)这些事件？这意味着聚合需要实现某种“重放”方法，这也将投影机和聚合耦合在一起。这也意味着其他投影机将接收这些事件，尽管是幂等的，但这似乎是消息总线上不必要的负载。
那么，实现重放的正确方法是什么
浏览 7提问于2022-08-18得票数 0
我有一个关于事件总线设计模式与机器人活动/片段/服务相结合的具体问题。
到目前为止，我理解的是:当使用我创建的事件总线时，让我们为整个应用程序创建一个单一的事件总线(单例设计模式)。现在，我可以让单个活动/片段/服务在事件总线上发布一个事件，而事件总线将消息传播到订阅此特定事件的所有其他活动/片段/服务。这样，所有其他活动/片段/服务都可以对此特定事件作出反应。为了使所有活动/片段/服务能够使用事件总线，它们必须在总线中注册(最好在其onCreate*()-methods中注册)，如果它们即将被停止/取消/销毁，则应该取消注册。
这就引出了我的问题:假设我想实现一个全新的actionbar (
浏览 0提问于2014-08-26得票数 0
回答已采纳
2回答
我有一个简单的用例：
Activity1创建一个fragment1
创建后的fragment1通知活动它已经创建，并更新其activity1视图。
获得通知后的activity1更新fragment1视图。
我使用的是rxandroid、子库rxlifecycle组件和android，但我还在学习阶段，甚至在堆栈溢出上没有rx-lifecycle标记，所以我仍然很难理解这个库的流程。
编辑
我不喜欢使用EventBus，就像每个人对每个人大喊大叫要做些什么一样，所以Rxjava可观察的方法将非常有用
浏览 1提问于2016-11-16得票数 17
回答已采纳
我想知道什么是更好的实践-类应该侦听全局事件，还是应该由管理器侦听事件，然后在这些类上调用公共方法？
例如：
import App
public class DualLanguageText
{
public function DualLanguageText():void
{
App.Model.addEventListener(AppEvent.CHANGE_LANGUAGE, onChangeLanguage)
}
}
...or
import App
public class ViewManager
{
public function v
浏览 0提问于2011-11-21得票数 1
发布者-订阅者模式，其中subsriber调用服务。
服务器作为发布者，将10个代理注册为订阅者。我已经使用发布者-订阅者模式成功地实现了这一点。在我的例子中，一个代理调用服务器上的服务，服务器通知它所有注册的代理。
有没有什么简单的方法可以在我现有的发布者-订阅者模式中包含这种由代理进行的服务调用？
浏览 2提问于2012-01-30得票数 1
回答已采纳
我很困惑为什么事件总线在这里需要线程本地？
/** queues of events for the current thread to dispatch */
private final ThreadLocal<Queue<EventWithHandler>> eventsToDispatch =
new ThreadLocal<Queue<EventWithHandler>>() {
@Override protected Queue<EventWithHandler> initialValue() {
浏览 3提问于2013-11-28得票数 0
回答已采纳
1回答
我正在开发一个将在多台计算机上执行的Java应用程序。我使用观察者模式来使更改可见，并使用Hibernate来持久化实体。如果我创建了几个观察者的实例(通过单击一个按钮)，观察者模式就可以很好地工作，并且更改会反映在每个窗口中。但是，如果我通过执行.jar文件创建了几个观察者实例，观察者模式就不起作用了。我认为这类似于在不同的计算机上执行应用程序。
我想知道如何使更改在远程计算机上可见。
这是我的Server类
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Observable;
public
浏览 0提问于2014-11-18得票数 0
我担心的是，为每个独特的事件创建自己的类不会被认为是不好的做法吗？感觉这种方法并不复杂，如果我有几十个事件，就更不复杂了。虽然这是一个简单的解决方案(每个事件类型都有唯一的字段)，但它附带了许多几乎为空的类。
我宁愿有一个泛化的类和一个@Subscribe-d方法，在这个方法中我可以检查发送的消息的类型(使用枚举)，然后执行相应的操作，但是这种方法需要我创建一个映射，并将数据放在其中，然后在每次我想发布什么东西时传递这个映射，这似乎也不是最好的方法。
你认为如何？
浏览 3提问于2014-10-04得票数 0
2回答
订阅Azure队列
、、、、
我有一个Azure网站，可以生成报告。这些报告需要45秒的时间才能生成，我想迁移到一个工人角色来减少网站上的负载。
我一直在研究使用哪种工具使网站能够将“报告生成请求”传递给工作人员角色。看起来就像要走的路，但是根据我在、和Stackoverflow (，)中看到的，Azure队列只支持轮询。
然而，Azure正在迅速变化，这一信息有点陈旧。队列是否仍然只支持轮询？
如果是这样的话，我会更好地使用Azure服务总线来传递消息，因为它支持发布/订阅模型吗？我对使用服务总线有些犹豫，因为我不需要任何特定于上的服务总线的特性。
浏览 1提问于2014-12-01得票数 2
回答已采纳
在CRC卡中，为什么我们列出了所有的合作者，而不仅仅是依赖项。我的意思是，如果A类调用B的函数，为什么在B类CRC协作者部分提到A。如果我们简单地将A留在B的CRC卡中会更好，因为在A的CRC卡中已经提到了B。这样我们也可以从CRC卡中找出依赖关系，如果你知道A需要的B类的函数名，我们也可以在A的CRC卡中提到它。这将通过快速生成类和序列图来提供更多帮助。通过在A协作者中提及B和在B协作者中提及A，可以实现哪些具体功能？
浏览 2提问于2009-11-11得票数 1
回答已采纳
因此，我知道这与MassTransit风格有一点不同，但我想利用MT的一些关键特性，如messages连接管理、sagas、预定消息。
然而，我知道这项服务将很少被使用。这是一个来自API的相当大的数据，其节流速度为每小时12,000次请求。每24小时一次，传奇就会开始收集数据，并将其移到数据湖。该服务将运行几分钟，直到油门被击中，然后重新启动，当足够的时间过去时，它停止(状态)，也许大约30分钟后。数据量意味着这将重复几个小时(2到4)。
适合一个传奇和和预定的信息似乎相当好。但是，如果该服务没有因为24小时24小时保持清醒而产生运营成本，那就更好了。一次只会有一次对一组API凭证的请求。总
浏览 1提问于2021-05-26得票数 0
回答已采纳
1回答
我正在开发一个小的cqrs实现，我对它非常陌生。我希望将每个处理程序(命令和事件)从聚合中分离出来，并确保所有处理程序都工作正常。命令处理程序是从控制器触发的，但事件处理程序不会从那里触发。有没有人能帮帮忙。
public class User extends AbstractAnnotatedAggregateRoot<String> {
/**
*
*/
private static final long serialVersionUID = 1L;
@AggregateIdentifier
private String userId;
private String
浏览 0提问于2016-10-17得票数 2
我有一个带有SQLite数据库的安卓应用程序，我想知道如何创建和注册一个ContentObserver，它将被告知数据库的更改。我知道我可以使用ContentProvider来完成这个任务，但是我只为我的应用程序使用数据库，所以没有必要把它变成ContentProvider，我想知道是否有办法避免这种情况。
谢谢!
浏览 3提问于2014-01-11得票数 2
1回答
有一种情况是，我有单独的CommandBus和EventBus，我有一个使用者侦听命令总线中的命令，并且在处理操作之后，它会将相关事件发布到事件总线。我希望在EventBus上内置支持事务性发件箱模式。
以下是应用程序的配置：
public static void ConfigureServices(HostBuilderContext host, IServiceCollection services)
{
services.Configure<MessageBrokerConfiguration>(host.Configuration.GetSect
浏览 12提问于2022-12-03得票数 0
回答已采纳
在我第一次尝试系统集成时，我确定了以下有限的上下文：
开发票
订阅
集合
特别针对集合范围内的上下文“挂起过期帐户”功能，我们将：
从Invoicing获得过期发票清单
向用户发送暂停通知(内部电子邮件服务)
请求将暂停发送到订阅有界上下文
我理解如何使用阻塞web服务来集成有限的上下文，但我可以看到，如果远程服务关闭，这将带来问题。
我知道消息总线，但不确定我们将如何与消息策略集成：
每个上下文是否包含外部有界上下文的本地读取模型(当外部有界上下文添加/删除实体并通过唯一ID进行关联时，侦听来自外部有界上下文的事件)？
如果使用消息，我们是否真的从感兴
浏览 1提问于2013-04-17得票数 1
回答已采纳
我有带BaseActivity ()方法和取消寄存器()方法：
public class BaseActivity extends AppCompatActivity{
...
@Override
protected void onResume() {
super.onResume();
// Register ourselves so that we can provide the initial value.
BusProvider.getInstance().register(this);
}
浏览 4提问于2015-10-29得票数 0
回答已采纳
5回答
我正在用Java设计一个独立的多线程应用程序。我正在尝试为他的项目选择最好的事件处理解决方案。
我有1-3个线程生成事件(例如，通信线程完成文件上传)，而其他线程可能希望注册此事件的通知。我希望事件生成和事件侦听尽可能分离。
你有什么建议？
浏览 3提问于2011-04-26得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
