Go 標準庫之 GoRequests 介紹與基本使用

来源:https://www.cnblogs.com/taoxiaoxin/p/18136833
-Advertisement-
Play Games

目錄一、介紹二、安裝三、導入四、基本使用4.1 發送GET 請求4.2 POST請求發送JSON數據4.3 Post 文件上傳4.4 GoRequests 使用代理4.5 Gorequests 使用session五、HTTP服務端代碼 一、介紹 官方文檔 DOC: https://pkg.go.de ...


目錄

一、介紹

官方文檔 DOC: https://pkg.go.dev/github.com/levigross/grequests

Github: http://github.com/levigross/grequests

Python中的Requests庫非常強大，所以Go開發者模仿Python的Requests庫，由此誕生了Grequests庫。Grequests提供了一系列便利功能，使得發送HTTP請求變得簡單高效。下麵就是Grequests在Golang中實現的一些關鍵特性：

  • 響應序列化：Grequests支持將HTTP響應內容序列化為JSON和XML格式，讓處理API響應時更為方便。
  • 文件上傳和下載：提供了便捷的方式來上傳和下載文件，無需複雜的配置。
  • HTTP動詞支持：支持廣泛的HTTP動詞，包括GET、HEAD、POST、PUT、DELETE、PATCH以及OPTIONS，可以覆蓋大多數HTTP請求場景。

二、安裝

要開始使用Grequests庫，你需要先在你的Go環境中安裝它。通過下麵的命令即可完成安裝：

go get -u github.com/levigross/grequests

三、導入

在安裝完Grequests後，你可以通過import語句把它引入到你的Go代碼中：

import "github.com/levigross/grequests"

四、基本使用

4.1 發送GET 請求

下麵是一個發送GET請求的示例，其中演示瞭如何獲取HTTP響應並列印出來：

func Get() {
	resp, err := grequests.Get("http://127.0.0.1:8080/book/", nil)
	if err != nil {
		log.Fatalln("Unable to make request: ", err)
	}

	if !resp.Ok {
		log.Fatalln("請求超時!")
	}

	// 解析響應的JSON數據
	var data []map[string]interface{}
	if err := resp.JSON(&data); err != nil {
		log.Fatalln("Unable to parse JSON response: ", err)
	}
	fmt.Println(data)
}

上面的代碼首先使用Get方法發送GET請求，然後檢查是否有錯誤發生。如果沒有錯誤，就可以通過resp.Json()方法獲取響應的文本內容。

4.2 POST請求發送JSON數據

在下麵的例子中，我們創建了一個map對象來保存我們想要發送的JSON數據。然後我們通過ROption創建了一個請求選項對象，併在其中指定了JSON為發送的數據類型。最後，我們調用Post方法來發送請求：

func Post() {
	postData := map[string]string{
		"id":   "1",
		"name": "Go入門到進階",
	}
	geq := &grequests.RequestOptions{
		JSON: postData,
	}
	resp, err := grequests.Post("http://127.0.0.1:8080/book/create", geq)
	if err != nil {
		log.Fatalln("Unable to make request: ", err)
	}
	fmt.Println(resp.String())
}

下麵是代碼的逐行解釋：

  1. postData := map[string]string{"id": "1", "name": "Go入門到進階"}
    • 這裡定義了一個map[string]string類型的變數postData，其中包含了兩個鍵值對，分別是"id"和"name"，它們的值分別是"1"和"Go入門到進階"。
  2. geq := &grequests.RequestOptions{JSON: postData}
    • 這裡創建了一個grequests.RequestOptions類型的變數geq。grequests.RequestOptions是一個結構體，用於配置HTTP請求的各種選項，如URL、方法、頭信息、數據等。在這個例子中，我們通過JSON欄位將postData作為JSON數據傳遞給POST請求。
  3. resp, err := grequests.Post("http://127.0.0.1:8080/book/create", geq)
    • 這裡調用grequests.Post函數發起一個POST請求。http://127.0.0.1:8080/book/create是請求的目標URL，而geq是請求的配置選項。grequests.Post函數會返回一個Response對象和一個可能的錯誤。
  4. if err != nil { log.Fatalln("Unable to make request: ", err) }
    • 如果grequests.Post函數調用時發生錯誤，這個條件塊會執行。log.Fatalln函數會列印錯誤消息並退出程式。
  5. fmt.Println(resp.String())
    • 如果請求成功，這個條件塊會執行。resp.String()方法會返迴響應體的字元串表示，然後使用fmt.Println函數將其列印到標準輸出。
      總的來說，這段代碼的作用是向本地伺服器（假設在127.0.0.1:8080上）的/book/create路徑發送一個POST請求，請求體是JSON格式的數據，包含一個ID和書名。如果請求成功，它會列印出伺服器的響應。如果請求失敗，它會列印出錯誤信息並退出程式。

