🔥 🔥 🔥 新鲜出炉！ go 版本的 pipeline 发布啦，你还在愁 go 没有好用的中间件吗？
qbhy · qbhy · 2022-01-29 10:38:55 +08:00 · 3750 次点击这是一个创建于 1031 天前的主题，其中的信息可能已经有所发展或是发生改变。
Goal-web/pipeline
goal-web/pipeline
这是一个管道库，实现了 和 laravel 一样的管道功能，如果你很熟悉 laravel 的管道或者中间件，那你一定对这个库很有亲切感。
安装 - install
go get github.com/goal-web/pipeline
使用 - usage
得益于 goal 强大的容器，你可以在管道(pipe)和目的地(destination)任意注入容器中存在的实例
对管道不熟悉的同学，可以把 pipe 理解为中间件，destination 就是控制器方法
package tests
import (
"fmt"
"github.com/goal-web/container"
"github.com/goal-web/contracts"
"github.com/goal-web/pipeline"
"github.com/pkg/errors"
"testing"
)
type User struct {
Id int
Name string
}
func TestPipeline(t *testing.T) {
pipe := pipeline.New(container.New())
pipe.Send(User{Id: 1, Name: "goal"}).
Through(
func(user User, next pipeline.Pipe) interface{} {
fmt.Println("中间件 1-start")
result := next(user)
fmt.Println("中间件 1-end")
return result
},
func(user User, next pipeline.Pipe) interface{} {
fmt.Println("中间件 2-start")
result := next(user)
fmt.Println("中间件 2-end")
return result
},
).
Then(func(user User) {
fmt.Println("then", user)
})
}
// TestPipelineException 测试异常情况
func TestPipelineException(t *testing.T) {
defer func() {
recover()
}()
pipe := pipeline.New(container.New())
pipe.Send(User{Id: 1, Name: "goal"}).
Through(
func(user User, next pipeline.Pipe) interface{} {
fmt.Println("中间件 1-start")
result := next(user)
fmt.Println("中间件 1-end", result)
return result
},
func(user User, next pipeline.Pipe) interface{} {
fmt.Println("中间件 2-start")
result := next(user)
fmt.Println("中间件 2-end", result)
return result
},
).
Then(func(user User) {
panic(errors.New("报个错"))
})
}
// TestStaticPipeline 测试调用 magical 函数
func TestStaticPipeline(t *testing.T) {
// 应用启动时就准备好的中间件和控制器函数，在大量并发时用 StaticPipeline 可以提高性能
middlewares := []contracts.MagicalFunc{
container.NewMagicalFunc(func(user User, next pipeline.Pipe) interface{} {
fmt.Println("中间件 1-start")
result := next(user)
fmt.Println("中间件 1-end", result)
return result
}),
container.NewMagicalFunc(func(user User, next pipeline.Pipe) interface{} {
fmt.Println("中间件 2-start")
result := next(user)
fmt.Println("中间件 2-end", result)
return result
}),
}
controller := container.NewMagicalFunc(func(user User) int {
fmt.Println("then", user)
return user.Id
})
pipe := pipeline.Static(container.New())
result := pipe.SendStatic(User{Id: 1, Name: "goal"}).
ThroughStatic(middlewares...).
ThenStatic(controller)
fmt.Println("穿梭结果", result)
/**
中间件 1-start
中间件 2-start
then {1 goal}
中间件 2-end [1]
中间件 1-end [1]
穿梭结果 [1]
*/
}
在 goal 之外的框架使用 - use in frameworks other than goal
这个库并不会限制你在哪个框架使用它，所以你可以在任意 go 环境使用这个管道库
第 1 条附言 · 2022-01-30 00:13:07 +08:00
// TestPurePipeline 测试纯净的 pipeline
func TestPurePipeline(t *testing.T) {
// 如果你的应用场景对性能要求极高，不希望反射影响你，那么你可以试试下面这个纯净的管道
pipe := pipeline.Pure()
result := pipe.SendPure(User{Id: 1, Name: "goal"}).
ThroughPure(
func(user interface{}, next pipeline.Pipe) interface{} {
fmt.Println("中间件1-start")
result := next(user)
fmt.Println("中间件1-end", result)
return result
},
func(user interface{}, next pipeline.Pipe) interface{} {
fmt.Println("中间件2-start")
result := next(user)
fmt.Println("中间件2-end", result)
return result
},
).
ThenPure(func(user interface{}) interface{} {
fmt.Println("then", user)
return user.(User).Id
})
fmt.Println("穿梭结果", result)
/**
中间件1-start
中间件2-start
then {1 goal}
中间件2-end 1
中间件1-end 1
穿梭结果 1
*/
}
 |
1
qbhy OP 其实也不是那么新鲜了，因为是昨天晚上写好的了，早上起来才发的 V2
|
 |
2
bthulu 2022-01-29 11:20:42 +08:00
中间件是不是就类似 java 里的过滤器, 为什么要叫中间件这个名字呢, 感觉好诡异
|
 |
6
xz410236056 2022-01-29 14:58:30 +08:00
@bthulu #2 过滤器是 Filter ， 中间件可以 Filter 可以 map ，还可以干别的，你觉得叫什么合适呢
|
 |
7
zoharSoul 2022-01-29 14:58:33 +08:00
理解为中间件是什么意思?
中间件不是指比如 rpc, mq, 配置中心, apm, 链路追踪之类的周边设施吗? |
 |
8
liuxu 2022-01-29 15:12:03 +08:00 via Android
@zoharSoul 其实没必要这么抠字眼，中间件是个思想，不是具体组件
可以看看红帽的文档 https://www.redhat.com/zh/topics/middleware/what-is-middleware 中间件是为应用提供通用服务和功能的软件。数据管理、应用服务、消息传递、身份验证和 API 管理通常都要通过中间件。 |
|
10
liuxu 2022-01-29 15:36:00 +08:00 via Android
@zoharSoul 对的，楼主只是为了没用过 linux 管道的人方便理解，类比了中间件的思想，要是楼主也写过 java ，原话应该会是：
可以理解成 laravel 的中间件，java 的 filter 插件名，类名 /结构名写的就是管道 pipeline 顺便给 phper 提一下，laravel 有中间件，而调用中间件方法和 controller 是框架底层的 Pipeline 类 |
 |
11
bigpigeon 2022-01-29 17:04:01 +08:00
和 gin 的 middleware 区别在哪里
|
|
12
qbhy OP 我赞成八楼老哥的，中间件是思想，不是具体的组件。
|
|
13
qbhy OP @bigpigeon 我这个管道库不是某个框架的中间件，只是洋葱模型的管道的一个实现，只是通常用来实现中间件功能。也就是说，你可以在任何需要用到管道的地方使用他，不局限于 gin 或者 goal 或者其他框架
|
|
14
qbhy OP 最新的版本支持了纯净模式，也就是没有容器的管道，因为没有反射，性能更好，但是也没有了依赖注入功能。
|
 |
15
js2854 2022-02-09 13:50:03 +08:00
好像有现成的轮子，[RxGo]( https://github.com/ReactiveX/RxGo)
|
Select Language