System 发布的文章

go语言---- channel的关闭

2024-08-12

在Go语言中，channel是一种用于线程安全通信的类型。你可以使用内置的close函数来关闭channel。当你关闭了一个channel，你可以通过在接收表达式中测试ok/false来检查channel是否已经关闭。

解决方案1：




package main
 
import "fmt"
 
func main() {
    // 创建一个新的channel
    ch := make(chan int)
 
    // 开启一个goroutine
    go func() {
        // 发送数据到channel
        ch <- 10
        // 关闭channel
        close(ch)
    }()
 
    // 无限循环，直到channel被关闭
    for {
        // 尝试从channel接收数据
        data, ok := <-ch
        // 如果ok为false，表示channel已经关闭
        if !ok {
            fmt.Println("Channel has been closed. Exiting...")
            break
        }
        fmt.Println(data)
    }
}

解决方案2：




package main
 
import "fmt"
 
func main() {
    // 创建一个新的channel
    ch := make(chan int)
 
    // 开启一个goroutine
    go func() {
        // 发送数据到channel
        ch <- 10
        // 关闭channel
        close(ch)
    }()
 
    // 使用for-range循环来处理channel的接收和关闭
    for data := range ch {
        fmt.Println(data)
    }
    fmt.Println("Channel has been closed. Exiting...")
}

在这两个解决方案中，我们首先创建一个新的channel，然后开启一个goroutine，在这个goroutine中，我们发送一个数据到channel，然后关闭channel。在主goroutine中，我们使用for循环来检查channel是否被关闭，如果关闭了，我们就退出循环。在第二个解决方案中，我们使用for-range循环，这种方式更简洁，因为当channel被关闭并且没有更多的数据可以接收时，for-range循环会自动退出。

golang读取json文件

2024-08-12

在Golang中读取JSON文件有多种实现方法，下面是几种常用的方法：

使用ioutil.ReadFile()函数读取整个JSON文件的内容，然后使用json.Unmarshal()函数将JSON数据解码为相应的结构体。这种方法适用于JSON文件大小较小且可以完全加载到内存的情况。示例代码如下：




package main
 
import (
    "encoding/json"
    "fmt"
    "io/ioutil"
    "log"
)
 
type Data struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}
 
func main() {
    filePath := "data.json"
    
    fileData, err := ioutil.ReadFile(filePath)
    if err != nil {
        log.Fatal(err)
    }
 
    var data Data
    err = json.Unmarshal(fileData, &data)
    if err != nil {
        log.Fatal(err)
    }
 
    fmt.Println(data.Name, data.Age)
}

使用os.Open()函数打开JSON文件，然后利用json.NewDecoder()创建一个新的解码器，最后使用Decode()方法将JSON数据解码为结构体。这种方法适用于较大的JSON文件，因为它可以一次只加载部分数据到内存。示例代码如下：




package main
 
import (
    "encoding/json"
    "fmt"
    "log"
    "os"
)
 
type Data struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}
 
func main() {
    filePath := "data.json"
    
    file, err := os.Open(filePath)
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()
 
    decoder := json.NewDecoder(file)
 
    var data Data
    err = decoder.Decode(&data)
    if err != nil {
        log.Fatal(err)
    }
 
    fmt.Println(data.Name, data.Age)
}

使用json.Decoder结合os.Open()函数以及Token()方法逐行读取JSON文件，可以有效地处理非常大的JSON文件，因为它只加载一行到内存中。示例代码如下：




package main
 
import (
    "encoding/json"
    "fmt"
    "log"
    "os"
)
 
type Data struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}
 
func main() {
    filePath := "data.json"
    
    file, err := os.Open(filePath)
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()
 
    decoder := json.NewDecoder(file)
 
    for decoder.More() {
        var data Data
 
        err := decoder.Decode(&data)
        if err != nil {
            log.Fatal(err)
        }
 
        fmt.Println(data.Name, data.Age)
    }
}

Java 与 Go：可变数组

2024-08-12

在Java中，可变数组通常是通过ArrayList类实现的，它允许动态地添加和删除元素。在Go语言中，可变数组是通过切片（slice）实现的，它也可以动态增长和缩减。

以下是Java和Go语言中创建可变数组的示例代码：

Java:




import java.util.ArrayList;
import java.util.List;
 
