golang实现各种情况的get请求操作

请求地址

var (
 requestGetURLNoParams string = "http://httpbin.org/get"
 requestGetURL   string = "http://httpbin.org/get?a=a&b=b&c=ccc"
 imageURL    string = "http://httpbin.org/image"
)

普通get请求

// 基本get请求
func basicGet() {
 resp, err := http.Get(requestGetURLNoParams)
 if err != nil {
 log.Println("err")
 }
 defer resp.Body.Close()
 b, err := ioutil.ReadAll(resp.Body)
 if err != nil {
 log.Println("err")
 }
 fmt.Println(string(b))
}

请求参数放到url.Values{}

// get请求参数放到 "net/url"
func basicGetURLParams() {
 params := url.Values{}
 parseURL, err := url.Parse(requestGetURLNoParams)
 if err != nil {
 log.Println("err")
 }
 params.Set("aaa", "aaa")
 params.Set("age", "23")
 //如果参数中有中文参数,这个方法会进行URLEncode
 parseURL.RawQuery = params.Encode()
 urlPathWithParams := parseURL.String()
 resp, err := http.Get(urlPathWithParams)
 if err != nil {
 log.Println("err")
 }
 defer resp.Body.Close()
 b, err := ioutil.ReadAll(resp.Body)
 if err != nil {
 log.Println("err")
 }
 fmt.Println(string(b))
}

自定义请求(添加头、cookie)

// 可以设置请求头 添加cookie
func basicGetHeader() {
 client := http.Client{}
 req, err := http.NewRequest(http.MethodGet, requestGetURLNoParams, nil)
 if err != nil {
 log.Println("err")
 }
 // 添加请求头
 req.Header.Add("Content-type", "application/json;charset=utf-8")
 req.Header.Add("header", "header😂😂")
 // 添加cookie
 cookie1 := &http.Cookie{
 Name: "aaa",
 Value: "aaa-value",
 }
 req.AddCookie(cookie1)
 // 发送请求
 resp, err := client.Do(req)
 if err != nil {
 log.Println("err")
 }
 defer resp.Body.Close()
 b, err := ioutil.ReadAll(resp.Body)
 if err != nil {
 log.Println("err")
 }
 fmt.Println(string(b))
}

接收文件–ioutil.WriteFile

// ioutil.ReadAll(resp.Body) 先将所有的响应读出来放到内存中。如果文件太大,那么就会消耗很多内存
func basicGetDownloadFile() {
 client := http.Client{}
 req, err := http.NewRequest(http.MethodGet, imageURL, nil) // strings.NewReader(data)
 if err != nil {
 log.Println("err")
 }
 resp, err := client.Do(req)
 if err != nil {
 log.Println("err")
 }
 defer resp.Body.Close()
 b, err := ioutil.ReadAll(resp.Body)
 if err != nil {
 log.Println("err")
 }
 ioutil.WriteFile("./images/img.jpg", b, 0644)
}

接收文件–io.Copy

// io.Copy() 省去了先把内容读取到内存,然后将内存中的内容写到文件
func basicGetDownloadFileIoCopy() {
 client := http.Client{}
 req, err := http.NewRequest(http.MethodGet, imageURL, nil)
 if err != nil {
 log.Println("err")
 }
 resp, err := client.Do(req)
 if err != nil {
 log.Println("err")
 }
 defer resp.Body.Close()
 // 创建一个文件用于保存
 dest, err := os.Create("./images/img.jpg")
 if err != nil {
 log.Println("err")
 }
 defer dest.Close()
 // 然后将响应流和文件流对接起来
 _, err = io.Copy(dest, resp.Body)
 if err != nil {
 log.Println("err")
 }
}

补充:golang(go语言)消息传递(管道)方法实现发送多个get请求

1.需求说明

我用django rest framework写了一个简单的用户增删改查小案例,然后我想使用golang实现一个多并发请求,看看我的小项目能承受多少请求!初学go代码不正确,请多多指点。

