Golang 实现 Telegram Bot API 完整功能的插件库 telego 的使用

Telego 是一个用于 Golang 的 Telegram Bot API 库，实现了完整的 API 功能（一对一映射）。

安装

go get github.com/mymmrac/telego

基本设置

首先需要创建 bot 实例并指定 token。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/mymmrac/telego"
)

func main() {
	// 从环境变量获取 Bot token
	botToken := os.Getenv("TOKEN")

	// 创建 bot 并启用调试信息
	// 注意：默认日志可能暴露敏感信息，仅在开发环境使用
	bot, err := telego.NewBot(botToken, telego.WithDefaultDebugLogger())
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	// 调用 getMe 方法 (https://core.telegram.org/bots/api#getme)
	botUser, err := bot.GetMe(context.Background())
	if err != nil {
		fmt.Println("Error:", err)
	}

	// 打印 Bot 信息
	fmt.Printf("Bot user: %+v\n", botUser)
}

获取更新

有两种获取更新的方法：

1. 使用长轮询 (bot.UpdatesViaLongPolling)
2. 使用 webhook (bot.UpdatesViaWebhook，推荐方式)

长轮询示例

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/mymmrac/telego"
)

func main() {
	botToken := os.Getenv("TOKEN")

	// 注意：默认日志可能暴露敏感信息，仅在开发环境使用
	bot, err := telego.NewBot(botToken, telego.WithDefaultDebugLogger())
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	// 获取更新通道
	updates, _ := bot.UpdatesViaLongPolling(context.Background(), nil)

	// 循环处理所有更新
	for update := range updates {
		fmt.Printf("Update: %+v\n", update)
	}
}

Webhook 示例

package main

import (
	"context"
	"fmt"
	"net/http"
	"os"

	"github.com/mymmrac/telego"
)

func main() {
	ctx := context.Background()
	botToken := os.Getenv("TOKEN")

	// 注意：默认日志可能暴露敏感信息，仅在开发环境使用
	bot, err := telego.NewBot(botToken, telego.WithDefaultDebugLogger())
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	// 在 Telegram 端设置 webhook
	_ = bot.SetWebhook(ctx, &telego.SetWebhookParams{
		URL:         "https://example.com/bot",
		SecretToken: bot.SecretToken(),
	})

	// 获取 webhook 信息
	info, _ := bot.GetWebhookInfo(ctx)
	fmt.Printf("Webhook Info: %+v\n", info)

	// 创建 http serve mux
	mux := http.NewServeMux()

	// 从 webhook 获取更新通道
	updates, _ := bot.UpdatesViaWebhook(ctx, telego.WebhookHTTPServeMux(mux, "/bot", bot.SecretToken()))

	// 启动服务器接收 Telegram 请求
	go func() {
		_ = http.ListenAndServe(":443", mux)
	}()

	// 循环处理所有更新
	for update := range updates {
		fmt.Printf("Update: %+v\n", update)
	}
}

使用 Telegram 方法

所有 Telegram Bot API 方法都可以通过该库使用。它们具有相同的名称和相同的参数。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/mymmrac/telego"
	tu "github.com/mymmrac/telego/telegoutil"
)

func main() {
	ctx := context.Background()
	botToken := os.Getenv("TOKEN")

	// 注意：默认日志可能暴露敏感信息，仅在开发环境使用
	bot, err := telego.NewBot(botToken, telego.WithDefaultDebugLogger())
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	// 调用 getMe 方法
	botUser, _ := bot.GetMe(ctx)
	fmt.Printf("Bot User: %+v\n", botUser)

	updates, _ := bot.UpdatesViaLongPolling(ctx, nil)

	for update := range updates {
		if update.Message != nil {
			// 获取聊天 ID
			chatID := update.Message.Chat.ID

			// 调用 sendMessage 方法
			// 向发送者发送相同文本的消息（回声机器人）
			sentMessage, _ := bot.SendMessage(ctx,
				tu.Message(
					tu.ID(chatID),
					update.Message.Text,
				),
			)

			fmt.Printf("Sent Message: %v\n", sentMessage)
		}
	}
}

工具方法

Telego 提供了 telegoutil 包来简化操作：

import tu "github.com/mymmrac/telego/telegoutil"

机器人处理器

Telego 提供了类似 net/http 的处理程序，但使用谓词而不是路径。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/mymmrac/telego"
	th "github.com/mymmrac/telego/telegohandler"
	tu "github.com/mymmrac/telego/telegoutil"
)

func main() {
	ctx := context.Background()
	botToken := os.Getenv("TOKEN")

	// 注意：默认日志可能暴露敏感信息，仅在开发环境使用
	bot, err := telego.NewBot(botToken, telego.WithDefaultDebugLogger())
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	// 获取更新通道
	updates, _ := bot.UpdatesViaLongPolling(ctx, nil)

	// 创建机器人处理器并指定更新来源
	bh, _ := th.NewBotHandler(bot, updates)

	// 停止处理更新
	defer func() { _ = bh.Stop() }()

	// 注册新处理器，匹配命令 `/start`
	bh.Handle(func(ctx *th.Context, update telego.Update) error {
		// 发送消息
		_, _ = ctx.Bot().SendMessage(ctx, tu.Message(
			tu.ID(update.Message.Chat.ID),
			fmt.Sprintf("Hello %s!", update.Message.From.FirstName),
		))
		return nil
	}, th.CommandEqual("start"))

	// 注册新处理器，匹配任何命令
	bh.Handle(func(ctx *th.Context, update telego.Update) error {
		// 发送消息
		_, _ = ctx.Bot().SendMessage(ctx, tu.Message(
			tu.ID(update.Message.Chat.ID),
			"Unknown command, use /start",
		))
		return nil
	}, th.AnyCommand())

	// 开始处理更新
	_ = bh.Start()
}

构建配置

Telego 支持通过 Go 的构建标签进行多种构建配置：

• 无标签 - 使用 goccy/go-json
• sonic - 使用 bytedance/sonic
• stdjson - 使用 encoding/json

许可证

Telego 采用 MIT 许可证分发。