package main

import (
    "context"
    "fmt"
    "log"
    "os"
    "os/signal"
    "syscall"
    "time"

    "github.com/segmentio/kafka-go"
)

var (
    topic  = "user_click&quo

version: '3'

######## 项目依赖的环境，启动项目之前要先启动此环境 #######
######## The environment that the project depends on, starting this environment before starting the project #######

services:
  #jaeger链路追踪 — Jaeger for tracing
  jaeger:
    image: jaegertracing/all-in-one:1.42.0
    c

package main

import (
    "flag"
    "fmt"

    "grpc-common/ucenter/types/login"
    "grpc-common/ucenter/types/register"
    "ucenter/internal/config"
    "ucenter/internal/middleware"

func TestGoFastDfsClient(t *testing.T) {
    url := "/group1/upload"
    filename := "2.png"

    // 1. form表单请求体:头部
    bodyBuf := bytes.NewBufferString("")
    bodyWrite := multipart.NewWriter(bodyBuf)
    _, err := bodyWrite.CreateFormFile("file", fi

go run main.go

package main

import (
    "flag"
    "fmt"

    "ucenter-api/internal/config"
    "ucenter-api/internal/handler"
    &

# 结点名称
name: "s1"

# 数据存储目录
data-dir: "/etcd-data"

# 集群提供给外部客户端访问的url, 即外部客户端必须通过指定
listen-client-urls: "http://0.0.0.0:2379"

# 想客户端发布的服务端点
advertise-client-urls: "http://42.193.152.252:2379"

# 集群成员之间通信使用的url
listen-peer-ur

package main

import (
    "os"

    "github.com/natefinch/lumberjack"
    "go.uber.org/zap"
    "go.uber.org/zap/zapcore"
)

type Logger struct {
    *zap.Logger
}

func ZapLoginit() *Logger {
    coreList := make([]zapcore.Core, 0)
    // 输出终端
    encod

package main

import (
    "fmt"
    "time"

    _ "github.com/go-sql-driver/mysql"
    "xorm.io/xorm"
)

type User struct {
    Id       int64
    Age      int
    Password string    `xorm: