2024-08-19



package main
 
import (
    "fmt"
    "sync"
)
 
// 使用sync.Once实现单例模式
type singleton struct{}
 
var once sync.Once
var instance *singleton
 
func GetInstance() *singleton {
    return instance
}
 
func init() {
    instance = &singleton{}
}
 
func (s *singleton) Initialize() {
    // 初始化代码
    fmt.Println("Initialized singleton")
}
 
func main() {
    // 安全地调用初始化方法,只会执行一次
    once.Do(GetInstance().Initialize)
    // 程序其他部分...
}

这段代码展示了如何使用sync.Once来确保单例模式中的初始化代码只执行一次,即便面临多个goroutine同时调用。这是一个在Go中实现单例模式的简单方法,同时也演示了sync.Once的用法。

2024-08-19

在CentOS 7上使用yum安装Go语言环境的步骤如下:

  1. 首先,你需要添加Go的官方仓库。创建一个新的repo文件:



sudo tee /etc/yum.repos.d/golang.repo<<EOF
[golang]
name=Go Repository
baseurl=https://mirrors.aliyun.com/golang/yum/el7/
enabled=1
gpgcheck=1
gpgkey=https://mirrors.aliyun.com/golang/yum/el7/gpgkey
EOF
  1. 导入Go的公钥:



sudo rpm --import https://mirrors.aliyun.com/golang/yum/el7/gpgkey
  1. 接下来,你可以使用yum安装Go语言:



sudo yum install golang
  1. 安装完成后,你可以检查Go的版本确认安装成功:



go version
  1. 设置环境变量。编辑你的shell配置文件(比如~/.bash_profile~/.bashrc),添加以下内容:



export GOROOT=/usr/lib/golang
export GOPATH=$HOME/go
export PATH=$PATH:$GOROOT/bin:$GOPATH/bin
  1. 更新你的shell配置使其生效:



source ~/.bash_profile
# 或者
source ~/.bashrc

完成以上步骤后,Go语言应该已经成功安装并配置在你的CentOS 7系统上。

2024-08-19



package main
 
import (
    "context"
    "fmt"
    "log"
    "time"
 
    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)
 
func main() {
    clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")
    client, err := mongo.Connect(context.Background(), clientOptions)
    if err != nil {
        log.Fatal(err)
    }
    defer client.Disconnect(context.Background())
 
    collection := client.Database("testdb").Collection("testcollection")
 
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()
 
    // 插入文档
    insertResult, err := collection.InsertOne(ctx, bson.D{{"name", "John Doe"}, {"age", 30}})
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("文档插入成功,ID: %v\n", insertResult.InsertedID)
 
    // 查询单个文档
    var result bson.M
    err = collection.FindOne(ctx, bson.D{{"name", "John Doe"}}).Decode(&result)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("查询结果: %v\n", result)
 
    // 更新文档
    updateResult, err := collection.UpdateOne(ctx, bson.D{{"name", "John Doe"}}, bson.D{{"$set", bson.D{{"age", 31}}}})
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("文档更新成功,影响行数: %v\n", updateResult.MatchedCount)
 
    // 删除文档
    deleteResult, err := collection.DeleteOne(ctx, bson.D{{"name", "John Doe"}})
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("文档删除成功,删除行数: %v\n", deleteResult.DeletedCount)
}

这段代码展示了如何使用MongoDB的Go语言驱动程序来连接到MongoDB实例,对一个集合进行插入、查询、更新和删除操作。代码简洁,注重于展示核心功能,并包含了错误处理。

2024-08-19

Golang的GMP模型是指Go程序运行时的内存管理、垃圾回收和并发调度。

  1. 内存管理:

    • 使用Tcmalloc替代glibc的malloc实现,减少内存分配的锁竞争。
    • 对象分配器,用于高效管理小对象。
    • 三色标记清除垃圾回收算法。
  2. 调度:

    • M: OS线程,负责执行Go代码。
    • P: 代表处理器,负责调度M和管理任务队列。
    • G: Go程,即Go语言中的goroutine。

GMP模型调度流程示例代码:




// 创建一个新的Goroutine
go func() {
    // 你的代码
}()
 
// 创建P
p := newP()
 
// 创建M
m := newM()
 
// 将新创建的M和P绑定
newm(m, p)
 
// 执行Goroutine
execute(gp)

在实际的Golang运行时中,这些操作都是隐式进行的,无需手动干预。开发者只需编写Go代码并让Go运行时负责管理内存和调度goroutine即可。

2024-08-19

