2024-08-16

FastAPI、Sanic、Tornado 是基于 Python 的异步框架,而 Gin 是基于 Go 语言的异步框架。在性能上,Python 和 Go 在不同的应用场景中有不同的表现。

在高并发场景下,Go 语言的性能更优越。Gin 是一个 Go 语言编写的 HTTP 框架,它以极快的速度和内存利用率而被人们所知。

FastAPI 和 Sanic 是基于 Python 的异步框架,它们主要使用 Python 的异步特性。

Tornado 是一个 Python 的网络库,它也支持异步操作,但它并不是基于异步语言特性设计的,因此在性能上不如基于异步 IO 的 Go 语言和其他框架。

下面是一些基本的代码示例:

Go Gin:




package main
 
import "github.com/gin-gonic/gin"
 
func main() {
    r := gin.Default()
    r.GET("/", func(c *gin.Context) {
        c.String(200, "Hello, World!")
    })
    r.Run() // 默认在 0.0.0.0:8080
}

Python FastAPI:




from fastapi import FastAPI
 
app = FastAPI()
 
@app.get("/")
def read_root():
    return {"Hello": "World"}

Python Sanic:




from sanic import Sanic
from sanic.response import json
 
app = Sanic()
 
@app.route("/")
async def test(request):
    return json({"hello": "world"})

由于这些框架的设计目的和实现方式不同,它们在设计理念、API 风格、开发习惯等方面都有所区别。选择哪一个框架,主要取决于你的应用需求、团队成员的技术背景、项目的规模和性能要求等因素。在性能要求高的场景下,Go 语言和 Gin 框架的组合可能是更好的选择。而在需要快速开发和部署的场景下,Python 生态中的 FastAPI 或许是更好的选择。

2024-08-16

在Go语言中,可以使用go-excel库来读取Excel表格中的数据。以下是一个简单的例子,展示如何使用go-excel库读取Excel文件:

首先,你需要安装go-excel库:




go get github.com/extrame/go-excel

然后,你可以使用以下代码来读取Excel文件:




package main
 
import (
    "fmt"
    "github.com/extrame/go-excel"
    "log"
)
 
func main() {
    xlFile, err := excel.Open("example.xlsx", "./")
    if err != nil {
        log.Fatal(err)
    }
    defer xlFile.Close()
 
    sheet := xlFile.GetSheet(0)
    for i := 1; i <= sheet.MaxRow(); i++ {
        row, err := sheet.GetRow(i)
        if err != nil {
            log.Fatal(err)
        }
        for j := 1; j <= sheet.MaxCol(); j++ {
            cell, err := row.GetCell(j)
            if err != nil {
                log.Fatal(err)
            }
            fmt.Printf("%s\t", cell.String())
        }
        fmt.Println()
    }
}

确保你的工作目录中有一个名为example.xlsx的Excel文件。这段代码将打开这个文件,读取第一个工作表中的所有行和列,并将单元格的内容打印到控制台。

请注意,go-excel库可能不支持所有Excel文件格式。如果你需要读取.xls格式的文件,你可能需要使用其他库,如tealeg/xlsx

2024-08-16

要使用SFTPGo调用API新增用户,你需要先部署SFTPGo并确保API能够被正确调用。以下是一个简化的步骤和示例代码,展示如何使用Python发送HTTP请求新增用户。

  1. 部署SFTPGo并启用API服务。
  2. 使用适当的HTTP客户端库编写代码发送请求。

以下是使用Python的requests库发送HTTP POST请求的示例代码:

首先,安装requests库(如果尚未安装):




pip install requests

然后,使用以下代码发送请求:




import requests
import json
 
# 替换为你的SFTPGo API URL和凭证
api_url = 'http://localhost:9090/api/v1/users'
username = 'your_username'
password = 'your_password'
 
# 新用户的详细信息
new_user = {
    "username": "new_user",
    "password": "new_password",
    "home_directory": "/path/to/user/home",
    # 其他需要的用户信息
}
 
# 发送POST请求
response = requests.post(api_url, json=new_user, auth=(username, password))
 
# 检查响应并输出结果
if response.status_code == 200:
    print('用户创建成功')
else:
    print('用户创建失败:', response.json())

确保替换api_urlusernamepasswordnew_user变量中的值以匹配你的SFTPGo服务器配置。

