Golang事件:插件架构的EventEmitter/dispatcher

Question

在Node.js中,我能够使用EventEmitter轻松地创建一个WordPress克隆,从而将一个钩子系统复制并构建到CMS核心中,然后插件可以连接到该核心.

我现在需要为我的CMS写入并移植到Go的相同级别的可扩展性和核心隔离.基本上我现在已经完成了核心,但是为了使它真正灵活,我必须能够插入事件(钩子)并使插件附加到这些具有附加功能的钩子.

我不关心重新编译(动态/静态链接),只要你不必修改核心来加载插件 - 永远不应该修改CMS核心.(如WP,Drupal等)

我注意到有一些相当未知的项目,试图在Go中实现与Node.js中的EventEmitter类似的事件:

https://github.com/CHH/eventemitter

https://github.com/chuckpreslar/emission

由于上面的这两个项目没有得到太多人气和关注,我觉得这种思考事件的方式现在可能是我们应该如何在Go中做到这一点？这是否意味着Go可能不适合这项任务？通过插件制作真正可扩展的应用程序？

似乎Go没有将事件构建到其核心中,并且RPC似乎不是将插件集成到核心应用程序中的有效解决方案,就像它们本地构建一样,并且好像它们是主应用程序本身的一部分.

无缝插件集成到您的核心应用程序中的最佳方式是什么,无需扩展点(在核心中),而无需在每次需要连接新插件时操作核心？

Answer 1

一般来说,在Go中,如果你需要事件,你可能需要使用通道,但如果你需要插件,那么前进的方法就是接口.这是一个简单的插件体系结构的一个有点长的例子,它最小化了需要在应用程序的主文件中添加插件的代码(这可以是自动的,但不是dnyamic,见下文).

我希望它是你正在寻找的方向.

1.插件接口

好吧,假设我们有两个插件,Fooer和Doer.我们首先定义他们的接口:

// All DoerPlugins can do something when you call that method
type DoerPlugin interface {
    DoSomething() 
}

// All FooerPlugins can Foo() when you want them too
type FooerPlugin interface {
    Foo()
}

2.插件注册表

现在,我们的核心应用程序有一个插件注册表.我在这里做一些快速而肮脏的事情,只是为了得到这个想法:

package plugin_registry

// These are are registered fooers
var Fooers = []FooerPlugin{}

// Thes are our registered doers
var Doers = []DoerPlugin{}

现在我们公开了将插件添加到注册表的方法.简单的方法是每种类型添加一个,但你可以使用更复杂的反射内容并拥有一个功能.但通常在Go中,尽量保持简单:)

package plugin_registry

// Register a FooerPlugin
func  RegisterFooer(f FooerPlugin) {
    Fooers = append(Fooers, f)
}

// Register a DoerPlugin
func RegisterDoer(d DoerPlugin) {
    Doers = append(Doers, d)
}

3.实现和注册插件

现在,假设这是您的插件模块.我们创建了一个doer的插件,在我们的包的 init()方法中我们注册它.init()在为每个导入的包启动的程序上发生一次.

package myplugin 

import (
    "github.com/myframework/plugin_registry"
)
type MyPlugin struct {
    //whatever
}

func (m *MyPlugin)DoSomething() {
    fmt.Println("Doing something!")
}

同样,这里是自动注册包的"init magic"

func init() {
    my := &MyPlugin{}
    plugin_registry.RegisterDoer(my)
}

4.导入插件会自动注册它们

而现在,我们唯一需要改变的是我们导入主包的内容.由于Go没有动态导入或链接,因此这是您需要编写的唯一内容.go generate通过查看文件树或配置文件并找到需要导入的所有插件,创建一个生成主文件的脚本非常简单.它不是动态的,但它可以自动化.因为主要为注册的副作用导入插件,导入使用空白标识符来避免未使用的导入错误.

package main

import (
    "github.com/myframework/plugin_registry"

    _ "github.com/d00dzzzzz/myplugin" //importing this will automaticall register the plugin
)

5.在应用程序的核心

现在我们的核心应用程序不需要任何代码来更改以便能够与插件进行交互:

func main() {


    for _, d := range plugin_registry.Doers {
        d.DoSomething()
    }

    for _, f := range plugin_registry.Fooers {
        f.Foo()
    }

}

这就是它.请记住,插件注册表应该是一个单独的包,应用程序的核心和插件都可以导入,因此您不会进行循环导入.

当然,您可以为此混音添加事件处理程序,但正如我所演示的那样,它不是必需的.