在Go语言中,通过反射(reflect)给对象赋值是一个常见的操作。但是,反射操作可能会导致一些不确定的行为,如果不正确地处理,可能会引发自定义异常。以下是一个简单的例子,展示如何通过反射给对象赋值,并在遇到错误时抛出自定义异常。




package main
 
import (
    "errors"
    "fmt"
    "reflect"
)
 
// 自定义异常
var ErrInvalidType = errors.New("invalid type")
 
// 通过反射给对象赋值
func setValueByReflect(obj interface{}, fieldName string, value interface{}) error {
    objValue := reflect.ValueOf(obj)
    if objValue.Kind() == reflect.Ptr {
        objValue = objValue.Elem()
    }
 
    if !objValue.IsValid() {
        return errors.New("object is invalid")
    }
 
    fieldValue := objValue.FieldByName(fieldName)
    if !fieldValue.IsValid() {
        return fmt.Errorf("field %s not found", fieldName)
    }
 
    if !fieldValue.CanSet() {
        return fmt.Errorf("field %s cannot be set", fieldName)
    }
 
    // 检查值的类型是否匹配
    valueType := reflect.TypeOf(value)
    if fieldValue.Type() != valueType {
        return ErrInvalidType
    }
 
    fieldValue.Set(reflect.ValueOf(value))
    return nil
}
 
func main() {
    type example struct {
        Field string
    }
 
    ex := &example{}
    err := setValueByReflect(ex, "Field", "value")
    if err != nil {
        if err == ErrInvalidType {
            fmt.Println("Invalid type error:", err)
        } else {
            fmt.Println("Other error:", err)
        }
        return
    }
 
    fmt.Println("Value set successfully:", ex.Field)
}

在这个例子中,setValueByReflect 函数接受一个对象、字段名和要赋的值,通过反射来设置字段的值。在赋值前,它会检查类型是否匹配,如果不匹配则抛出ErrInvalidType异常。在main函数中,我们创建了一个example结构体的实例,并尝试给它的Field字段赋一个不匹配类型的值,以此来演示异常处理的流程。

2024-08-19

在Go语言中,可以使用标准库中的sort包提供的SearchInts函数来高效地判断有序数组中是否包含指定元素。如果数组未排序,可以先排序然后再使用SearchInts

以下是一个判断数组中是否包含指定元素的示例代码:




package main
 
import (
    "fmt"
    "sort"
)
 
func contains(s []int, e int) bool {
    i := sort.SearchInts(s, e)
    return i < len(s) && s[i] == e
}
 
func main() {
    array := []int{1, 2, 3, 4, 5}
    element := 3
 
    if contains(array, element) {
        fmt.Printf("%d is in the array.\n", element)
    } else {
        fmt.Printf("%d is not in the array.\n", element)
    }
}

如果数组是其他类型的切片,可以使用Search函数的泛型版本Search或者自定义搜索函数来适应特定的切片类型。

2024-08-19

在Go语言中,有多个库可以用来解析JSON,例如encoding/jsonjson-iterator/goeasyjson等。以下是使用encoding/json库解析JSON的示例代码:




package main
 
import (
    "encoding/json"
    "fmt"
    "log"
)
 
// 定义结构体,与JSON数据结构匹配
type Person struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}
 
func main() {
    // JSON数据
    jsonData := `{"name": "John", "age": 30}`
 
    // 将要解析的数据解引用
    var person Person
 
    // 解析JSON数据
    err := json.Unmarshal([]byte(jsonData), &person)
    if err != nil {
        log.Fatalf("JSON Unmarshal error: %v", err)
    }
 
    // 输出解析后的数据
    fmt.Printf("Name: %v, Age: %v\n", person.Name, person.Age)
}

这段代码首先定义了一个Person结构体,与JSON数据的结构相匹配。然后,它使用json.Unmarshal函数将JSON数据解析到结构体实例中。如果解析成功,它会打印出解析后的数据。

如果你想要一个更高效的解析方式,可以考虑使用json-iterator/go库,它号称比encoding/json更快。使用方法类似,只是导入的包不同:




import "github.com/json-iterator/go"
 
var json = jsoniter.ConfigCompatibleWithStandardLibrary
 
// 解析JSON数据
err := json.Unmarshal([]byte(jsonData), &person)
if err != nil {
    log.Fatalf("JSON Unmarshal error: %v", err)
}

在选择库时,你需要考虑项目的具体需求,比如是否需要高性能,是否需要与其他库(如easyjson)进行对比测试等。通常,对于大多数应用,encoding/json已经足够好用,但在处理非常大的JSON数据或者高性能要求的场景下,可能会考虑使用其他库。

2024-08-19

