feat(certx): go-hua/ssl 迁入并更名 certx(证书/私钥工具)
- 原包名 ssl 与协议名混淆, 实为 x509 证书解析校验与自签生成, 更名 certx - 附测试、examples/certx 例程与包 README
This commit is contained in:
@@ -0,0 +1,31 @@
|
||||
# certx
|
||||
|
||||
证书/私钥工具:PEM 解析校验(证书、公私钥匹配验证)与自签证书生成。
|
||||
|
||||
> 迁移自 go-hua/ssl 并更名:原包名 `ssl` 与协议名混淆,实际是 x509 证书操作,
|
||||
> 故更名 `certx`。
|
||||
|
||||
## 用法
|
||||
|
||||
```go
|
||||
import "git.zeroonesoft.cn/golib/zogo/certx"
|
||||
|
||||
// 自签证书(返回证书 PEM 与私钥 PEM)
|
||||
certPEM, keyPEM, err := certx.CreateCertificate(
|
||||
"localhost", // CommonName
|
||||
[]string{"localhost", "example.com"}, // SAN DNS 列表
|
||||
)
|
||||
|
||||
// 解析校验
|
||||
cert, err := certx.ParseCertificate(certPEM)
|
||||
key, err := certx.ParsePrivateKey(keyPEM)
|
||||
err = certx.VerifyPrivateKey(cert, keyPEM) // 证书与私钥是否配对
|
||||
```
|
||||
|
||||
完整可运行例程:[examples/certx/main.go](../examples/certx/main.go)
|
||||
|
||||
## 注意
|
||||
|
||||
- `CreateCertificate` 生成 RSA 2048 自签证书,仅适合内网/测试或做 CA 签发的种子;
|
||||
生产对外服务请用正规 CA 证书。
|
||||
- `ParsePrivateKey` 支持 PKCS#1/PKCS#8/EC 三种 PEM 形态,返回 `any`(断言后使用)。
|
||||
+156
@@ -0,0 +1,156 @@
|
||||
// Package certx 提供证书/私钥的解析校验与自签证书生成。
|
||||
package certx
|
||||
|
||||
import (
|
||||
"crypto/ecdh"
|
||||
"crypto/ecdsa"
|
||||
"crypto/ed25519"
|
||||
"crypto/rand"
|
||||
"crypto/rsa"
|
||||
"crypto/x509"
|
||||
"crypto/x509/pkix"
|
||||
"encoding/pem"
|
||||
"errors"
|
||||
"math/big"
|
||||
"time"
|
||||
)
|
||||
|
||||
// ParseCertificate 解析 PEM 格式证书
|
||||
func ParseCertificate(data []byte) (*x509.Certificate, error) {
|
||||
block, _ := pem.Decode(data)
|
||||
if block == nil {
|
||||
return nil, errors.New("证书M解码失败")
|
||||
}
|
||||
//调用x509的接口
|
||||
cert, err := x509.ParseCertificate(block.Bytes)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return cert, err
|
||||
}
|
||||
|
||||
// ParsePrivateKey 解析 PEM 格式私钥(自动尝试 PKCS8/PKCS1/EC 格式)
|
||||
func ParsePrivateKey(data []byte) (any, error) {
|
||||
block, _ := pem.Decode(data)
|
||||
if block == nil {
|
||||
return nil, errors.New("证书M解码失败")
|
||||
}
|
||||
//调用x509的接口
|
||||
PKCS8, err := x509.ParsePKCS8PrivateKey(block.Bytes)
|
||||
if err == nil {
|
||||
return PKCS8, nil
|
||||
}
|
||||
|
||||
PKCS1, err := x509.ParsePKCS1PrivateKey(block.Bytes)
|
||||
if err == nil {
|
||||
return PKCS1, nil
|
||||
}
|
||||
|
||||
ECP, err := x509.ParseECPrivateKey(block.Bytes)
|
||||
if err == nil {
|
||||
return ECP, nil
|
||||
}
|
||||
|
||||
return nil, err
|
||||
}
|
||||
|
||||
// VerifyPrivateKey 校验私钥与证书是否匹配
|
||||
// der 为 PEM 格式私钥,支持 RSA/ECDSA/Ed25519/ECDH 类型
|
||||
func VerifyPrivateKey(cert *x509.Certificate, der []byte) error {
|
||||
block, _ := pem.Decode(der)
|
||||
if block == nil {
|
||||
return errors.New("证书M解码失败")
|
||||
}
|
||||
//调用x509的接口
|
||||
|
||||
PKCS1, err := x509.ParsePKCS1PrivateKey(block.Bytes)
|
||||
if err == nil {
|
||||
if PKCS1.PublicKey.Equal(cert.PublicKey) == false {
|
||||
return errors.New("私钥与证书不匹配")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
ECP, err := x509.ParseECPrivateKey(block.Bytes)
|
||||
if err == nil {
|
||||
if ECP.PublicKey.Equal(cert.PublicKey) == false {
|
||||
return errors.New("私钥与证书不匹配")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
PKCS8, err := x509.ParsePKCS8PrivateKey(block.Bytes)
|
||||
if err == nil {
|
||||
|
||||
// 根据实际类型使用私钥
|
||||
switch key := PKCS8.(type) {
|
||||
case *rsa.PrivateKey:
|
||||
// 在这里使用 RSA 私钥
|
||||
if key.PublicKey.Equal(cert.PublicKey) == false {
|
||||
return errors.New("私钥与证书不匹配")
|
||||
}
|
||||
return nil
|
||||
case *ecdsa.PrivateKey:
|
||||
// 在这里使用 ECDSA 私钥
|
||||
if key.PublicKey.Equal(cert.PublicKey) == false {
|
||||
return errors.New("私钥与证书不匹配")
|
||||
}
|
||||
return nil
|
||||
case ed25519.PrivateKey:
|
||||
// 在这里使用 Ed25519 私钥
|
||||
if key.Equal(cert.PublicKey) == false {
|
||||
return errors.New("私钥与证书不匹配")
|
||||
}
|
||||
return nil
|
||||
case ecdh.PrivateKey:
|
||||
// 在这里使用 Ed25519 私钥
|
||||
if key.Equal(cert.PublicKey) == false {
|
||||
return errors.New("私钥与证书不匹配")
|
||||
}
|
||||
return nil
|
||||
default:
|
||||
return errors.New("不支持的私钥类型")
|
||||
}
|
||||
}
|
||||
|
||||
return err
|
||||
}
|
||||
|
||||
// CreateCertificate 生成自签名证书
|
||||
// commonName 为证书主题,dnsName 为 SAN 域名列表
|
||||
// 返回 PEM 格式的证书与 RSA 2048 私钥,有效期 10 年
|
||||
func CreateCertificate(commonName string, dnsName []string) ([]byte, []byte, error) {
|
||||
maxValue := new(big.Int).Lsh(big.NewInt(1), 128)
|
||||
serialNumber, _ := rand.Int(rand.Reader, maxValue)
|
||||
|
||||
// 定义:引用IETF的安全领域的公钥基础实施(PKIX)工作组的标准实例化内容
|
||||
subject := pkix.Name{
|
||||
CommonName: commonName,
|
||||
}
|
||||
|
||||
// 设置 SSL证书的属性用途
|
||||
certificate509 := x509.Certificate{
|
||||
SerialNumber: serialNumber,
|
||||
Subject: subject,
|
||||
NotBefore: time.Now(),
|
||||
NotAfter: time.Now().AddDate(10, 0, 0),
|
||||
KeyUsage: x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature,
|
||||
ExtKeyUsage: []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth},
|
||||
//IPAddresses: []net.IP{net.ParseIP("127.0.0.1")},
|
||||
DNSNames: dnsName,
|
||||
}
|
||||
|
||||
// 生成指定位数密匙
|
||||
pk, _ := rsa.GenerateKey(rand.Reader, 2048)
|
||||
|
||||
// 生成 SSL公匙
|
||||
derBytes, err := x509.CreateCertificate(rand.Reader, &certificate509, &certificate509, &pk.PublicKey, pk)
|
||||
if err != nil {
|
||||
return nil, nil, err
|
||||
}
|
||||
certBuf := pem.EncodeToMemory(&pem.Block{Type: "CERTIFICATE", Bytes: derBytes})
|
||||
|
||||
// 生成 SSL私匙
|
||||
keyBuf := pem.EncodeToMemory(&pem.Block{Type: "RAS PRIVATE KEY", Bytes: x509.MarshalPKCS1PrivateKey(pk)})
|
||||
return certBuf, keyBuf, err
|
||||
}
|
||||
@@ -0,0 +1,56 @@
|
||||
package certx
|
||||
|
||||
import (
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
|
||||
func TestCreateAndParseCertificate(t *testing.T) {
|
||||
certPEM, keyPEM, err := CreateCertificate("test.example.com", []string{"test.example.com", "localhost"})
|
||||
if err != nil {
|
||||
t.Fatalf("CreateCertificate: %v", err)
|
||||
}
|
||||
|
||||
// PEM 格式校验
|
||||
if !strings.Contains(string(certPEM), "BEGIN CERTIFICATE") {
|
||||
t.Error("证书 PEM 格式错误")
|
||||
}
|
||||
if !strings.Contains(string(keyPEM), "PRIVATE KEY") {
|
||||
t.Error("私钥 PEM 格式错误")
|
||||
}
|
||||
|
||||
// 解析证书
|
||||
cert, err := ParseCertificate(certPEM)
|
||||
if err != nil {
|
||||
t.Fatalf("ParseCertificate: %v", err)
|
||||
}
|
||||
if cert.Subject.CommonName != "test.example.com" {
|
||||
t.Errorf("CommonName = %q", cert.Subject.CommonName)
|
||||
}
|
||||
if len(cert.DNSNames) != 2 {
|
||||
t.Errorf("DNSNames = %v, want 2 项", cert.DNSNames)
|
||||
}
|
||||
if !time.Now().Before(cert.NotAfter) {
|
||||
t.Error("证书应未过期")
|
||||
}
|
||||
|
||||
// 解析私钥
|
||||
if _, err := ParsePrivateKey(keyPEM); err != nil {
|
||||
t.Fatalf("ParsePrivateKey: %v", err)
|
||||
}
|
||||
|
||||
// 证书与私钥匹配
|
||||
if err := VerifyPrivateKey(cert, keyPEM); err != nil {
|
||||
t.Errorf("证书私钥应匹配: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseInvalidPem(t *testing.T) {
|
||||
if _, err := ParseCertificate([]byte("not a pem")); err == nil {
|
||||
t.Error("非法 PEM 应返回错误")
|
||||
}
|
||||
if _, err := ParsePrivateKey([]byte("not a pem")); err == nil {
|
||||
t.Error("非法 PEM 应返回错误")
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user