2.代码实现

//基本的GET请求
package main

import (
 "fmt"
 "io/ioutil"
 "net/http"
 "time"
)
// HTTP get请求
func httpget(ch chan int){
 resp, err := http.Get("http://localhost:8000/rest/api/user")
 if err != nil {
  fmt.Println(err)
  return
 }
 defer resp.Body.Close()
 body, err := ioutil.ReadAll(resp.Body)
 fmt.Println(string(body))
 fmt.Println(resp.StatusCode)
 if resp.StatusCode == 200 {
  fmt.Println("ok")
 }
 ch <- 1
}
// 主方法
func main() {
 start := time.Now()
 // 注意设置缓冲区大小要和开启协程的个人相等
 chs := make([]chan int, 2000)
 for i := 0; i < 2000; i++ {
  chs[i] = make(chan int)
  go httpget(chs[i])
 }
 for _, ch := range chs {
  <- ch
 }
 end := time.Now()
 consume := end.Sub(start).Seconds()
 fmt.Println("程序执行耗时(s):", consume)
}

3.结果

当我把开了10000个协程时候django后台数据库就崩了哈哈应该连接数过大导致的,所以我就试了2000个感觉有点并发的意思哈哈!左侧是返回的json结果 右侧是django的后台!

4.总结

我们通过go语言的管道channel来实现并发请求,能够解决何避免传统共享内存实现并发的很多问题而且效率会高于共享内存的方法。

(0)