public class MutableArrayExample {
    public static void main(String[] args) {
        List<Integer> list = new ArrayList<>();
        
        // 添加元素
        list.add(1);
        list.add(2);
        list.add(3);
        
        // 删除元素
        list.remove(1); // 删除索引为1的元素
        
        // 打印结果
        System.out.println(list);
    }
}

Go:




package main
 
import "fmt"
 
func main() {
    slice := []int{}
    
    // 添加元素
    slice = append(slice, 1)
    slice = append(slice, 2)
    slice = append(slice, 3)
    
    // 删除元素
    slice = append(slice[:1], slice[2:]...) // 删除索引为1的元素
    
    // 打印结果
    fmt.Println(slice)
}

在这两个示例中，我们创建了一个可变数组，然后分别在Java中使用ArrayList和在Go中使用切片来添加了一些元素，并从数组中删除了一个元素。这展示了两种语言中如何处理动态数组的基本方法。

golang gin web开发

2024-08-12




package main
 
import (
    "fmt"
    "github.com/gin-gonic/gin"
)
 
func main() {
    // 设置Gin为发布模式
    gin.SetMode(gin.ReleaseMode)
 
    // 创建一个Gin路由器
    r := gin.Default()
 
    // 添加一个基本的GET路由
    r.GET("/", func(c *gin.Context) {
        c.JSON(200, gin.H{
            "message": "Hello, World!",
        })
    })
 
    // 启动服务器，默认在0.0.0.0:8080监听
    // 如果你想要改变监听地址或端口，可以传递一个字符串参数，如："localhost:9090"
    if err := r.Run(); err != nil {
        fmt.Printf("服务器启动失败：%v\n", err)
    }
}

这段代码演示了如何使用Gin框架来创建一个简单的Web服务器，并对外提供一个基本的GET接口。在服务器启动时，如果有错误发生，会输出错误信息。这是一个典型的Gin Web服务器的入口代码。

深入理解Go语言中的Channel与Select

2024-08-12




package main
 
import (
    "fmt"
    "time"
)
 
func main() {
    // 创建一个无缓冲的channel
    ch := make(chan string)
 
    // 启动一个goroutine，每秒发送一次消息到channel
    go func() {
        for {
            time.Sleep(time.Second)
            ch <- "Hello, Channel!"
        }
    }()
 
    // 使用select监听channel是否有消息可读
    for {
        select {
        case msg := <-ch:
            fmt.Println(msg)
        case <-time.After(5 * time.Second):
            fmt.Println("Timeout!")
            return
        }
    }
}

这段代码创建了一个无缓冲的字符串类型channel，并在一个goroutine中循环发送消息。使用select语句监听channel，如果在5秒内有消息到达，则打印消息；如果5秒内没有消息，则触发超时并退出程序。这个例子展示了如何使用channel和select实现并发程序中的超时机制。

Go语言入门之数组切片

2024-08-12




package main
 
import "fmt"
 
// 定义一个函数，接收一个整型切片并打印其元素
func printNumbers(numbers []int) {
    fmt.Print("[")
    for i, number := range numbers {
        fmt.Print(number)
        if i < len(numbers)-1 {
            fmt.Print(", ")
        }
    }
    fmt.Print("]")
}
 
func main() {
    // 创建一个整型切片
    var numbers []int
    // 向切片添加元素
    numbers = append(numbers, 1)
    numbers = append(numbers, 2, 3, 4)
    // 打印切片元素
    printNumbers(numbers)
    // 输出: [1, 2, 3, 4]
}

这段代码定义了一个函数printNumbers，用于打印整型切片中的元素。然后在main函数中创建了一个整型切片，向其中添加了一些元素，并调用printNumbers函数打印这个切片的内容。

Go语言入门心法 Go操作Redis实战

2024-08-12




package main
 
import (
    "context"
    "fmt"
    "github.com/go-redis/redis/v8"
)
 
var ctx = context.Background()
 
func main() {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // 默认没有密码，如果有则填写
        DB:       0,  // 默认数据库为0，可以通过这个字段来切换数据库
    })
 
    // 设置键值对
    err := rdb.Set(ctx, "key", "value", 0).Err()
    if err != nil {
        panic(err)
    }
 
    // 获取存储的值
    val, err := rdb.Get(ctx, "key").Result()
    if err != nil {
        panic(err)
    }
    fmt.Println("key", val) // 输出: "key value"
 
    // 关闭连接
    err = rdb.Close()
    if err != nil {
        panic(err)
    }
}