请注意,具体的API端点(如/api/v1/users)、请求方法(POST)、请求头(如需要JSON内容)和请求体(new_user字典)可能会根据你使用的SFTPGo版本和API文档的不同而有所差异。

2024-08-16



package main
 
import (
    "fmt"
    "sync"
    "sync/atomic"
    "time"
)
 
var (
    count int32
    wg    sync.WaitGroup
    mutex sync.Mutex
    rwmutex sync.RWMutex
)
 
func main() {
    // 启动读写协程
    go writeData()
    go readData()
 
    // 启动10个增加计数的协程
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go incrementCount()
    }
 
    // 等待所有增加计数的协程完成
    wg.Wait()
 
    fmt.Println("最终计数:", count)
}
 
// 增加计数,使用原子操作来保证计数的线程安全
func incrementCount() {
    defer wg.Done()
    time.Sleep(time.Millisecond * 100) // 模拟耗时操作
    atomic.AddInt32(&count, 1)
}
 
// 写数据,使用互斥锁来保证线程安全
func writeData() {
    for {
        mutex.Lock()
        count += 100
        mutex.Unlock()
        time.Sleep(time.Millisecond * 100) // 模拟耗时操作
    }
}
 
// 读数据,使用读写锁来保证线程安全
func readData() {
    for {
        rwmutex.RLock()
        fmt.Println("读取的计数:", count)
        rwmutex.RUnlock()
        time.Sleep(time.Millisecond * 100) // 模拟耗时操作
    }
}

这段代码模拟了一个简单的Go语言爬虫修炼(系列文章之一)中的场景,使用了互斥锁、读写锁和WaitGroup来同步和管理并发。代码中使用了原子操作来安全地增加计数,使用了Mutex来保护写操作的同步,使用了RWMutex来保护读操作的同步,并且周期性地在控制台打印出读取的计数值。这样的实践有助于理解Go语言中线程安全编程的一些基本概念。

2024-08-16



package main
 
import (
    "fmt"
    "syscall/js"
 
    "github.com/cloudwego/higress"
)
 
func main() {
    c := make(chan struct{}, 0)
    higress.InitHigressWASM()
 
    // 注册一个简单的处理函数,它将输入的数据转换为大写然后返回
    higress.RegisterWASM("uppercase", func(this js.Value, args []js.Value) interface{} {
        if len(args) != 1 {
            return "invalid argument count"
        }
        return args[0].String() // 假设第一个参数是字符串
    })
 
    select {
    case <-c:
        fmt.Println("Higress WASM plugin is running...")
    }
}

这段代码演示了如何初始化Higress的WASM插件,并注册一个名为"uppercase"的函数,该函数将输入的字符串转换为大写。这是一个简单的示例,实际的Higress WASM插件可能会更复杂,包含更多的功能和错误处理。

2024-08-16

Go模块代理设计上容易受到DNS劫持攻击,攻击者可以将用户的请求重定向到恶意模块服务器。

解决方法:

  1. 使用HTTPS来确保模块下载过程的完整性和未篡改性。
  2. 使用GOPRIVATE环境变量来指定私有模块的代理跳过。
  3. 使用模块的校验和来确保下载的模块未被篡改。
  4. 设置GONOPROXYGONOSUMDB环境变量来指定不使用代理和sum.golang.org的模块。
  5. 使用模块的可选字段replace指定模块的真实来源。
  6. 使用模块缓存,如go mod cache,来减少重复下载。
  7. 使用模块代理,如Proxyfier,来提高模块代理的安全性。

示例代码:




# 设置不使用代理的模块
export GONOPROXY="example.com/private-module"

# 设置私有模块的代理跳过
export GOPRIVATE="example.com/private-module"

# 运行模块代理服务
github.com/proxy/module-proxy

请注意,上述代码仅为示例,实际解决方案可能需要根据实际情况进行调整。

2024-08-16

在Go语言中,切片(slice)是一种数据结构,可以理解为一种动态长度的数组。切片的nil值和空切片(length为0)是两个不同的概念。

  1. 空切片:

空切片是长度为0,容量为0的切片,可以通过以下方式创建:




var emptySlice []int // 空切片

或者




emptySlice := make([]int, 0) // 空切片
  1. nil切片:

nil切片是一个未指向任何底层数组的切片,也就是说它的长度和容量都是0,但是它不是空切片。nil切片可以通过以下方式创建:




var nilSlice []int = nil // nil切片

在Go中,空切片和nil切片有以下区别:

  • 空切片(len,cap = 0)指向底层数组,这个数组的长度是0,容量是0,但是它确实存在。
  • nil切片(len,cap = 0)不指向任何底层数组,它的长度和容量都是0,但是它的值是nil。

在实际使用中,空切片和nil切片的主要区别在于,你可以向空切片添加元素,但是不能向nil切片添加元素,因为nil切片不指向任何底层的数组。

例如:




var nilSlice []int = nil
var emptySlice []int
 
emptySlice = append(emptySlice, 1) // 这是可以的,因为emptySlice是一个空切片,但是它指向底层数组
 
_, err := nilSlice.Append(1) // 这会引发panic,因为nilSlice是nil切片,不能添加元素
if err != nil {
    fmt.Println(err)
}

在实际编程中,我们应该尽量避免使用nil切片,而是使用空切片,因为它更加安全和易于处理。

2024-08-16

在Go语言中,函数式编程库samber/mo提供了Option模式的实现。Option模式是一种处理可能未定义值的方法。在Go中,Option通常是一个返回Option类型的函数,可以链式调用。

以下是一个使用samber/mo库中Option模式的简单示例:




package main
 
import (
    "fmt"
    "github.com/samber/lo"
)
 
func main() {
    // 创建一个Option
    myOption := lo.Some(10).Map(func(x int) string {
        return fmt.Sprintf("Value: %d", x)
    }).Get()
 
    // 打印Option的值
    fmt.Println(myOption)
}

在这个例子中,lo.Some(10) 创建了一个Option,它包含了值10。Map 方法应用了一个函数,将值10转换成字符串。Get 方法提取Option中的值。如果Option为None(即未定义值),则Get 方法会引发panic。

请注意,在实际应用中,你需要安装samber/mo库:




go get github.com/samber/lo
2024-08-16



// Rust代码,在lib.rs文件中
#[no_mangle]
pub extern "C" fn double_input(input: i32) -> i32 {
    input * 2
}
 
// 构建Rust库的命令
// 在Rust项目目录中执行:
// cargo build --release
 
// Go代码,在main.go文件中
package main
 
/*
#cgo LDFLAGS: -L${SRCDIR}/target/release -lmy_rust_library -lstdc++
#include <stdlib.h>
 
extern int double_input(int input);
 
static int double_input_wrapper(void *arg) {
    int input = *(int*)arg;
    return double_input(input);
}
*/
import "C"
import (
    "fmt"
    "unsafe"
)
 
func main() {
    input := 10
    result := C.double_input_wrapper(unsafe.Pointer(&input))
    fmt.Printf("Result from Rust: %d\n", result)
}
 
// 构建Go程序的命令
// 在Go项目目录中执行:
// go build
// 运行Go程序
// ./my_go_program

这个代码示例展示了如何在Go程序中调用一个使用Rust编写的函数。首先,在Rust中定义了一个函数double_input,该函数接收一个整数输入并返回其两倍。然后,在Go中,我们使用cgo特性定义了相应的外部函数声明和包装器,以便能够正确地调用Rust函数。在实际使用时,你需要确保Rust库已经被正确编译并且Go程序知道从哪里链接这个库。

2024-08-16



package main
 
/*
#cgo CFLAGS: -I./include
#cgo LDFLAGS: -L./lib -lmylib
#include <mylib.h>
*/
import "C"
import (
    "fmt"
    "runtime"
    "unsafe"
)
 
func main() {
    // 设置Go的垃圾收集器的并行度
    // 这是为了配合C代码中可能使用的其他并行机制
    runtime.GOMAXPROCS(runtime.NumCPU())
 
    // 调用C函数,传递参数并获取结果
    result := C.my_function(C.int(42))
    fmt.Printf("C函数返回的结果是: %d\n", uintptr(result))
}

这个示例代码展示了如何在Go程序中正确地设置并行度,并调用一个C库中的函数。这里使用runtime.GOMAXPROCS来设置垃圾收集器的并行度,这样做可以减少垃圾收集对程序运行的影响。同时,通过C.my_function调用C函数,并使用C.int来传递整数参数。最后,使用uintptr来正确地打印结果,因为C中的整数类型可能不是指针安全的。