相关推荐

  • golang http请求封装代码

    在GOPATH 中创建 utils 文件夹 放置这两个文件 http.go package utils import ( "crypto/tls" "encoding/json" "errors" "fmt" "io/ioutil" "net/http" "net/url" "strings" "sync" ) var ( GE

  • golang使用http client发起get和post请求示例

    golang要请求远程网页,可以使用net/http包中的client提供的方法实现.查看了官方网站有一些示例,没有太全面的例子,于是自己整理了一下: get请求 func httpGet() { resp, err := http.Get("http://www.01happy.com/demo/accept.php?id=1") if err != nil { // handle error } defer resp.Body.Close() body, err := ioutil

  • golang 设置web请求状态码操作

    我就废话不多说了,大家还是直接看代码吧~ package main import ( "net/http" ) func main() { //路由处理绑定 http.HandleFunc("/", Hander) //监听8080端口 http.ListenAndServe(":8080", nil) } func Hander(w http.ResponseWriter, req *http.Request) { //设置 http请求状态

  • Golang发送http GET请求的示例代码

    使用标准库http来实现 package tools import ( "io/ioutil" "net/http" ) func Get(url string)string{ res, err :=http.Get(url) if err != nil { return "" } robots, err := ioutil.ReadAll(res.Body) res.Body.Close() if err != nil { return &qu

  • 详解golang开发中http请求redirect的问题

    这两天在开发项目的时候遇到了一个问题,请求了一个URL,它会302到另一个地址,本意上只是想检查这个URL是否会做3XX的redirect跳转,结果每次reqeust都会返回最后一跳的结果.后来就看了下源码,了解下请求跳转的机制 实现代码 看下实现的简单代码 func main() { client := &http.Client{} url := "http://www.qq.com" reqest, err := http.NewRequest("GET"

  • golang实现各种情况的get请求操作

    请求地址 var ( requestGetURLNoParams string = "http://httpbin.org/get" requestGetURL string = "http://httpbin.org/get?a=a&b=b&c=ccc" imageURL string = "http://httpbin.org/image" ) 普通get请求 // 基本get请求 func basicGet() { resp

  • Angular的$http的ajax的请求操作(推荐)

    angular通过封装$http方法,封装了,ajax请求 也通过$http封装了$http.get()和$http.post()的方法,这里由于图省事,这两种方法不如直接使用通用的方法 这里先写一个案例,首先先写一个对象 var req = { method: 'POST',//请求的方式 url: ip,//请求的地址 headers: { 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8', 'Accept'

  • 微信小程序设置全局请求URL及封装wx.request请求操作示例

    本文实例讲述了微信小程序设置全局请求URL及封装wx.request请求操作.分享给大家供大家参考,具体如下: app.js: App({ //设置全局请求URL globalData:{ URL: 'https://www.oyhdo.com', }, /** * 封装wx.request请求 * method: 请求方式 * url: 请求地址 * data: 要传递的参数 * callback: 请求成功回调函数 * errFun: 请求失败回调函数 **/ wxRequest(metho

  • Python3模拟curl发送post请求操作示例

    本文实例讲述了Python3模拟curl发送post请求操作.分享给大家供大家参考,具体如下: 后端给的接口样式: curl "http://65.33.44.43:509/pre/update" -H "Content-Type: text/json" -d '{"TYPE":"PRE-FILTER_UPDATE", "DATA":[{"SN":"1E3006CEBFE00&

  • 微信小程序使用request网络请求操作实例

    本文实例讲述了微信小程序使用request网络请求操作.分享给大家供大家参考,具体如下: 小程序提供了很多api,极大的方便了开发者,其中网络请求api是wx.request(object),这是小程序与开发者的服务器实现数据交互的一个很重要的api. 官方参数说明如下 OBJECT参数说明: 参数名 类型 必填 说明 url String 是 开发者服务器接口地址 data Object.String 否 请求的参数 header Object 否 设置请求的 header , header

  • PHP实现的curl批量请求操作示例

    本文实例讲述了PHP实现的curl批量请求操作.分享给大家供大家参考,具体如下: <?php $ch = array(); $res = array(); $conn = array(); $urls = array( 'baidu' => "http://www.baidu.com/", 'cheyun' => "http://auto.jrj.com.cn/", 'w3c' => "http://www.w3cschool.cc

  • Laravel框架处理用户的请求操作详解

    本文实例讲述了Laravel框架处理用户的请求操作.分享给大家供大家参考,具体如下: 1.请求对象Request Request中包含了用户请求的一些信息,使用该对象首先需要use Illuminate\Http\Request类,之后在参数中传入该对象, public static function getRequest(Request $request) { //获取请求类型 echo "请求类型" . $request->method() . "<br/&g

  • Laravel5.1 框架Request请求操作常见用法实例分析

    本文实例讲述了Laravel5.1 框架Request请求操作常见用法.分享给大家供大家参考,具体如下: 这篇主要说说Request 每当用户访问我们的网站功能时都会用到它 我们可以使用Request中的一些数据来做出适当的相应. 1 常用的属性和方法 我们可以从Request中取到一些重要属性来做一些逻辑处理,下面是Request中常用的属性: 1.1 获取用户输入 (前提工作 创建一个RESTful风格的控制器 并声明路由),Request可以获取到用户输入的数据 我们来看看 1.1.1 i

  • java实现响应重定向发送post请求操作示例

    本文实例讲述了java实现响应重定向发送post请求操作.分享给大家供大家参考,具体如下: 关于重定向我们用的比较多的还是redirect:重定向,默认发送的get请求. return "redirect:/index"; 但有时候请求地址必须为post请求,比如security登录就只能接收post请求,下面来看一下如何后台如何发送post请求响应重定向. 首先可以定义一个map,用于存放参数键值对 Map<String, String> parameter = new

  • C# 使用Fiddler捕获本地HttpClient发出的请求操作

    示例接口定义 为了方便笔者先自己写了个简单的接口用于展示,返回当前时间,具体如下 /// <summary> /// GetToday. /// </summary> /// <returns></returns> [HttpGet] [Route("GetTime/Today")] public MyDateTime GetToday() { var now = DateTime.Now; return new MyDateTime {

随机推荐