4.3 Post 文件上傳

文件上傳同樣簡單。你可以通過RequestOptions指定文件：

func UploadFile() {
	// 允許您通過指定磁碟上的位置來創建FileUpload結構片
	// 打開要上傳的文件
	file, err := os.Open("./go.mod")
	if err != nil {
		log.Fatalln("Unable to open file: ", err)
	}
	defer file.Close()

	// 創建FileUpload結構片
	ro := &grequests.RequestOptions{
		Files: []grequests.FileUpload{{
			FileName:     "1.txt", // 上傳後的文件名稱
			FieldName:    "file",  // 上傳文件對應欄位
			FileContents: file, // 使用文件內容作為FileContents
		}},
	}
	// 發送POST請求
	resp, err := grequests.Post("http://127.0.0.1:8080/book/upload/", ro)
	if err != nil {
		log.Fatalln("Unable to make request: ", err)
	}
	fmt.Println(resp.String())
}

在上述代碼中，我們創建了一個FileUpload結構，通過FileName、FieldName和FileContents來指定我們要上傳的文件詳情。

4.4 GoRequests 使用代理

gorequest代理，下麵是一個簡單的例子，需要把Proxies中的URL添加為*url.URL代理：

func Proxy() {
	// 代理伺服器
	const proxyServer = "http-pro.xxx.com:9010"

	// 代理隧道驗證信息
	const proxyUser = "xxxxxxxxx"
	const proxyPass = "xxxxxxxxx"

	// 初始化代理URL
	proxyUrl, _ := url.Parse("http://" + proxyUser + ":" + proxyPass + "@" + proxyServer)

	// 創建請求選項
	ro := &grequests.RequestOptions{
		Proxies: map[string]*url.URL{
			"http": proxyUrl,
		},
		Headers: map[string]string{
			"user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36",
		},
	}

	// 發起GET請求
	resp, err := grequests.Get("http://www.example.com", ro)
	if err != nil {
		fmt.Println("Error:", err)
		return
	}

	// 列印響應狀態碼
	fmt.Println("Status code:", resp.StatusCode)

	// 列印響應體
	fmt.Println("Response:", resp.String())
}

下麵是代碼的逐行解釋：

  1. // 代理伺服器
    • 這一行是一個註釋，聲明瞭接下來的代碼將定義代理伺服器的URL。
  2. const proxyServer = "http-pro.xxx.com:9010"
    • 這裡定義了一個常量proxyServer，它的值是代理伺服器的URL，格式為http://host:port。
  3. // 代理隧道驗證信息
    • 這一行是一個註釋，聲明瞭接下來的代碼將定義代理隧道的驗證信息。
  4. const proxyUser = "xxxxxxxxx"
    • 這裡定義了一個常量proxyUser，它的值是代理隧道的用戶名。
  5. const proxyPass = "xxxxxxxxx"
    • 這裡定義了一個常量proxyPass，它的值是代理隧道的密碼。
  6. // 初始化代理URL
    • 這一行是一個註釋，說明接下來的代碼將創建代理URL。
  7. proxyUrl, _ := url.Parse("http://" + proxyUser + ":" + proxyPass + "@" + proxyServer)
    • 這行代碼使用url.Parse函數創建了一個代理URL。它將代理隧道的用戶名、密碼和代理伺服器地址組合成一個URL，格式為http://username:password@host:port。_是忽略返回值的約定，因為返回值通常不需要使用。
  8. // 創建請求選項
    • 這一行是一個註釋，說明接下來的代碼將創建一個grequests.RequestOptions結構體，用於配置HTTP請求。
  9. ro := &grequests.RequestOptions{
    • 這裡開始定義grequests.RequestOptions結構體變數ro。
  10. Proxies: map[string]*url.URL{
    • 這裡定義了Proxies欄位，它是一個映射，將協議（如"http"）映射到代理URL。
  11. "http": proxyUrl,
    • 這行代碼將代理URL設置為HTTP協議的代理。
  12. },
    • 這是映射定義的結束。
  13. Headers: map[string]string{
    • 這裡定義了Headers欄位，它是一個映射，將HTTP頭欄位（如"user-agent"）映射到相應的值。
  14. "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36",
    • 這行代碼設置了一個HTTP頭欄位，即用戶代理（User-Agent），用於標識發起請求的客戶端。
  15. },
    • 這是映射定義的結束。
  16. }
    • 這是grequests.RequestOptions結構體變數的定義結束。
  17. // 發起GET請求
    • 這一行是一個註釋，說明接下來的代碼將發起一個GET請求。
  18. resp, err := grequests.Get("http://www.example.com", ro)
    • 這行代碼使用grequests.Get函數發起一個GET請求。http://www.example.com是請求的目標URL，而ro是請求的配置選項。grequests.Get函數會返回一個Response對象和一個可能的錯誤。
  19. if err != nil {
    • 如果grequests.Get函數調用時發生錯誤，這個條件塊會執行。
  20. fmt.Println("Error:", err)
    • 這行代碼列印出錯誤信息。
  21. return
    • 這行代碼表示如果發生錯誤，函數將返回，不繼續執行。
  22. }
    • 這是錯誤處理塊的結束。
  23. fmt.Println("Status code:", resp.StatusCode)
    • 如果請求成功，這行代碼會列印出響應的狀態碼。
  24. fmt.Println("Response:", resp.String())