在VSCode中设置Go语言的开发环境,需要安装Go语言扩展、设置GOPATH环境变量、安装Go语言工具链,并可选择配置代理。以下是简要步骤和示例代码:

  1. 安装Go语言扩展:

    打开VSCode,通过扩展市场安装Go插件。

  2. 设置GOPATH环境变量:

    在操作系统的环境变量中设置GOPATH。

    • 在Windows上:

      
      
      
      setx GOPATH "C:\path\to\your\workspace"
    • 在Linux或macOS上:

      
      
      
      export GOPATH=/path/to/your/workspace
  3. 安装Go语言工具链:

    访问Go官方下载页面,下载并安装适合你操作系统的Go语言工具链。

  4. 配置代理(可选):

    如果你在中国大陆等地使用Go语言,可能需要配置代理以访问Google的服务。

    • 在Windows上:

      
      
      
      setx GOPROXY=https://goproxy.io,direct
    • 在Linux或macOS上:

      
      
      
      export GOPROXY=https://goproxy.io,direct
  5. 创建Go项目和文件:

    在你的GOPATH下的src目录中创建你的项目文件夹,并在其中创建Go源文件。

    
    
    
    mkdir -p $GOPATH/src/yourproject
    cd $GOPATH/src/yourproject
    touch main.go

    然后,在main.go中写入以下代码:

    
    
    
    package main
     
    import "fmt"
     
    func main() {
        fmt.Println("Hello, Go!")
    }
  6. 运行Go程序:

    在VSCode中打开终端,运行以下命令:

    
    
    
    go run main.go

    如果一切设置正确,终端将输出:"Hello, Go!"

以上步骤为在VSCode中设置Go语言开发环境的基本过程。

2024-08-19

在Go程序中处理僵尸进程的一个常见方法是使用信号处理。以下是一个简单的示例,展示如何捕获SIGCHLD信号并处理僵尸进程。




package main
 
import (
    "fmt"
    "os"
    "os/exec"
    "os/signal"
    "syscall"
)
 
func main() {
    cmd := exec.Command("sleep", "5")
    err := cmd.Start()
    if err != nil {
        fmt.Println(err)
        return
    }
 
    c := make(chan os.Signal, 1)
    signal.Notify(c, syscall.SIGCHLD)
    go func() {
        for {
            <-c
            for {
                // Wait for any child process to exit, and clean up the zombie.
                var status syscall.WaitStatus
                var rusage syscall.Rusage
                pid, err := syscall.Wait4(-1, &status, syscall.WNOHANG, &rusage)
                if pid <= 0 || err == syscall.ECHILD {
                    break
                }
                fmt.Printf("Reaped process %d\n", pid)
            }
        }
    }()
 
    cmd.Wait() // Wait for the command to exit.
}

这段代码首先启动一个子进程执行sleep 5命令。然后,它设置一个信号处理程序来监听SIGCHLD信号。当有子进程结束时,操作系统会发送SIGCHLD信号给父进程。父进程在接收到SIGCHLD信号后,通过syscall.Wait4函数来回收僵尸进程。

这样做可以避免僵尸进程的产生,确保系统资源得到有效管理。

2024-08-19



// Java 服务端代码
public class GreeterImpl implements Greeter {
    @Override
    public String greet(String name) {
        return "Hello, " + name + "!";
    }
}
 
// Java 客户端代码
public class GreeterClient {
    private final GreeterBlockingStub stub;
 
    public GreeterClient(String host, int port) {
        ManagedChannel channel = ManagedChannelBuilder.forAddress(host, port)
            .usePlaintext()
            .build();
        stub = GreeterGrpc.newBlockingStub(channel);
    }
 
    public String greet(String name) {
        HelloRequest request = HelloRequest.newBuilder().setName(name).build();
        HelloResponse response = stub.sayHello(request);
        return response.getMessage();
    }
}



// Go 服务端代码
type Greeter struct {}
 
func (g *Greeter) Greet(ctx context.Context, request *pb.HelloRequest) (*pb.HelloResponse, error) {
    return &pb.HelloResponse{Message: "Hello, " + request.Name + "!"}, nil
}
 
// Go 客户端代码
func Greet(c pb.GreeterClient, name string) (string, error) {
    response, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: name})
    if err != nil {
        return "", err
    }
    return response.Message, nil
}

这两个代码示例展示了如何在Java和Go语言中实现gRPC服务端和客户端。Java服务端实现了RPC接口,Go服务端和客户端使用protobuf定义了序列化的消息格式,并实现了相应的服务调用。这为跨语言的分布式系统通信提供了一个简洁的实践案例。