client.go
package main
import (
// "bytes"
"fmt"
"io/ioutil"
"net/http"
"net/url"
)
var client = &http.Client{}
func Get() {
//向服务端发送get请求
request, _ := http.NewRequest("GET", "http://192.168.1.35:9091/?publicKey=-----BEGIN+PUBLIC+KEY-----%0D%0AMIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDZsfv1qscqYdy4vY%2BP4e3cAtmv%0D%0AppXQcRvrF1cB4drkv0haU24Y7m5qYtT52Kr539RdbKKdLAM6s20lWy7%2B5C0Dgacd%0D%0AwYWd%2F7PeCELyEipZJL07Vro7Ate8Bfjya%2BwltGK9%2BXNUIHiumUKULW4KDx21%2B1NL%0D%0AAUeJ6PeW%2BDAkmJWF6QIDAQAB%0D%0A-----END+PUBLIC+KEY-----&privateKey=&info=sad&message=", nil)
response, _ := client.Do(request)
defer response.Body.Close()
if response.StatusCode == 200 {
str, _ := ioutil.ReadAll(response.Body)
bodystr := string(str)
fmt.Println(bodystr)
}
}
func Post() {
//post请求
postValues := url.Values{}
postValues.Add("publicKey", `-----BEGIN PUBLIC KEY-----
MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDZsfv1qscqYdy4vY+P4e3cAtmv
ppXQcRvrF1cB4drkv0haU24Y7m5qYtT52Kr539RdbKKdLAM6s20lWy7+5C0Dgacd
wYWd/7PeCELyEipZJL07Vro7Ate8Bfjya+wltGK9+XNUIHiumUKULW4KDx21+1NL
AUeJ6PeW+DAkmJWF6QIDAQAB
-----END PUBLIC KEY-----`)
postValues.Add("privateKey", `-----BEGIN RSA PRIVATE KEY-----
MIICXQIBAAKBgQDZsfv1qscqYdy4vY+P4e3cAtmvppXQcRvrF1cB4drkv0haU24Y
7m5qYtT52Kr539RdbKKdLAM6s20lWy7+5C0DgacdwYWd/7PeCELyEipZJL07Vro7
Ate8Bfjya+wltGK9+XNUIHiumUKULW4KDx21+1NLAUeJ6PeW+DAkmJWF6QIDAQAB
AoGBAJlNxenTQj6OfCl9FMR2jlMJjtMrtQT9InQEE7m3m7bLHeC+MCJOhmNVBjaM
ZpthDORdxIZ6oCuOf6Z2+Dl35lntGFh5J7S34UP2BWzF1IyyQfySCNexGNHKT1G1
XKQtHmtc2gWWthEg+S6ciIyw2IGrrP2Rke81vYHExPrexf0hAkEA9Izb0MiYsMCB
/jemLJB0Lb3Y/B8xjGjQFFBQT7bmwBVjvZWZVpnMnXi9sWGdgUpxsCuAIROXjZ40
IRZ2C9EouwJBAOPjPvV8Sgw4vaseOqlJvSq/C/pIFx6RVznDGlc8bRg7SgTPpjHG
4G+M3mVgpCX1a/EU1mB+fhiJ2LAZ/pTtY6sCQGaW9NwIWu3DRIVGCSMm0mYh/3X9
DAcwLSJoctiODQ1Fq9rreDE5QfpJnaJdJfsIJNtX1F+L3YceeBXtW0Ynz2MCQBI8
9KP274Is5FkWkUFNKnuKUK4WKOuEXEO+LpR+vIhs7k6WQ8nGDd4/mujoJBr5mkrw
DPwqA3N5TMNDQVGv8gMCQQCaKGJgWYgvo3/milFfImbp+m7/Y3vCptarldXrYQWO
AQjxwc71ZGBFDITYvdgJM1MTqc8xQek1FXn1vfpy2c6O
-----END RSA PRIVATE KEY-----`)
postValues.Add("info", "hello")
postValues.Add("message", "")
resp, err := client.PostForm("http://192.168.1.35:9091", postValues)
if err != nil {
fmt.Println(err.Error())
}
defer resp.Body.Close()
if resp.StatusCode == 200 {
body, _ := ioutil.ReadAll(resp.Body)
fmt.Println(string(body))
}
}
func main() {
Get()
Post()
}
index.go
package controllers
import (
"crypto/rand"
"crypto/rsa"
"crypto/x509"
"encoding/base64"
"encoding/pem"
"errors"
"fmt"
"net/http"
)
//处理数据的加密，解密或者单独的对数据进行或者解密
//用base64进行编码
func base64Encode(src []byte) []byte {
return []byte(base64.StdEncoding.EncodeToString(src))
}
//用base64进行解码
func base64Decode(src []byte) ([]byte, error) {
return base64.StdEncoding.DecodeString(string(src))
}
func toString(value []string) string {
length := len(value)
var sum string
for i := 0; i < length; i++ {
sum = sum + value[i]
}
return sum
}
var publicKey []byte
var privateKey []byte
//获得表单中的原文信息，明文是解密的结果
var cont []string
//得到原文字符串
var info string
//获得密文信息，密文是加密的结果
var meg []string
//得到密文字符串
var message string
func Get(w http.ResponseWriter, r *http.Request) {
//得到表单上的信息
Display(r)
//调用deal方法
Deal(info, message, publicKey, privateKey, w, r)
}
func Post(w http.ResponseWriter, r *http.Request) {
//得到客户端的数据
Display(r)
//调用deal方法
Deal(info, message, publicKey, privateKey, w, r)
}
//得到表单上的信息
func Display(r *http.Request) {
r.ParseForm() //解析参数，默认是不会解析的，如果没有写这句话的话，就无法得到请求的表单上面的数据
//得到私钥
var pri []string = r.Form["privateKey"]
//得到私钥字节类型的切片
privateKey = []byte(toString(pri))
// fmt.Fprintf(w, "私钥：\n"+string(privateKey)+"\n")
//得到公钥
var pub []string = r.Form["publicKey"]
//得到公钥字节类型的切片
publicKey = []byte(toString(pub))
//获得表单中的原文信息，明文是解密的结果
cont = r.Form["info"]
//得到原文字符串
info = toString(cont)
//获得密文信息，密文是加密的结果
meg = r.Form["message"]
//得到密文字符串
message = toString(meg)
}
//处理客户端的需求到底是什么
func Deal(info, message string, publicKey, privateKey []byte, w http.ResponseWriter, r *http.Request) {
//解密：密文， 私钥
//加密：明文， 共钥
//让我加解密
if info != "" && string(publicKey) != "" && string(privateKey) != "" && message == "" {
data, err := RsaEncrypt([]byte(info))
if err != nil {
panic(err)
}
// fmt.Fprintf(w, "公钥为：\n"+string(publicKey)+"\n")
debyte := base64Encode(data)
// fmt.Fprintf(w, "密文：\n"+string(debyte)+"\n")
origData, err := RsaDecrypt(data)
if err != nil {
panic(err)
}
// fmt.Fprintf(w, "私钥为：\n"+string(privateKey)+"\n")
fmt.Fprintf(w, "明文：\n%s", string(origData)+"\n")
fmt.Fprintf(w, "密文：\n"+string(debyte)+"\n")
//让我解密
} else if message != "" && string(privateKey) != "" && info == "" && string(publicKey) == "" {
//利用私钥解析密文得到明文
conte, err := base64Decode([]byte(message))
if err != nil {
panic(err)
}
conte, err = RsaDecrypt(conte)
if err != nil {
panic(err)
}
info = string(conte)
fmt.Fprintf(w, "明文：\n%s", info+"\n")
fmt.Fprintf(w, "密文：\n"+message+"\n")
} else if string(publicKey) != "" && info != "" && message == "" && string(privateKey) == "" { //让我加密
data, err := RsaEncrypt([]byte(info))
if err != nil {
panic(err)
}
message = string(base64Encode(data))
// fmt.Println("明文：", content)
fmt.Fprintf(w, "明文：\n%s", info+"\n")
fmt.Fprintf(w, "密文：\n"+message+"\n")
} else {
fmt.Fprintf(w, "请重新输入，不支持该种输入方式")
return
}
}
// 加密
func RsaEncrypt(origData []byte) ([]byte, error) {
block, _ := pem.Decode(publicKey)
if block == nil {
return nil, errors.New("public key error")
}
pubInterface, err := x509.ParsePKIXPublicKey(block.Bytes)
if err != nil {
return nil, err
}
pub := pubInterface.(*rsa.PublicKey)
return rsa.EncryptPKCS1v15(rand.Reader, pub, origData)
}
// 解密
func RsaDecrypt(ciphertext []byte) ([]byte, error) {
block, _ := pem.Decode(privateKey)
if block == nil {
return nil, errors.New("private key error!")
}
priv, err := x509.ParsePKCS1PrivateKey(block.Bytes)
if err != nil {
return nil, err
}
return rsa.DecryptPKCS1v15(rand.Reader, priv, ciphertext)
}
httpweb.go
package main
import (
// "fmt"
"log"
"net/http"
"testRSA2/controllers"
)
//设置服务端处理请求
//判断请求方式是get还是post请求
func indexHandle(w http.ResponseWriter, r *http.Request) {
m := r.Method
if m == "GET" {
controllers.Get(w, r)
} else {
controllers.Post(w, r)
}
}
func main() {
http.HandleFunc("/", indexHandle) //设置访问的路由
err := http.ListenAndServe(":9091", nil) //设置监听的端口
if err != nil {
log.Fatal("listenAndServe:", err)
}
}
有疑问加站长微信联系（非本文作者）
