- 关于 ChatGPT 必看的 10 篇论文
- ChatGPT常见问答
- ChatGPT对接微信
- OpenAI 推出超神 ChatGPT 注册教程来了|Gmail 外国手机短信验证码接码
在基于 Message 的系统中,每一个 Event 也可以被称为 Message,Message 是对 Event 更高一个层级的抽象,每一个 Message 都有一个特定的 Type 用于与对应的 Handler 做关联。它是一种数据。
Change 用于接收来自 Event Loop 分配的消息,每一个 Channel 负责处理一种类型的消息。它是对数据的处理。
它的作用类似于 Event Loop,其主要是帮助 Event 找到合适的 Channel 并且传送给它,它是连接 Event 和 Channel 之间的桥梁。
Event 是对 Message 的一个最简单的实现,在后续使用过程中,将 Event 直接作为其他 Message 的基类使用。
EventDispatcher 是对 DynamicRouter 一个最基本的实现,适合在单线程的情况下进行使用,因此不需要考虑线程安全问题。
连接上述各组件,完成测试。
package synceda;
public interface Message {
// 返回 Message 的类型
Class<? extends Message> getType();
}
package synceda;
public interface Channel<E extends Message> {
// 用于负责 Message 的调度
void dispatch(E message);
}
package synceda;
public interface DynamicRouter<E extends Message> {
// 针对每一种 Message 类型注册相关的 Channel,只有找到合适的 Channel 该 Message 才会被处理
void registerChannel(Class<? extends E> messageType, Channel<? extends E> channel);
// 为相应的 Channel 分配 Message
void dispatch(E message);
}
package synceda;
public class Event implements Message {
@Override
public Class<? extends Message> getType() {
return getClass();
}
}
package synceda;
import java.util.HashMap;
import java.util.Map;
/**
* @className: EventDispatcher
* @description: 该类不是一个线程安全的类
* @date: 2022/5/18
* @author: cakin
*/
public class EventDispatcher implements DynamicRouter<Message>{
// 用于保存 Channel 和 Message 的关系
private final Map<Class<? extends Message>,Channel> routerTable;
public EventDispatcher() {
this.routerTable = new HashMap<>();
}
@Override
public void registerChannel(Class<? extends Message> messageType, Channel<? extends Message> channel) {
this.routerTable.put(messageType,channel);
}
@Override
public void dispatch(Message message) {
if(routerTable.containsKey(message.getType())){
// 直接获取对应的 Channel 处理 Message
routerTable.get(message.getType()).dispatch(message);
} else {
throw new MessageMatcherException("can not match thw channel for ["+message.getType()+"] type");
}
}
}
package synceda;
public class MessageMatcherException extends RuntimeException {
public MessageMatcherException(String message) {
super(message);
}
}
package synceda;
public class EventDispatcherExample {
// InputEvent 中定义了两个属性 X 和 Y,主要用于其他 Channel 中的元素
static class InputEvent extends Event {
private final int x;
private final int y;
public InputEvent(int x, int y) {
this.x = x;
this.y = y;
}
public int getX() {
return x;
}
public int getY() {
return y;
}
}
// 用于存放结果的 Event
static class ResultEvent extends Event {
private final int result;
public ResultEvent(int result) {
this.result = result;
}
public int getResult() {
return result;
}
}
// 处理 ResultEvent 的 Handler(Channel),只是简单地将计算结果输出到控制台
static class ResultEventHandler implements Channel<ResultEvent> {
@Override
public void dispatch(ResultEvent message) {
System.out.println("The result is:" + message.getResult());
}
}
// InputEventHandler 需要向 Router 发送 Event,因此在构造的时候需要传入 Dispatcher
static class InputEventHandler implements Channel<InputEvent> {
private final EventDispatcher dispatcher;
public InputEventHandler(EventDispatcher dispatcher) {
this.dispatcher = dispatcher;
}
// 将计算的结果构造成新的 Event 提交给 Router
@Override
public void dispatch(InputEvent message) {
System.out.printf("X:%d,Y:%d\n", message.getX(), message.getY());
int result = message.getX() + message.getY();
dispatcher.dispatch(new ResultEvent(result));
}
public static void main(String[] args) {
EventDispatcher dispatcher = new EventDispatcher();
// 将 Event 和 Handler(Channel)的绑定关系注册到 DisPatcher
dispatcher.registerChannel(InputEvent.class, new InputEventHandler(dispatcher));
dispatcher.registerChannel(ResultEvent.class, new ResultEventHandler());
dispatcher.dispatch(new InputEvent(1, 2));
}
}
}
X:1,Y:2
The result is:3
我需要开发一个简单的网站,我通常使用 bootstrap CSS 框架,但是我想使用 Gumbyn,它允许我使用 16 列而不是 12 列。 我想知道是否: 我可以轻松地改变绿色吗? 如何使用固定布局
这个问题在这里已经有了答案: 关闭 13 年前。 与直接编写 PHP 代码相比,使用 PHP 框架有哪些优点/缺点?
我开发了一个 Spring/JPA 应用程序:服务、存储库和域层即将完成。 唯一缺少的层是网络层。我正在考虑将 Playframework 2.0 用于 Web 层,但我不确定是否可以在我的 Play
我现有的 struts Web 应用程序具有单点登录功能。然后我将使用 spring 框架创建一个不同的 Web 应用程序。然后想要使用从 struts 应用程序登录的用户来链接新的 spring 应
我首先使用Spark框架和ORMLite处理网页上表单提交的数据,在提交中文字符时看到了unicode问题。我首先想到问题可能是由于ORMLite,因为我的MySQL数据库的字符集已设置为使用utf8
我有一个使用 .Net 4.5 功能的模块,我们的应用程序也适用于 XP 用户。所以我正在考虑将这个 .net 4.5 依赖模块移动到单独的项目中。我怎样才能有一个解决方案,其中有两个项目针对不同的版
我知道这是一个非常笼统的问题,但我想我并不是真的在寻找明确的答案。作为 PHP 框架的新手,我很难理解它。 Javascript 框架,尤其是带有 UI 扩展的框架,似乎通过将 JS 代码与设计分开来
我需要收集一些关于现有 ORM 解决方案的信息。 请随意编写任何编程语言。 你能谈谈你用过的最好的 ORM 框架吗?为什么它比其他的更好? 最佳答案 我使用了 NHibernate 和 Entity
除了 Apple 的 SDK 之外,还有什么强大的 iPhone 框架可供开始开发?有没有可以加快开发时间的方法? 最佳答案 此类框架最大的是Three20 。 Facebook 和许多其他公司都使用
有人可以启发我使用 NodeJS 的 Web 框架吗?我最近开始从免费代码营学习express js,虽然一切进展顺利,但我对express到底是什么感到困惑。是全栈框架吗?纯粹是为了后端吗?我发现您
您可以推荐哪种 Ajax 框架/工具包来构建使用 struts 的 Web 应用程序的 GUI? 最佳答案 我会说你的 AJAX/javascript 库选择应该较少取决于你的后端是如何实现的,而更多
我有生成以下错误的 python 代码: objc[36554]: Class TKApplication is implemented in both /Library/Frameworks/Tk.
首先,很抱歉,如果我问的问题很明显,因为我没有编程背景,那我去吧: 我想运行一系列测试场景并在背景部分声明了几个变量(我打印它们以仔细检查它们是否已正确声明),第一个是整数,另外两个字符串为你可以看到
在我们承担的一个项目中,我们正在寻找一个视频捕获和录制库。我们的基础工作(基于 google 搜索)表明 vlc (libvlc)、ffmpeg (libavcodec) 和 gstreamer 是三
我试过没有运气的情况下寻找某种功能来杀死/中断Play中的正常工作!框架。 我想念什么吗?还是玩了!实际没有添加此功能? 最佳答案 Java stop类中没有像Thread方法那样的东西,由于种种原因
我们希望在我们的系统中保留所有重大事件的记录。例如,在数据库可能存储当前用户状态的地方,事件日志应记录对该状态的所有更改以及更改发生的时间。 事件记录工具应该尽可能接近于事件引发器的零开销,应该容纳结
那里有 ActionScript 2.0/3.0 的测试框架列表吗? 最佳答案 2010-05-18 更新 由于这篇文章有点旧,而且我刚刚收到了赞成票,因此可能值得提供一些更新的信息,这样人们就不会追
我有一个巨大的 numpy 数组列表(一维),它们是不同事件的时间序列。每个点都有一个标签,我想根据其标签对 numpy 数组进行窗口化。我的标签是 0、1 和 2。每个窗口都有一个固定的大小 M。
我是 Play 的新手!并编写了我的第一个应用程序。这个应用程序有一组它依赖的 URL,从 XML 响应中提取数据并返回有效的 URL。 此应用程序需要在不同的环境(Dev、Staging 和 Pro
关闭。这个问题不满足Stack Overflow guidelines .它目前不接受答案。 想改善这个问题吗?更新问题,使其成为 on-topic对于堆栈溢出。 4年前关闭。 Improve thi
我是一名优秀的程序员,十分优秀!