go代理服务器代码
最近用废弃的小笔记本搭了个centos服务器挂着,搭了ssh,tomcat,go环境,想搭个代理服务器访问路由,不想安装,想自己写一个,顺便复习一下go语言知识。
一开始,我网上搜了一下go语言写代理服务器的代理,搜索到一个:
来自:http://symphony.b3log.org/article/1357452978419
(原文地址:http://kejibo.com/golang-http-proxy-server 已失效)
package main
import (
@H_301_10@"http"
@H_301_10@"log"
@H_301_10@"os"
@H_301_10@"io/IoUtil"
)
func handler(w http.ResponseWriter,r *http.Request) {
resp,err := http.DefaultClient.Do(r)
defer resp.Body.Close()
if err != nil { panic(err) }
for k,v := range resp.Header {
for _,vv := range v {
w.Header().Add(k,vv)
}
}
for _,c := range resp.SetCookie {
w.Header().Add(@H_301_10@"Set-Cookie",c.Raw)
}
w.WriteHeader(resp.StatusCode)
result,err := IoUtil.ReadAll(resp.Body)
if err != nil && err != os.EOF { panic(err) }
w.Write(result)
}
func main() {
http.HandleFunc(@H_301_10@"/",handler)
log.Println(@H_301_10@"Start serving on port 8888")
http.ListenAndServe(@H_301_10@":8888",nil)
os.Exit(0)
}
写成文件上传到服务器,go build test.go 编译,发现resp.SetCookie根本没有这个方法,编译不通过,上面文章说它要最新的http源码并编译到go源码里,我都惊呆了,还要修改它的源码啊,我看了下自己的go语言版本,是1.4.2,是15年今年的了,他写的文章的时候是13年,呵呵了,我的比他的新多了,怎么可能会旧?!还有他说的编译源码,是多么复杂啊~
于是乎。机智的我,为了编译通过,活生生的把它注释了。
go build test.go
好了,编译通过,执行它
/.test
显示开启了,还是要证实一下,扫描一下端口,看了下确实开了。
好像完成了喔,于是去浏览器设置一下代理,打开baidu.com,他告诉我方法错误了,我查看了一下打印信息,发现
defer resp.Body.Close()
这行报这个错:
invalid memory address or nil pointer dereference
网上找了一下,原来是resp变量空指针错误。
我又尝试打印err信息:
http: Request.RequestURI can’t be set in client requests.
就是说,ttp.DefaultClient.Do(r)这个用法是不正确的,是不能这样设置的,于是我找了一个替代品:http.NewRequest,它的优点就是可以get也可以post,应该还有put等操作,没尝试。
于是这段handler function被我耐心的改成了这样:
func handler(w http.ResponseWriter,r *http.Request) {
fmt.Println(@H_301_10@"url:",r.RequestURI)
fmt.Println(@H_301_10@"method:",r.Method)
fmt.Println(@H_301_10@"header:",r.Header)
client0 := &http.Client{}
req,_ := http.NewRequest(r.Method,r.RequestURI,r.Body)
fmt.Printf(@H_301_10@"send:%+v\n",req) //看下发送的结构
resp,err := client0.Do(req) //发送
if err!=nil {
fmt.Println(@H_301_10@"error:",err)
}
defer resp.Body.Close()
for _,value := range resp.Request.Cookies() {
w.Header().Add(value.Name,value.Value)
}
for k,v := range resp.Header {
for _,vv := range v {
w.Header().Add(k,vv)
}
}
w.WriteHeader(resp.StatusCode)
result,err := IoUtil.ReadAll(resp.Body)
if (err != nil) {
fmt.Println(@H_301_10@"error:",err)
}
fmt.Println(@H_301_10@"result:",result);
_,err = w.Write(result)
if (err != nil) {
fmt.Println(@H_301_10@"error:",err)
}
实际上我是在mac电脑上编辑的,用服务器上传在编译运行速度太慢了 = =、
看上去,代码好像写的很不错的样子。
运行起来,访问baidu死循环啦,我又改了几次,看了几次,还是这样,无奈的我只好测试其他网站,那个测试的网站是我的一个简单的jsp网页,就一个简单的列表,我一访问,竟然快速的出现了,竟然成功访问了,为什么百度的不行呢?我又试了试淘宝的网站,也是很快出现了,可是我没改到什么代码啊,就在我百事不得其解的时候,脑子闪出一个想法:可能是百度首页有复杂的判断导致代理服务器的请求死循环了,为了证实我的想法,我在浏览器输入网址:
http://www.baidu.com/s?wd=key
竟然能访问了!至于为什么会这样,读者有兴趣自行研究研究,在这,我只是先把简单的代理服务器帖上来,方便大家使用。
最后浏览了一下整改代理服务器的代码:
package main
import (
@H_301_10@"net/http"
@H_301_10@"log"
@H_301_10@"io/IoUtil"
@H_301_10@"fmt"
)
func handler(w http.ResponseWriter,r *http.Request) {
req,r.Body)
for k,v := range r.Header {
for _,vv := range v {
req.Header.Add(k,vv)
}
}
req.Header.Set(@H_301_10@"Content-Type",@H_301_10@"application/x-www-form-urlencoded; param=value")
client := &http.Client{}
resp,err := client.Do(req)
if err!=nil {
fmt.Println(@H_301_10@"error:",err)
}
defer resp.Body.Close()
for k,vv)
}
}
for _,value.Value)
}
w.WriteHeader(resp.StatusCode)
result,err)
}
_,err)
}
}
func main() {
http.HandleFunc(@H_301_10@"/",handler)
log.Println(@H_301_10@"Start serving on port 8089")
err := http.ListenAndServe(@H_301_10@":8089",nil)
if (err!=nil) {
log.Println(@H_301_10@"error:",err)
}
}