1 Star 0 Fork 32

祝子 / yomo

forked from YoMo / yomo 
Create your Gitee Account
Explore and code with more than 6 million developers,Free private repositories !:)
Sign up
Clone or download
README_CN.md 4.42 KB
Copy Edit Web IDE Raw Blame History
fanweixiao authored 2020-09-15 18:26 . Create README_CN.md (#34)

YoMo Go

YoMo 是一套开源的实时边缘计算网关、开发框架和微服务平台,通讯层基于QUIC协议,更好的释放了未来5G等低时延网络的价值;为流式处理(Streaming Computing)设计的编解码器yomo-codec能大幅提升计算服务的吞吐量;基于插件的开发模式,5分钟即可上线您的物联网实时边缘计算处理系统。YoMo关注在工业互联网领域,目的是打造国产化自主可控的工业实时边缘计算体系。

官网: yomo.run.

🚀 3分钟构建工业微服务 Quick Start

1. 创建工程,并引入yomo

创建一个叫yomotest的目录:

mkdir yomotest
cd yomotest

初始化项目:

go mod init yomotest

引入yomo

go get -u github.com/yomorun/yomo

2. 编写业务逻辑echo.go

package main

import (
	"github.com/yomorun/yomo/pkg/yomo"
)

func main() {
  //// 运行echo plugin并监控4241端口,数据将会从YoMo Edge推送过来
  // yomo.Run(&EchoPlugin{}, "0.0.0.0:4241")
	
  // 开发调试时运行该方法,处于联网状态时,程序会自动连接至 yomo.run 的开发服务器,连接成功后,
  // 该Plugin会每2秒收到一条Observed()方法指定的Key的Value
  yomo.RunDev(&EchoPlugin{}, "localhost:4241")
}

// EchoPlugin 是一个YoMo Plugin,会将接受到的数据转换成String形式,并再结尾添加内容,修改
// 后的数据将流向下一个Plugin
type EchoPlugin struct{}

// Handle 方法将会在数据流入时被执行,使用Observed()方法通知YoMo该Plugin要关注的key,参数value
// 即该Plugin要处理的内容
func (p *EchoPlugin) Handle(value interface{}) (interface{}, error) {
	return value.(string) + "✅", nil
}

// Observed 返回一个string类型的值,该值是EchoPlugin插件关注的数据流中的Key,该数据流中Key对应
// 的Value将会以对象的形式被传递进Handle()方法中
func (p EchoPlugin) Observed() string {
	return "name"
}

// Name 用于设置该Plugin的名称,方便Debug等操作
func (p *EchoPlugin) Name() string {
	return "EchoPlugin"
}

// Mold 描述`Observed`的值的数据结构
func (p EchoPlugin) Mold() interface{} {
	return ""
}

3. 运行

  1. 在终端里执行 go run echo.go,您将会看到:
% go run a.go
[EchoPlugin:6031]2020/07/06 22:14:20 plugin service start... [localhost:4241]
name:yomo!✅
name:yomo!✅
name:yomo!✅
name:yomo!✅
name:yomo!✅
^Csignal: interrupt

恭喜!您的第一个YoMo应用已经完成!

小提示: 如果您使用复合数据结构(Complex Mold), 请参考:yomo-echo-plugin

🌟 YoMo架构和亮点

yomo-arch

YoMo关注在:

  • 工业互联网领域
    • 在IoT设备接入侧,需要<10ms的低延时实时通讯
    • 在智能设备侧,需要在边缘侧进行大算力的AI执行工作
  • YoMo包含两部分:
    • yomo-edge: 部署在企业内网,负责接收设备数据,并按照配置,依次执行各个yomo-plugin
    • yomo-plugin: 可以部署在企业私有云、公有云及yomo-edge-server上

YoMo的优势:

  • 全程基于Quic协议传输数据,使用UDP协议替代TCP协议后,大幅提升了传输的稳定性和高通率
  • 自研的yomo-codec优化了数据解码性能
  • 全程基于Stream Computing模型,并简化面向Stream编程的复杂度

🦸 成为YoMo开发者

First off, thank you for considering making contributions. It's people like you that make YoMo better. There are many ways in which you can participate in the project, for example: 首先感谢您的contributions,是您这样的人让YoMo能变得越来越好!参与YoMo项目有很多种方式:

🧙 联系YoMo组织

Email us at yomo@cel.la. Any feedback would be greatly appreciated!

开源协议

Apache License 2.0

Go
1
https://gitee.com/zhuzhaoyong201709/yomo.git
git@gitee.com:zhuzhaoyong201709/yomo.git
zhuzhaoyong201709
yomo
yomo
master

Search

103611 48b8ff67 1899542 103622 4d02230c 1899542