今天给大家演示一下官方knative-eventing事件消费 CloudEvent事件的案例，从而帮助我们理解knative-eventing中原理。
1、knative 官方网站地址
2、上传 docker file和相关源码 到带有docker 环境的服务器制作docker镜像文件，并上传镜像私服habor镜像仓库。
官方默认的Dockerfile是需要修改的，主要是国内没办法访问golang.org ,因为 go .mod中使用到了。
github.com/cloudevents/sdk-go/v2 v2.0.0-RC2
github.com/google/uuid v1.1.1 国内没办法下载，所以我们需要设置代理，具体修改如下：
ENV GOPROXY 接下来我们执行docker build 和 docker push
docker build -t=yf.registry.965432.com/sjjcb/knative-eventing/helloworld-go:helloworldgo001 . 接下来我们在用docker push 把创建好的镜像推送到 harbor私有仓库中。
docker push yf.registry.965432.com/sjjcb/knative-eventing/helloworld-go:helloworldgo001 
3.修改sample-app.yaml 文件上传带有安装好kubectl 的机器
将以下服务定义复制到文件中。确保用 Docker Hub 用户名替换“{username}”
替换刚才创建的私有镜像地址
修改namespace 空间serving-test
修改后的 yaml 如下
# Namespace for sample application
apiVersion: v1
kind: Namespace
metadata:
name: serving-test
---
# A default broker
apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
name: default
namespace: serving-test
annotations:
# Note: you can set the eventing.knative.dev/broker.class annotation to change the class of the Broker .
# The default broker class is MTChannelBasedBroker, but Knative also supports use of the other class.
eventing.knative.dev/broker.class: MTChannelBasedBroker
spec: {}
---
# Helloworld-go app deployment
apiVersion: apps/v1
kind: Deployment
metadata:
name: helloworld-go
namespace: serving-test
spec:
replicas: 1
selector:
matchLabels: &labels
app: helloworld-go
template:
metadata:
labels: *labels
spec:
containers:
- name: helloworld-go
image: yf.registry.xx.com/xxx/knative-eventing/helloworld-go:helloworldgo001
---
# Service that exposes helloworld-go app.
# This will be the subscriber for the Trigger
apiVersion: v1
kind: Service
metadata:
name: helloworld-eventing-go
namespace: serving-test
spec:
selector:
app: helloworld-go
ports:
- protocol: TCP
port: 80
targetPort: 8080
---
# Knative Eventing Trigger to trigger the helloworld-go service
apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
name: helloworld-go
namespace: serving-test
spec:
broker: default
filter:
attributes:
type: dev.knative.samples.helloworld
source: dev.knative.samples/helloworldsource
subscriber:
ref:
apiVersion: v1
kind: Service
name: helloworld-go 将修改后的sample-app.yaml 上传服务器
执行kubectl 命令
kubectl apply -f sample-app.yaml 
创建后我们看rancher 平台上新增加的 工作负载和服务发现
4.接下来验证和测试发送并验证CloudEvents
Get the Broker URL 我们先获取这个Broker 信息
kubectl -n serving-test get broker default 
我们记录返回的URL
部署一个curl pod并用SSH连接到其中
kubectl -n serving-test run curl --image=radial/busyboxplus:curl -it 执行后我们在rancher平台中创建出一个带URL POD
我们点击这个URL 在“执行命令” 窗口中输入一下信息
curl -v "#34; -X POST -H "Ce-Id: 536808d3-88be-4077-9d7a-a3f162705f79" -H "Ce-Specversion: 1.0" -H "Ce-Type: dev.knative.samples.helloworld" -H "Ce-Source: dev.knative.samples/helloworldsource" -H "Content-Type: application/json" -d '{"msg":"Hello World from the curl pod."}' 
执行后
控制台立刻返回信息
同时我们在helloworld-go 容器中查看是否能监听到broker 代理转发的事件信息
果然收到事件监听返回信息
2022/03/05 15:08:59 Event received.
Validation: valid
Context Attributes,
specversion: 1.0
type: dev.knative.samples.helloworld
source: dev.knative.samples/helloworldsource
id: 536808d3-88be-4077-9d7a-a3f162705f79
datacontenttype: application/json
Extensions,
knativearrivaltime: 2022-03-05T15:08:59.768727795Z
Data,
{
"msg": "Hello World from the curl pod."
}
2022/03/05 15:08:59 Hello World Message from received event "Hello World from the curl pod."
2022/03/05 15:08:59 Responding with event
Validation: valid
Context Attributes,
specversion: 1.0
type: dev.knative.samples.hifromknative
source: knative/eventing/samples/hello-world
id: 4cee11fa-0d23-4577-808c-299fb70e11ce
datacontenttype: application/json
Data,
{
"msg": "Hi from helloworld-go app!"
} 以上我们通过使用curl命令中的CloudEvent属性和触发器监听到消息。
从上面的实例中是个典型的代理与触发器 模式。
为了更容易地过滤事件，Knative Eventing定义了代理 （Broker）和触发器（Trigger）对象。代理提供了一个可以通过属性选择的事件桶。它接收并转发事件 到由一个或多个匹配的Trigger所定义的订阅者中。 触发器描述了一个基于事件属性的过滤器，该事件将被传递给可 寻址对象。你可以按需创建多个触发器。
对于每个代理，Knative Eventing会隐式地创建一个通道。 Trigger会订阅Broker，并将过滤器作用到消息上。过滤器通过 CloudEvent消息的属性过滤相应的消息，然后将消息传递给感兴趣的 订阅者，下面一张图可以很好地解释。
好了今天的分享就到这里，感兴趣的小伙伴可以持续关注，我后面将陆续介绍Event 其他案例以及原理等。
