今天给大家演示一下官方knative-eventing事件消费 c++loudEvent事件的案例，从而帮助我们理解knative-eventing中原理。
1、knative 官方网站地址https://knative.dev/docs/install/
2、上传dockerfile和相关源码 到带有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国内没办法下载，所以我们需要设置代理https://goproxy.cn，具体修改如下：
ENV GOPROXY https://goproxy.cn接下来我们执行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:helloworldgo0013.修改sample-app.yaml 文件上传带有安装好kubectl 的机器
将以下服务定义复制到文件中。确保用Docker Hub用户名替换“{username}”
替换刚才创建的私有镜像地址
修改namespace 空间serving-test
修改后的yaml 如下
# Namespace for sample applicationapiVersion: v1kind: Namespacemetadata: name: serving-test---# A default brokerapiVersion: eventing.knative.dev/v1kind: Brokermetadata: 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: MTChannelBasedBrokerspec: {}---# Helloworld-go app deploymentapiVersion: apps/v1kind: Deploymentmetadata: name: helloworld-go namespace: serving-testspec: 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 TriggerapiVersion: v1kind: Servicemetadata: name: helloworld-eventing-go namespace: serving-testspec: selector: app: helloworld-go ports: - protocol: tcp port: 80 targetPort: 8080---# Knative Eventing Trigger to trigger the helloworld-go serviceapiVersion: eventing.knative.dev/v1kind: Triggermetadata: name: helloworld-go namespace: serving-testspec: 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
http://broker-ingress.knative-eventing.svc.cluster.local/serving-test/default
部署一个curl pod并用ssh连接到其中
kubectl -n serving-test run curl --image=radial/busyboxplus:curl -it执行后我们在rancher平台中创建出一个带URL POD
我们点击这个URL 在“执行命令” 窗口中输入一下信息
curl -v "http://broker-ingress.knative-eventing.svc.cluster.local/serving-test/default" -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: validcontext Attributes, specversion: 1.0 type: dev.knative.samples.helloworld source: dev.knative.samples/helloworldsource id: 536808d3-88be-4077-9d7a-a3f162705f79 datacontenttype: application/jsonExtensions, knativearrivaltime: 2022-03-05T15:08:59.768727795ZData, { "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 eventValidation: validContext Attributes, specversion: 1.0 type: dev.knative.samples.hifromknative source: knative/eventing/samples/hello-world id: 4cee11fa-0d23-4577-808c-299fb70e11ce datacontenttype: application/jsonData, { "msg": "Hi from helloworld-go app!" }以上我们通过使用curl命令中的CloudEvent属性和触发器监听到消息。
从上面的实例中是个典型的代理与触发器 模式。
为了更容易地过滤事件，Knative Eventing定义了代理 （Broker）和触发器（Trigger）对象。代理提供了一个可以通过属性选择的事件桶。它接收并转发事件 到由一个或多个匹配的Trigger所定义的订阅者中。 触发器描述了一个基于事件属性的过滤器，该事件将被传递给可 寻址对象。你可以按需创建多个触发器。
对于每个代理，Knative Eventing会隐式地创建一个通道。 Trigger会订阅Broker，并将过滤器作用到消息上。过滤器通过 CloudEvent消息的属性过滤相应的消息，然后将消息传递给感兴趣的 订阅者，下面一张图可以很好地解释。
好了今天的分享就到这里，感兴趣的小伙伴可以持续关注，我后面将陆续介绍Event 其他案例以及原理等。
