码迷,mamicode.com
首页 > 其他好文 > 详细

Golang ETCD包的安装使用

时间:2020-01-29 10:58:36      阅读:193      评论:0      收藏:0      [点我收藏+]

标签:raft   mod   ring   success   linu   架构   import   com   led   

ETCD

日志收集项目

为什么要自己写不用ELK?

ELK: 部署的时候麻烦每一个filebeat都需要配置一个配置文件

使用etcd来管理被收集的日志项。

项目的架构

技术图片

上节课项目进度

  1. kafka:消息队列
  2. tailf:从文件里读日志
  3. go-ini:解析配置文件

今日内容

etcd

etcd介绍

详见群文件:etcd.pdf

http://www.5lmh.com/%E6%95%B0%E6%8D%AE%E5%BA%93%E6%93%8D%E4%BD%9C/go%E6%93%8D%E4%BD%9Cetcd/%E6%93%8D%E4%BD%9Cetcd.html

安装etcd

详见:https://docs.qq.com/doc/DTndrQXdXYUxUU09O

Ubuntu安装etcd

下载:etcd-v3.3.18-linux-amd64
解压文件即可使用,无需安装

go操作etcd

命令行操作:使用自带的etcdctl

注意一定要使用V3版本的API

先设置环境变量:

SET ETCDCTL_API=3 // Windows
export ETCDCTL_API=3 // Mac&Linux

启动服务端
进入安装目录中/usr/local/etcd-v3.3.18-linux-amd64

root@haima-PC:/usr/local/etcd-v3.3.18-linux-amd64# ./etcd

客户端操作:

PUT:

./etcdctl --endpoints=http://127.0.0.1:2379 put key value

GET:

./etcdctl --endpoints=http://127.0.0.1:2379 GET key

DEL:

./etcdctl --endpoints=http://127.0.0.1:2379 DEL key

go mod设置代理:

SET GOPROXY=https://goproxy.cn // Windows
export GOPROXY=https://goproxy.cn // Mac&Linux

PUT/GET

package main
import (
    "context"
    "fmt"
    "time"
    "go.etcd.io/etcd/clientv3"
)
// etcd client put/get demo
// use etcd/clientv3
func main() {
    cli, err := clientv3.New(clientv3.Config{
        Endpoints: []string{"127.0.0.1:2379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        // handle error!
        fmt.Printf("connect to etcd failed, err:%v\n", err)
        return
    }
    fmt.Println("connect to etcd success")

    defer cli.Close()

    // put
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    _, err = cli.Put(ctx, "baodelu", "dsb")
    cancel()
    if err != nil {
        fmt.Printf("put to etcd failed, err:%v\n", err)
        return
    }
    // get
    ctx, cancel = context.WithTimeout(context.Background(), time.Second)
    resp, err := cli.Get(ctx, "baodelu")
    cancel()
    if err != nil {
        fmt.Printf("get from etcd failed, err:%v\n", err)
        return
    }
    for _, ev := range resp.Kvs {
        fmt.Printf("%s:%s\n", ev.Key, ev.Value)
    }
}

watch

非常重要

package main

import (
    "context"
    "fmt"
    "go.etcd.io/etcd/clientv3"
    "time"
)
// etcd watch


func main() {
    cli, err := clientv3.New(clientv3.Config{
        Endpoints: []string{"127.0.0.1:2379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        // handle error!
        fmt.Printf("connect to etcd failed, err:%v\n", err)
        return
    }
    fmt.Println("connect to etcd success")

    defer cli.Close()
    // watch
    // 派一个哨兵 一直监视着 luminghui 这个key的变化(新增、修改、删除)
    ch := cli.Watch(context.Background(), "luminghui")
    // 从通道尝试取值(监视的信息)
    for wresp := range ch{
        for _, evt := range wresp.Events{
            fmt.Printf("Type:%v key:%v value:%v\n", evt.Type, string(evt.Kv.Key), string(evt.Kv.Value))
        }
    }
}

使用etcd优化日志收集项目

本周任务

  1. Raft协议

    1. 选举
    2. 日志复制机制
    3. 异常处理(脑裂)
    4. zookeeper的zad协议的区别

Golang ETCD包的安装使用

标签:raft   mod   ring   success   linu   架构   import   com   led   

原文地址:https://www.cnblogs.com/haima/p/12239543.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!