4.5 Gorequests 使用session

下麵是使用Session的一個例子:

session := grequests.Session{
		RequestOptions: &grequests.RequestOptions{
			Headers: map[string]string{
				"authority":  "mp3.haoge500.com",
				"referer":    "https://www.zz123.com/",
				"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36",
			},
		},
	}

五、HTTP服務端代碼

package main

import (
	"encoding/json"
	"github.com/gin-gonic/gin"
	"net/http"
	"os"
)

type Book struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type BookHandler struct {
}

func (b *BookHandler) RegisterRoutes(server *gin.Engine) {
	bg := server.Group("/book")
	bg.POST("/upload", b.Upload)
	bg.POST("/create", b.Create)
	bg.GET("/", b.GetAllBooks) // 查詢書籍
}

func (b *BookHandler) Upload(ctx *gin.Context) {
	// 從請求中獲取文件
	file, err := ctx.FormFile("file")
	if err != nil {
		ctx.JSON(http.StatusBadRequest, gin.H{"error": "無法獲取上傳的文件"})
		return
	}

	// 將文件保存到伺服器
	// 註意：這裡需要確保保存文件的目錄存在，並且伺服器有寫入許可權
	savePath := "./uploads/" + file.Filename
	if err := ctx.SaveUploadedFile(file, savePath); err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{"error": "文件保存失敗"})
		return
	}

	ctx.JSON(http.StatusOK, gin.H{"message": "文件上傳成功"})
}

func (b *BookHandler) Create(ctx *gin.Context) {
	var req Book
	if err := ctx.Bind(&req); err != nil {
		return
	}

	// 將新的書籍數據保存到data.json文件中
	if err := addBookToFile(&req); err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to save book data"})
		return
	}

	ctx.JSON(http.StatusOK, gin.H{"message": "Book added successfully"})
}
func (b *BookHandler) GetAllBooks(c *gin.Context) {
	// 從data.json文件中讀取書籍數據
	books, err := getBooksFromFile()
	if err != nil {
		c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to read book data"})
		return
	}

	// 獲取URL查詢參數中的id
	id := c.Query("id")

	// 如果提供了ID，查找具有匹配ID的書籍列表
	if id != "" {
		// 查找具有匹配ID的書籍
		var foundBooks []Book
		for _, book := range books {
			if book.ID == id {
				foundBooks = append(foundBooks, book)
			}
		}
		// 如果找到了匹配的書籍，返回這些書籍
		if len(foundBooks) > 0 {
			c.JSON(http.StatusOK, foundBooks)
			return
		}
		// 如果沒有找到匹配的書籍，返回404
		c.JSON(http.StatusNotFound, gin.H{"error": "Books not found"})
		return
	}

	// 如果沒有提供ID，返回所有書籍
	c.JSON(http.StatusOK, books)
}
func addBookToFile(book *Book) error {
	// 讀取現有的data.json文件內容
	var books []Book
	data, err := os.ReadFile("data.json")
	if err != nil && !os.IsNotExist(err) {
		return err
	}

	// 如果文件存在，解析現有的書籍數據
	if err == nil {
		if err := json.Unmarshal(data, &books); err != nil {
			return err
		}
	}

	// 將新的書籍添加到數組中
	books = append(books, *book)

	// 將更新後的書籍數組序列化為JSON
	newData, err := json.MarshalIndent(books, "", "    ")
	if err != nil {
		return err
	}

	// 將序列化的JSON數據寫入data.json文件
	if err := os.WriteFile("data.json", newData, 0644); err != nil {
		return err
	}

	return nil
}
func getBooksFromFile() ([]Book, error) {
	// 讀取data.json文件內容
	data, err := os.ReadFile("data.json")
	if err != nil {
		return nil, err
	}

	// 解析JSON數據到書籍數組中
	var books []Book
	if err := json.Unmarshal(data, &books); err != nil {
		return nil, err
	}

	return books, nil
}

