1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

version: '3.7'
services:
  etcd:
    image: cgr.dev/chainguard/etcd:latest
    #    image: "bitnami/etcd"
    container_name: etcd
    environment:
      - ALLOW_NONE_AUTHENTICATION=yes
      # 配置公网访问
      - ETCD_LISTEN_CLIENT_URLS=http://0.0.0.0:2379
    ports:
      - "2380:2380"
      - "2379:2379"

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

package main

import (
	"fmt"
	etcd "go.etcd.io/etcd/client/v3"
	"go.etcd.io/etcd/client/v3/concurrency"
	"time"
)

var (
	cli *etcd.Client
)

func Service() error {
	session, err := concurrency.NewSession(cli)
	if err != nil {
		return err
	}

	locker := concurrency.NewLocker(session, "Id:1")
	locker.Lock()
	defer locker.Unlock()

	// do any thing...
	// 模拟耗时任务
	time.Sleep(time.Second)
	fmt.Println("?")
	return nil
}
func main() {
	var err error
	cli, err = etcd.New(etcd.Config{
		Endpoints:   []string{"192.168.80.128:2379"},
		DialTimeout: 5 * time.Second,
	})

	if err != nil {
		panic(err)
	}
	var ch = make(chan int, 1)
	for i := 0; i < 30; i++ {
		go Service()
	}
	<-ch

}