例如:
在一个DBServer服务进程的应用场景 DBServer Fiber 初始化时,创建了另外8个用来处理数据的Processor Fiber。
这些Processor Fiber各自维护了一个处理队列,使用while(true)来处理数据。
在该DBServer服务进程收到外部的Query,Save等网络消息后,在各自的MessageHandler里将这些消息转变成数据库请求投递给Processor fiber中。
该如何在DBServer服务进程内的 DBServer Fiber 和 Processor Fiber之间方便的进行数据交互?
我尝试定义了一组 Fiber 之间通信的消息,类似 Actor2NetClient_* 这种的方式:具体的就是使用Fiber.MessageInnerSender使用ActorId将消息发送目标fiber。
但总感觉不太对劲。毕竟不是跨进程的,需要定义这些交互消息吗?
另外,请教下各位老大,目前的框架中有进程内的Fiber通信的例子吗?