func InitWebServer(bookHandler *BookHandler) *gin.Engine {
	server := gin.Default()
	bookHandler.RegisterRoutes(server)
	return server
}

func main() {
	// 確保上傳目錄存在
	os.MkdirAll("./uploads", 0755)

	bookHandler := &BookHandler{}
	server := InitWebServer(bookHandler)
	server.Run(":8080") // 在8080埠啟動伺服器
}
分享是一種快樂，開心是一種態度！
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • vue3在構建時，使用魔法糖語法時defineProps和defineEmits的註意事項
    1、首先構造函數為中心 function Person() { } var p = new Person(); console.log('Person::', p) console.log(p.constructor Person) 列印如下： 可以看出構造函數通過new得到實例，實例可以通過【co ...
  • 基於 Scriptable 從零開始美化iOS桌面（一）
    今天我為大家帶來新的作品，iOS17桌面組件神器（Scriptable）原創腳本，精美作品分享！喜歡的話就點關註吧！更多腳本正在路上... * script : ONE-Progress.js * version : 1.0.0 * author : Nicolas-kings * date : 2 ...
  • java 適配器模式
    適配器模式（Adapter Pattern） 結構型設計模式，見名知意，就是兩個不相容的介面之間的橋梁。它結合了兩個獨立介面的功能。 主要解決：常常要將一些"現存的對象"放到新的環境中，而新環境要求的介面是現對象不能滿足的。 關鍵代碼：適配器繼承或依賴已有的對象，實現想要的目標介面。 優點： 1、可 ...
  • 位元組面試：領域、子域、核心域、通用域和支撐域怎麼劃分？
    領域驅動設計（DDD）裡面有一堆專業術語，比如領域、子域、核心域、通用域、支撐域等等，聽著是不是覺得挺嚇人？別怕，我來帶你輕鬆搞懂它們。 如何理解領域和子域？ 領域是指一定的業務範圍或問題域。在解決業務問題時，DDD 會將業務領域進行細分，將問題範圍限定在一定的邊界內，在這個邊界內建立領域模型，用代 ...
  • java 策略模式
    策略模式（Strategy Pattern） 指對象有某個行為，但是在不同的場景中，該行為有不同的實現演算法。將每個演算法封裝在獨立的類中，使得它們可以互相替換。可以在運行時根據需要選擇不同的演算法，而不需要修改客戶端代碼。 主要解決：在有多種演算法相似的情況下，使用 if...else 所帶來的複雜和難以 ...
  • 【python量化交易】qteasy使用教程04 -使用內置交易策略，搭積木式創建複雜交易策略
    抽象工廠模式（Abstract Factory Pattern）： 是圍繞一個超級工廠創建其他工廠。該超級工廠又稱為其他工廠的工廠。這種類型的設計模式屬於創建型模式，它提供了一種創建對象的最佳方式。 在抽象工廠模式中，介面是負責創建一個相關對象的工廠，不需要顯式指定它們的類。每個生成的工廠都能按照工 ...
  • 正則表達式中 “$” 並不是表示 “字元串結束
    原理 在看雪看到一篇文章：逆向調用QQ截圖NT與WeChatOCR-軟體逆向。裡面說了怎麼調用微信和QQ本地的OCR模型，還有很詳細的分析過程。 我稍微看了下文章，多的也看不懂。大概流程是使用mmmojo.dll這個dll來與WeChatOCR.exe做通信的，也是用它來啟動和關閉WeChatOCR ...
  • C++ 預設參數與引用傳遞：語法、用法及示例
    C++ 預設參數 預設參數概述 在 C++ 中，函數參數可以擁有預設值。這意味著，在調用函數時，如果省略了某個參數，那麼將使用為該參數指定的預設值。 設置預設參數 預設參數值使用等號 = 符號進行設置，位於參數聲明的類型之後。例如： void myFunction(string country = ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類