这段代码演示了如何在Go语言中使用go-redis/redis库来连接Redis服务器，设置键值对，获取键对应的值，并在最后关闭连接。这是一个非常基础且实用的操作，对于想要入门Redis和Go操作的开发者来说，这是一个很好的起点。

Go Web框架-Beego

2024-08-12

以下是一个使用Beego框架创建的简单Web应用程序的代码示例。这个示例展示了如何设置一个基础的Web服务器，并定义一个简单的路由来响应HTTP请求。




package main
 
import "github.com/astaxie/beego"
 
type MainController struct {
    beego.Controller
}
 
func main() {
    // 运行Beego的默认Web服务器
    beego.Run()
}
 
// 定义一个处理"/hello"路径的方法
func (c *MainController) Get() {
    // 设置响应的状态码为200，并发送文本"Hello, World!"
    c.Ctx.WriteString("Hello, World!")
}
 
// 注册路由，将"/hello"路径映射到MainController的Get方法
func init() {
    beego.Router("/hello", &MainController{})
}

这段代码首先导入了Beego框架，然后定义了一个MainController结构体，它继承了beego.Controller。在main函数中，beego.Run()被调用以启动Web服务器。Get()方法处理对"/hello"路径的GET请求，并简单地返回文本"Hello, World!"。init()函数中的beego.Router用于注册路由。当服务器启动并且有请求发送到/hello路径时，Beego会调用MainController的Get()方法来响应请求。

Golang中四种gRPC模式

2024-08-12

在Golang中，gRPC支持以下四种模式：

简单模式(Simple RPC): 这是最基本的gRPC模式，客户端向服务器发送一个请求，并且期望从服务器接收一个响应。




// 服务器端
type MyService struct{}
 
func (s *MyService) UnaryRPC(ctx context.Context, req *MyRequest) (*MyResponse, error) {
    // 处理请求
    return &MyResponse{}, nil
}
 
// 客户端
func CallUnaryRPC(c MyServiceClient, req *MyRequest) (*MyResponse, error) {
    return c.UnaryRPC(context.Background(), req)
}

服务端流模式(Server-side streaming RPC): 客户端向服务器发送请求，并获取一系列响应消息。




// 服务器端
func (s *MyService) ServerStreamingRPC(req *MyRequest, stream MyService_ServerStreamingRPCServer) error {
    // 处理请求
    for {
        // 发送多个响应
        if err := stream.Send(&MyResponse{}); err != nil {
            return err
        }
    }
}
 
// 客户端
func CallServerStreamingRPC(c MyServiceClient, req *MyRequest) (MyService_ServerStreamingRPCClient, error) {
    return c.ServerStreamingRPC(req)
}

客户端流模式(Client-side streaming RPC): 客户端通过一系列请求消息向服务器发送请求，并期望从服务器获得一个响应。




// 服务器端
func (s *MyService) ClientStreamingRPC(stream MyService_ClientStreamingRPCServer) error {
    // 处理请求流
    for {
        req, err := stream.Recv()
        if err == io.EOF {
            break
        }
        if err != nil {
            return err
        }
        // 处理请求
    }
    return stream.SendAndClose(&MyResponse{})
}
 
// 客户端
func CallClientStreamingRPC(c MyServiceClient) (MyService_ClientStreamingRPCClient, error) {
    return c.ClientStreamingRPC(context.Background())
}

双向流模式(Bidirectional streaming RPC): 客户端和服务器通过一个双向的请求-响应流进行通信。




// 服务器端
func (s *MyService) BidirectionalStreamingRPC(stream MyService_BidirectionalStreamingRPCServer) error {
    // 处理请求流
    for {
        req, err := stream.Recv()
        if err == io.EOF {
            break
        }
        if err != nil {
            return err
        }
        // 处理请求
 
        // 发送响应
        if err := stream.Send(&MyResponse{}); err != nil {
            return err
        }
    }
    return nil
}
 
// 客户端
func CallBidirectionalStreamingRPC(c MyServiceClient) (MyService_BidirectionalStreamingRPCClient, error) {
    return c.BidirectionalStreamingRPC(context.Background())
}

在这些模式中，你需要定义一个服务和一个与服务相对应的proto文件，然后使用protoc编译器生成gRPC客户端和服务端的stub代码。在你的gRPC服务中实现服务方法，并在客户端代码中调用这些方法。