Merge branch 'master' of http://43.139.89.198:30000/hwf453/go_mqtt.git

.gitignore

@@ -23,5 +23,5 @@
 # Go workspace file
 go.work
 go_mqtt
-go_mqtt.db
+
 

FullCpu.go

@@ -0,0 +1,17 @@
+package main
+
+import "time"
+
+func test_print(a int) {
+	for {
+
+	}
+}
+
+
+func main() {
+	for i := 0; i < 100; i++ {
+		go test_print(i)
+	}
+	time.Sleep(360000000*time.Second)
+}

beepack.sh

@@ -12,16 +12,7 @@ bee pack -be GOOS=windows GOARCH=amd64
 
 #go build打包方式
 GOOS=windows GOARCH=amd64 go build
-GOOS=windows GOARCH=amd64 go build -o go_mqtt_pg.exe
-GOOS=windows GOARCH=amd64 go build -o go_mqtt_weather.exe
 
 GOOS=linux GOARCH=amd64 go build
-GOOS=linux GOARCH=amd64 go build -o go_mqtt_pg
-
-GOOS=freebsd GOARCH=amd64 go build
-GOOS=freebsd GOARCH=amd64 go build -o go_mqtt_pg
-
-GOOS=linux GOARCH=arm64 go build
-GOOS=linux GOARCH=arm64 go build -o go_mqtt_pg
 
 GOOS=darwin GOARCH=amd64 go build

go.mod

@@ -2,42 +2,21 @@ module go_mqtt
 
 go 1.24.1
 
+require (
+	github.com/eclipse/paho.mqtt.golang v1.5.0
+	github.com/go-sql-driver/mysql v1.9.3
+	github.com/google/uuid v1.6.0
+	github.com/shopspring/decimal v1.4.0
+	gorm.io/driver/mysql v1.6.0
+	gorm.io/gorm v1.30.0
+)
+
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
-	github.com/denisenkom/go-mssqldb v0.12.3 // indirect
-	github.com/dustin/go-humanize v1.0.1 // indirect
-	github.com/eclipse/paho.mqtt.golang v1.5.0 // indirect
-	github.com/glebarez/go-sqlite v1.22.0 // indirect
-	github.com/glebarez/sqlite v1.11.0 // indirect
-	github.com/go-sql-driver/mysql v1.9.3 // indirect
-	github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect
-	github.com/golang-sql/sqlexp v0.1.0 // indirect
-	github.com/google/uuid v1.6.0 // indirect
 	github.com/gorilla/websocket v1.5.3 // indirect
-	github.com/jackc/pgpassfile v1.0.0 // indirect
-	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
-	github.com/jackc/pgx/v5 v5.7.5 // indirect
-	github.com/jackc/puddle/v2 v2.2.2 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
-	github.com/mattn/go-isatty v0.0.20 // indirect
-	github.com/mattn/go-sqlite3 v1.14.28 // indirect
-	github.com/microsoft/go-mssqldb v1.9.2 // indirect
-	github.com/ncruces/go-strftime v0.1.9 // indirect
-	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
-	github.com/shopspring/decimal v1.4.0 // indirect
-	golang.org/x/crypto v0.39.0 // indirect
-	golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b // indirect
 	golang.org/x/net v0.41.0 // indirect
 	golang.org/x/sync v0.15.0 // indirect
-	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
-	gorm.io/driver/mysql v1.6.0 // indirect
-	gorm.io/driver/postgres v1.6.0 // indirect
-	gorm.io/driver/sqlserver v1.6.0 // indirect
-	gorm.io/gorm v1.30.0 // indirect
-	modernc.org/libc v1.66.2 // indirect
-	modernc.org/mathutil v1.7.1 // indirect
-	modernc.org/memory v1.11.0 // indirect
-	modernc.org/sqlite v1.38.0 // indirect
 )

go.sum

@@ -1,203 +1,26 @@
 filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
-github.com/Azure/azure-sdk-for-go/sdk/azcore v0.19.0/go.mod h1:h6H6c8enJmmocHUbLiiGY6sx7f9i+X3m1CHdd5c6Rdw=
-github.com/Azure/azure-sdk-for-go/sdk/azcore v1.0.0/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U=
-github.com/Azure/azure-sdk-for-go/sdk/azcore v1.1.2/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U=
-github.com/Azure/azure-sdk-for-go/sdk/azidentity v0.11.0/go.mod h1:HcM1YX14R7CJcghJGOYCgdezslRSVzqwLf/q+4Y2r/0=
-github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.1.0/go.mod h1:bhXu1AjYL+wutSL/kpSq6s7733q2Rb0yuot9Zgfqa/0=
-github.com/Azure/azure-sdk-for-go/sdk/internal v0.7.0/go.mod h1:yqy467j36fJxcRV2TzfVZ1pCb5vxm4BtZPUdYWe/Xo8=
-github.com/Azure/azure-sdk-for-go/sdk/internal v1.0.0/go.mod h1:eWRD7oawr1Mu1sLCawqVc0CUiF43ia3qQMxLscsKQ9w=
-github.com/AzureAD/microsoft-authentication-library-for-go v0.5.1/go.mod h1:Vt9sXTKwMyGcOxSmLDMnGPgqsUg7m8pe215qMLrDXw4=
-github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/denisenkom/go-mssqldb v0.12.3 h1:pBSGx9Tq67pBOTLmxNuirNTeB8Vjmf886Kx+8Y+8shw=
-github.com/denisenkom/go-mssqldb v0.12.3/go.mod h1:k0mtMFOnU+AihqFxPMiF05rtiDrorD1Vrm1KEz5hxDo=
-github.com/dnaeon/go-vcr v1.1.0/go.mod h1:M7tiix8f0r6mKKJ3Yq/kqU1OYf3MnfmBWVbPx/yU9ko=
-github.com/dnaeon/go-vcr v1.2.0/go.mod h1:R4UdLID7HZT3taECzJs4YgbbH6PIGXB6W/sc5OLb6RQ=
-github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
-github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
 github.com/eclipse/paho.mqtt.golang v1.5.0 h1:EH+bUVJNgttidWFkLLVKaQPGmkTUfQQqjOsyvMGvD6o=
 github.com/eclipse/paho.mqtt.golang v1.5.0/go.mod h1:du/2qNQVqJf/Sqs4MEL77kR8QTqANF7XU7Fk0aOTAgk=
-github.com/glebarez/go-sqlite v1.22.0 h1:uAcMJhaA6r3LHMTFgP0SifzgXg46yJkgxqyuyec+ruQ=
-github.com/glebarez/go-sqlite v1.22.0/go.mod h1:PlBIdHe0+aUEFn+r2/uthrWq4FxbzugL0L8Li6yQJbc=
-github.com/glebarez/sqlite v1.11.0 h1:wSG0irqzP6VurnMEpFGer5Li19RpIRi2qvQz++w0GMw=
-github.com/glebarez/sqlite v1.11.0/go.mod h1:h8/o8j5wiAsqSPoWELDUdJXhjAhsVliSn7bWZjOhrgQ=
 github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1aweo=
 github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=
-github.com/golang-jwt/jwt v3.2.1+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
-github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
-github.com/golang-jwt/jwt/v4 v4.2.0/go.mod h1:/xlHOz8bRuivTWchD4jCa+NbatV+wEUSzwAxVc6locg=
-github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
-github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
-github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
-github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
-github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI=
-github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
-github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/gorilla/securecookie v1.1.1/go.mod h1:ra0sb63/xPlUeL+yeDciTfxMRAA+MP+HVt/4epWDjd4=
-github.com/gorilla/sessions v1.2.1/go.mod h1:dk2InVEVJ0sfLlnXv9EAgkf6ecYs/i80K/zI+bUmuGM=
 github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
 github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
-github.com/hashicorp/go-uuid v1.0.2/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
-github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
-github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
-github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 h1:iCEnooe7UlwOQYpKFhBabPMi4aNAfoODPEFNiAnClxo=
-github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
-github.com/jackc/pgx/v5 v5.7.5 h1:JHGfMnQY+IEtGM63d+NGMjoRpysB2JBwDr5fsngwmJs=
-github.com/jackc/pgx/v5 v5.7.5/go.mod h1:aruU7o91Tc2q2cFp5h4uP3f6ztExVpyVv88Xl/8Vl8M=
-github.com/jackc/puddle/v2 v2.2.2 h1:PR8nw+E/1w0GLuRFSmiioY6UooMp6KJv0/61nB7icHo=
-github.com/jackc/puddle/v2 v2.2.2/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
-github.com/jcmturner/aescts/v2 v2.0.0/go.mod h1:AiaICIRyfYg35RUkr8yESTqvSy7csK90qZ5xfvvsoNs=
-github.com/jcmturner/dnsutils/v2 v2.0.0/go.mod h1:b0TnjGOvI/n42bZa+hmXL+kFJZsFT7G4t3HTlQ184QM=
-github.com/jcmturner/gofork v1.0.0/go.mod h1:MK8+TM0La+2rjBD4jE12Kj1pCCxK7d2LK/UM3ncEo0o=
-github.com/jcmturner/goidentity/v6 v6.0.1/go.mod h1:X1YW3bgtvwAXju7V3LCIMpY0Gbxyjn/mY9zx4tFonSg=
-github.com/jcmturner/gokrb5/v8 v8.4.2/go.mod h1:sb+Xq/fTY5yktf/VxLsE3wlfPqQjp0aWNYyvBVK62bc=
-github.com/jcmturner/rpc/v2 v2.0.3/go.mod h1:VUJYCIDm3PVOEHw8sgt091/20OJjskO/YJki3ELg/Hc=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
-github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
-github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
-github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
-github.com/mattn/go-sqlite3 v1.14.28 h1:ThEiQrnbtumT+QMknw63Befp/ce/nUPgBPMlRFEum7A=
-github.com/mattn/go-sqlite3 v1.14.28/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
-github.com/microsoft/go-mssqldb v0.19.0/go.mod h1:ukJCBnnzLzpVF0qYRT+eg1e+eSwjeQ7IvenUv8QPook=
-github.com/microsoft/go-mssqldb v1.9.2 h1:nY8TmFMQOHpm2qVWo6y4I2mAmVdZqlGiMGAYt64Ibbs=
-github.com/microsoft/go-mssqldb v1.9.2/go.mod h1:GBbW9ASTiDC+mpgWDGKdm3FnFLTUsLYN3iFL90lQ+PA=
-github.com/modocache/gover v0.0.0-20171022184752-b58185e213c5/go.mod h1:caMODM3PzxT8aQXRPkAt8xlV/e7d7w8GM5g0fa5F0D8=
-github.com/montanaflynn/stats v0.6.6/go.mod h1:etXPPgVO6n31NxCd9KQUMvCM+ve0ruNzt6R8Bnaayow=
-github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4=
-github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=
-github.com/pkg/browser v0.0.0-20180916011732-0a3d74bf9ce4/go.mod h1:4OwLy04Bl9Ef3GJJCoec+30X3LQs/0/m4HFRt/2LUSA=
-github.com/pkg/browser v0.0.0-20210115035449-ce105d075bb4/go.mod h1:N6UoU20jOqggOuDwUaBQpluzLNDqif3kq9z2wpdYEfQ=
-github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8/go.mod h1:HKlIX3XHQyzLZPlr7++PzdhaXEj94dEiJgZDTsxEqUI=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
-github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
 github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
-github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
-github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
-github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
-golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
-golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.0.0-20201016220609-9e8e0b390897/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.0.0-20201112155050-0c6587e931a9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
-golang.org/x/crypto v0.0.0-20220511200225-c6db032c6c88/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
-golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
-golang.org/x/crypto v0.13.0/go.mod h1:y6Z2r+Rw4iayiXXAIxJIDAJ1zMW4yaTpebo8fPOliYc=
-golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU=
-golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8=
-golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=
-golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=
-golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b h1:M2rDM6z3Fhozi9O7NWsxAkg/yqS/lQJ6PmkyIV3YP+o=
-golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b/go.mod h1:3//PLf8L/X+8b4vuAfHzxeRUl04Adcb341+IGKfnqS8=
-golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
-golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
-golang.org/x/mod v0.12.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
-golang.org/x/mod v0.15.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
-golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
-golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
-golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20201010224723-4f7140c49acb/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
-golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
-golang.org/x/net v0.0.0-20210610132358-84b48f89b13b/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
-golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
-golang.org/x/net v0.0.0-20220425223048-2871e0cb64e4/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
-golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
-golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
-golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
-golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk=
-golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
-golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM=
 golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=
 golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=
-golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.3.0/go.mod h1:FU7BRWz2tNW+3quACPkgCx/L+uEAv1htQ0V83Z9Rj+Y=
-golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
-golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
-golang.org/x/sync v0.9.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sync v0.15.0 h1:KWH3jNZsfyT6xfAfKiz6MRNmd46ByHDYaZ7KSkCtdW8=
 golang.org/x/sync v0.15.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
-golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20210616045830-e2b7044e8c71/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220224120231-95c6836cb0e7/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
-golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
-golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2/go.mod h1:TeRTkGYfJXctD9OcfyVLyj2J3IxLnKwHJR8f4D8a3YE=
-golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
-golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
-golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
-golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
-golang.org/x/term v0.12.0/go.mod h1:owVbMEjm3cBLCHdkQu9b1opXd4ETQWc3BhuQGKgXgvU=
-golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk=
-golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY=
-golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
-golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
-golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
-golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
-golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
-golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
-golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
-golang.org/x/text v0.20.0/go.mod h1:D4IsuqiFMhST5bX19pQ9ikHC2GsaKyk/oF+pn3ducp4=
 golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
 golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
-golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
-golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
-golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
-golang.org/x/tools v0.13.0/go.mod h1:HvlwmtVNQAhOuCjW7xxvovg8wbNq7LwfXh/k7wXUl58=
-golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
-golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/natefinch/npipe.v2 v2.0.0-20160621034901-c1b8fa8bdcce/go.mod h1:5AcXVHNjg+BDxry382+8OKon8SEWiKktQR07RKPsv1c=
-gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gorm.io/driver/mysql v1.6.0 h1:eNbLmNTpPpTOVZi8MMxCi2aaIm0ZpInbORNXDwyLGvg=
 gorm.io/driver/mysql v1.6.0/go.mod h1:D/oCC2GWK3M/dqoLxnOlaNKmXz8WNTfcS9y5ovaSqKo=
-gorm.io/driver/postgres v1.6.0 h1:2dxzU8xJ+ivvqTRph34QX+WrRaJlmfyPqXmoGVjMBa4=
-gorm.io/driver/postgres v1.6.0/go.mod h1:vUw0mrGgrTK+uPHEhAdV4sfFELrByKVGnaVRkXDhtWo=
-gorm.io/driver/sqlserver v1.6.0 h1:VZOBQVsVhkHU/NzNhRJKoANt5pZGQAS1Bwc6m6dgfnc=
-gorm.io/driver/sqlserver v1.6.0/go.mod h1:WQzt4IJo/WHKnckU9jXBLMJIVNMVeTu25dnOzehntWw=
 gorm.io/gorm v1.30.0 h1:qbT5aPv1UH8gI99OsRlvDToLxW5zR7FzS9acZDOZcgs=
 gorm.io/gorm v1.30.0/go.mod h1:8Z33v652h4//uMA76KjeDH8mJXPm1QNCYrMeatR0DOE=
-modernc.org/libc v1.66.2 h1:JCBxlJzZOIwZY54fzjHN3Wsn8Ty5PUTPr/xioRkmecI=
-modernc.org/libc v1.66.2/go.mod h1:ceIGzvXxP+JV3pgVjP9avPZo6Chlsfof2egXBH3YT5Q=
-modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
-modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
-modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=
-modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
-modernc.org/sqlite v1.38.0 h1:+4OrfPQ8pxHKuWG4md1JpR/EYAh3Md7TdejuuzE7EUI=
-modernc.org/sqlite v1.38.0/go.mod h1:1Bj+yES4SVvBZ4cBOpVZ6QgesMCKpJZDq0nxYzOpmNE=

install_goget.sh

@@ -9,12 +9,6 @@
 
 #mysql driver
 go get -u github.com/go-sql-driver/mysql
-#sqlite driver
-go get -u github.com/glebarez/sqlite
-#postgres driver
-go get -u gorm.io/driver/postgres
-#sqlserver driver
-go get -u "gorm.io/driver/sqlserver"
 #uuid
 go get github.com/google/uuid
 #gorm

main.go

@@ -24,8 +24,6 @@ import (
 	"time"
 )
 
-var ExitFlag bool = false
-
 func getMySqlDB() (*sql.DB, error) {
 	dsn := "root:Skyinno251,@tcp(47.242.184.139:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
 	db, err := sql.Open("mysql", dsn)
@@ -188,6 +186,7 @@ func dbTest() {
 	stmt.Exec(1)
 }
 
+
 // GenRsaKey generates an PKCS#1 RSA keypair of the given bit size in PEM format.
 func GenRsaKey(bits int) (prvkey, pubkey []byte, err error) {
 	// Generates private key.
@@ -216,6 +215,7 @@ func GenRsaKey(bits int) (prvkey, pubkey []byte, err error) {
 	return
 }
 
+
 func ParseRSAPrivateKeyFromPEM(pemData string) (*rsa.PrivateKey, error) {
 	var keyData = []byte(pemData)
 	// 解析PEM块
@@ -252,7 +252,7 @@ func parsePrivateKey(privateKeyFile string) (*rsa.PrivateKey, error) {
 	return privateKey, nil
 }
 
-// 生成RSA私钥和公钥，保存到文件中
+//生成RSA私钥和公钥，保存到文件中
 func GenerateRSAKey(bits int) {
 	//GenerateKey函数使用随机数据生成器random生成一对具有指定字位数的RSA密钥
 	//Reader是一个全局、共享的密码用强随机数生成器
@@ -403,7 +403,7 @@ func RsaEncryptBlock(src []byte, path string) (bytesEncrypt []byte, err error) {
 	// 读取公钥文件
 	keyData, err := ioutil.ReadFile(path)
 	if err != nil {
-		return nil, err
+		return nil,err
 	}
 
 	//pem解码
@@ -436,6 +436,7 @@ func RsaEncryptBlock(src []byte, path string) (bytesEncrypt []byte, err error) {
 	return
 }
 
+
 func timing(client mqtt.Client) {
 	//定时器，10秒钟执行一次
 	ticker := time.NewTicker(10 * time.Second)
@@ -474,6 +475,7 @@ func timing(client mqtt.Client) {
 			//fmt.Println("解密后的字符串：")
 			//fmt.Println(string(decrptCode))
 
+
 		}
 	}
 }
@@ -486,6 +488,7 @@ var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Me
 	fmt.Println(message)
 	fmt.Println(topic)
 
+
 	//privatePath := "/Users/edao/GolandProjects/go_mqtt/privateKey.pem"
 	privateKeyPEM := `-----BEGIN PRIVATE KEY-----
 MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL3dDf12MSeIY2jm5QpUSSoMhrJOWLbOt5fXQepPaNO0M30A+3C4SFZrM/9WA5ehazO1u1m1LAkYzoSDRH3MMJsrJC3lCGDeOROteu+safuP9k/npU1YQu/+Ll2xEJNxyvUx4jLGM4LamiMI6ytM3gdnOAGP4YRQo9Etwo6I986yg/seCQC5rza9M4iBamoin7U8h9yOMKrM6xK/k9CcY/vn5+Uhe3Pvk4qj/2Ff3OXkkc1wfdILqdLwLOKL0Tb3ZciwG0p1CKO80yf5hyYoWjqZk5Rcd07nTo2gqTFGfLl9sqI9/+ipMDtnHlAgMBAAECggEATJd5yCC6lusdMRO5FOBUyUaUi9X2i1AU+RZKAynQySvSnbavUgExW58tRCHBUrGW9gJp59ft1N8J8hHhSO18NDY4H7laBlVdnwmYjRqtFo2VQO6sD4G8JRDION5f2iIxn/b2fYDI9H8vILfJRbNgtTSILyGlzTYUZzhLKxCh+8IsN96Nic8wa5COd1vZZmdhf2y8TG8clFWmozaScNSAATx7y+8XLVWjjWiIRZ6xQvx0uQPUParc9KihXXTKR2pA22yPIdz+U4MGD4kC0eczlcFKZ/dYv9e7OIGgnJfT0idSCu7nYb1pxJ1LxD9fS6IScNTF5dSe0OIL98e+XdyoAQKBgQDRep+5cW4iAKrEMH+djmcXAkoMiYtNVtnu0efLE8dP6vjYytQi368X9SdcASbfrQ31eEZmr/xQnlUF8oyHGkI38YS8dpAHzQcrkP3BljbbzB/3gJZaUdghGsDrK0xAJIzzmFKQpeKnGtr23vxUgaGrNsCYvQ0eQ7+5056KXS4r5QKBgQC6r8xtRSaje6L4WIydjWvYywsmRO0Of0aJLMDA/Wt2MWhHfh7ba9oI1cKGN80ap7xB2a9lQLgpv+C53wNtE5SpvjxsikAj96nUMMhGy9ojXrUith6HQhiINETz6Shnznd+AyrXP6KI/RpfA5nkDB5nrJxODwtYLP467IL7Cv7OAQKBgQCl4KxKdH/5fP28jYsAgJsxpSZt9xzQCU5Zxu396ZOSvUaApVyGoQpNtluMh3z48lhzYOKevgzW6gn5w69z7F8zXZT2iAxVoQ1kelP2z7RxKJrHqpNkwhqbXEwX7RlcUZUr8BqxYCqymJl7k+fMIzqaEalBSbLxnEReKi0I8/Bz4QKBgHK4b0ZCtVDHPEmimJ6E9l4dv/c/afF7swu+zaCK2ouiJvOwBCRQbYb6XPR/u/GCXASXUdpF4CX/vIhcDE3uN2/r8FO+zVWM7vbvF1OyF5WesG7pPW9e5ZZlkG3WvLa1wOZV6fCmMSo/ZwI2Q05JSDHrd43cXttLotrw1jiQ9C4BAoGBAKi4SOoOVQ5J5HQCDkBwPbG1AOLHFinzfoDl26GF/8Hy7fmmd1JiRTFldQp/A9VTAABz3sVYmMB92HSIaJhuDMoYJNI2Cf/cZifsv7vUL8cbLn+lPsKsebiuB0m0g4P2qLwLfegfNGEgA7lA5HIz3SELqbdp3iuqJeQl1fsJqD74
@@ -499,6 +502,7 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 		}
 		//decrptCode := RSA_Decrypts(decodeByte, privatePath)
 
+
 		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
 
 		fmt.Println("解密后的字符串：")
@@ -510,11 +514,11 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 
 		if models.GetUser(&user) {
 			models.UpdateUser(&user)
-		} else {
+		}else{
 			models.SaveUser(&user)
 		}
 
-	} else if topic == "app_push_dyw" {
+	}else if topic == "app_push_dyw" {
 		fmt.Println("大亚湾电厂APP收到mqtt消息")
 		decodeByte, err := base64.StdEncoding.DecodeString(message)
 		if err != nil {
@@ -530,11 +534,11 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 
 		if models.GetUserdyw(&user) {
 			models.UpdateUserdyw(&user)
-		} else {
+		}else{
 			models.SaveUserdyw(&user)
 		}
 
-	} else if topic == "app_push_yf" {
+	}else if topic == "app_push_yf" {
 		fmt.Println("云浮电厂APP收到mqtt消息")
 		decodeByte, err := base64.StdEncoding.DecodeString(message)
 		if err != nil {
@@ -550,18 +554,16 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 
 		if models.GetUseryf(&user) {
 			models.UpdateUseryf(&user)
-		} else {
+		}else{
 			models.SaveUseryf(&user)
 		}
 
-	} else {
+	}else{
 		result := strings.Split(message, " ")
 		fmt.Println(result[0])
 		fmt.Println(result[1])
 
 		now := time.Now()
-		fmt.Println("---------now--------")
-		fmt.Println(now)
 		temperature := new(models.Temperature)
 		temperature.CreateDate = now
 		temperature.DataDate = now.Format("2006-01-02")
@@ -583,6 +585,9 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 		models.SaveTemperature(temperature)
 	}
 
+
+
+
 	//uuid := uuid.New()
 	//models.SaveProduct()
 	//models.SaveUser(uuid.String())
@@ -648,12 +653,7 @@ func subAppPushDyw(client mqtt.Client) {
 	token.Wait()
 	fmt.Printf("Subscribed to topic: %s", topic)
 }
-func subAppPushYf(client mqtt.Client) {
-	topic := "app_push_yf"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
+
 
 func publish(client mqtt.Client) {
 	num := 999999000000000000
@@ -666,7 +666,7 @@ func publish(client mqtt.Client) {
 	}
 }
 
-func main1() {
+func main() {
 
 	uuid := uuid.New()
 	fmt.Println("Generated UUID:", uuid)
@@ -694,12 +694,7 @@ func main1() {
 	subTemperature(client)
 	subAppPush(client)
 	subAppPushDyw(client)
-	subAppPushYf(client)
-	//publish(client)
-
-	for true {
-		time.Sleep(5 * time.Second)
-	}
+	publish(client)
 
 	//client.Disconnect(1000)
 

main_hwy.go

@@ -1,229 +0,0 @@
-package main
-
-import (
-	"encoding/base64"
-	"encoding/json"
-	"fmt"
-	mqtt "github.com/eclipse/paho.mqtt.golang"
-	"github.com/google/uuid"
-	"go_mqtt/models"
-	"strings"
-	"time"
-)
-
-func timing01(client mqtt.Client) {
-	//定时器，10秒钟执行一次
-	ticker := time.NewTicker(10 * time.Second)
-	for {
-		time := <-ticker.C
-		fmt.Println("定时器====>", time.String())
-		if !client.IsConnectionOpen() {
-			client.Connect()
-		} else {
-			fmt.Println("client has connect")
-		}
-	}
-}
-
-var messagePubHandler01 mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
-	fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
-
-	message := fmt.Sprintf("%s", msg.Payload())
-	topic := fmt.Sprintf("%s", msg.Topic())
-	fmt.Println(message)
-	fmt.Println(topic)
-
-	//privatePath := "/Users/edao/GolandProjects/go_mqtt/privateKey.pem"
-	privateKeyPEM := `-----BEGIN PRIVATE KEY-----
-MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL3dDf12MSeIY2jm5QpUSSoMhrJOWLbOt5fXQepPaNO0M30A+3C4SFZrM/9WA5ehazO1u1m1LAkYzoSDRH3MMJsrJC3lCGDeOROteu+safuP9k/npU1YQu/+Ll2xEJNxyvUx4jLGM4LamiMI6ytM3gdnOAGP4YRQo9Etwo6I986yg/seCQC5rza9M4iBamoin7U8h9yOMKrM6xK/k9CcY/vn5+Uhe3Pvk4qj/2Ff3OXkkc1wfdILqdLwLOKL0Tb3ZciwG0p1CKO80yf5hyYoWjqZk5Rcd07nTo2gqTFGfLl9sqI9/+ipMDtnHlAgMBAAECggEATJd5yCC6lusdMRO5FOBUyUaUi9X2i1AU+RZKAynQySvSnbavUgExW58tRCHBUrGW9gJp59ft1N8J8hHhSO18NDY4H7laBlVdnwmYjRqtFo2VQO6sD4G8JRDION5f2iIxn/b2fYDI9H8vILfJRbNgtTSILyGlzTYUZzhLKxCh+8IsN96Nic8wa5COd1vZZmdhf2y8TG8clFWmozaScNSAATx7y+8XLVWjjWiIRZ6xQvx0uQPUParc9KihXXTKR2pA22yPIdz+U4MGD4kC0eczlcFKZ/dYv9e7OIGgnJfT0idSCu7nYb1pxJ1LxD9fS6IScNTF5dSe0OIL98e+XdyoAQKBgQDRep+5cW4iAKrEMH+djmcXAkoMiYtNVtnu0efLE8dP6vjYytQi368X9SdcASbfrQ31eEZmr/xQnlUF8oyHGkI38YS8dpAHzQcrkP3BljbbzB/3gJZaUdghGsDrK0xAJIzzmFKQpeKnGtr23vxUgaGrNsCYvQ0eQ7+5056KXS4r5QKBgQC6r8xtRSaje6L4WIydjWvYywsmRO0Of0aJLMDA/Wt2MWhHfh7ba9oI1cKGN80ap7xB2a9lQLgpv+C53wNtE5SpvjxsikAj96nUMMhGy9ojXrUith6HQhiINETz6Shnznd+AyrXP6KI/RpfA5nkDB5nrJxODwtYLP467IL7Cv7OAQKBgQCl4KxKdH/5fP28jYsAgJsxpSZt9xzQCU5Zxu396ZOSvUaApVyGoQpNtluMh3z48lhzYOKevgzW6gn5w69z7F8zXZT2iAxVoQ1kelP2z7RxKJrHqpNkwhqbXEwX7RlcUZUr8BqxYCqymJl7k+fMIzqaEalBSbLxnEReKi0I8/Bz4QKBgHK4b0ZCtVDHPEmimJ6E9l4dv/c/afF7swu+zaCK2ouiJvOwBCRQbYb6XPR/u/GCXASXUdpF4CX/vIhcDE3uN2/r8FO+zVWM7vbvF1OyF5WesG7pPW9e5ZZlkG3WvLa1wOZV6fCmMSo/ZwI2Q05JSDHrd43cXttLotrw1jiQ9C4BAoGBAKi4SOoOVQ5J5HQCDkBwPbG1AOLHFinzfoDl26GF/8Hy7fmmd1JiRTFldQp/A9VTAABz3sVYmMB92HSIaJhuDMoYJNI2Cf/cZifsv7vUL8cbLn+lPsKsebiuB0m0g4P2qLwLfegfNGEgA7lA5HIz3SELqbdp3iuqJeQl1fsJqD74
------END PRIVATE KEY-----`
-
-	if topic == "app_push" {
-		fmt.Println("珠海电厂APP收到mqtt消息")
-		decodeByte, err := base64.StdEncoding.DecodeString(message)
-		if err != nil {
-			fmt.Println(err.Error())
-		}
-		//decrptCode := RSA_Decrypts(decodeByte, privatePath)
-
-		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
-
-		fmt.Println("解密后的字符串：")
-		fmt.Println(string(decrptCode))
-		fmt.Println("-----user--------")
-		var user models.User
-		json.Unmarshal(decrptCode, &user)
-		fmt.Println(user)
-
-		if models.GetUser(&user) {
-			models.UpdateUser(&user)
-		} else {
-			models.SaveUser(&user)
-		}
-
-	} else if topic == "app_push_dyw" {
-		fmt.Println("大亚湾电厂APP收到mqtt消息")
-		decodeByte, err := base64.StdEncoding.DecodeString(message)
-		if err != nil {
-			fmt.Println(err.Error())
-		}
-		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
-		fmt.Println("解密后的字符串：")
-		fmt.Println(string(decrptCode))
-		fmt.Println("-----userdyw--------")
-		var user models.Userdyw
-		json.Unmarshal(decrptCode, &user)
-		fmt.Println(user)
-
-		if models.GetUserdyw(&user) {
-			models.UpdateUserdyw(&user)
-		} else {
-			models.SaveUserdyw(&user)
-		}
-
-	} else if topic == "app_push_yf" {
-		fmt.Println("云浮电厂APP收到mqtt消息")
-		decodeByte, err := base64.StdEncoding.DecodeString(message)
-		if err != nil {
-			fmt.Println(err.Error())
-		}
-		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
-		fmt.Println("解密后的字符串：")
-		fmt.Println(string(decrptCode))
-		fmt.Println("-----userdyw--------")
-		var user models.Useryf
-		json.Unmarshal(decrptCode, &user)
-		fmt.Println(user)
-
-		if models.GetUseryf(&user) {
-			models.UpdateUseryf(&user)
-		} else {
-			models.SaveUseryf(&user)
-		}
-
-	} else {
-		result := strings.Split(message, " ")
-		fmt.Println(result[0])
-		fmt.Println(result[1])
-
-		now := time.Now()
-		fmt.Println("---------now--------")
-		fmt.Println(now)
-		temperature := new(models.Temperature)
-		temperature.CreateDate = now
-		temperature.DataDate = now.Format("2006-01-02")
-		temperature.DataHour = now.Format("2006-01-02 15")
-		temperature.DataMinute = now.Format("2006-01-02 15:04")
-		temperature.Humidity = result[0]
-		temperature.Temperature = result[1]
-		temperature.Topic = topic
-		if topic == "WifiSHT/7C87CE9CA4E6/SHT20" {
-			temperature.LocationDesc = "广东省珠海市高新区唐家湾镇东岸村水风三街28号501"
-		}
-		if topic == "WifiSHT/7C87CE9F5CBF/SHT20" {
-			temperature.LocationDesc = "广东省珠海市金湾区三灶镇百川路1号1栋1单元1508房"
-		}
-		if topic == "WifiSHT/4CEBD686B6AA/SHT20" {
-			temperature.LocationDesc = "广西壮族自治区崇左市天等县天等镇荣华村弄在屯113号"
-		}
-		fmt.Println("测温传感器地点:", temperature.LocationDesc)
-		models.SaveTemperature(temperature)
-	}
-
-	//uuid := uuid.New()
-	//models.SaveProduct()
-	//models.SaveUser(uuid.String())
-	//models.SaveOrder()
-
-	//var users []models.User
-	//var orders []models.Order
-	//var user models.User
-	//mydb.DB.Where("name = ?", "wenfei").First(&user)
-	//fmt.Println(user)
-
-	// 查询多条记录
-	//mydb.DB.Find(&users) // 查询所有产品信息
-	//mydb.DB.Order("id desc").Limit(2).Offset(0).Find(&users) // 按价格降序排序，取前 10 条记录
-	//fmt.Println("users:", users)
-
-	// 查询多条记录
-	//mydb.DB.Find(&users) // 查询所有产品信息
-	//mydb.DB.Where("id > ? and id < ?", 60,65).Find(&orders)
-	//fmt.Println("orders:", orders)
-
-	// 原生 SQL 查询
-	//var products []models.Product
-	//mydb.DB.Raw("SELECT * FROM product WHERE price > ?", 1000).Scan(&products) // 查询价格大于 1000 的产品信息
-	//fmt.Println("Products:", products)
-
-}
-
-var connectHandler01 mqtt.OnConnectHandler = func(client mqtt.Client) {
-	fmt.Println("Connected")
-	subTemperature01(client)
-	subAppPush01(client)
-	subAppPushDyw01(client)
-	subAppPushYf01(client)
-}
-
-var connectLostHandler01 mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
-	fmt.Printf("Connect lost: %v", err)
-}
-
-func subTemperature01(client mqtt.Client) {
-	topic := "WifiSHT/+/SHT20"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-
-func subAppPush01(client mqtt.Client) {
-	topic := "app_push"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-func subAppPushDyw01(client mqtt.Client) {
-	topic := "app_push_dyw"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-func subAppPushYf01(client mqtt.Client) {
-	topic := "app_push_yf"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-
-func main() {
-
-	uuid := uuid.New()
-	fmt.Println("Generated UUID:", uuid)
-
-	var broker = "mqtt.fileview123.com"
-	var port = 1883
-	opts := mqtt.NewClientOptions()
-	opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
-	opts.SetClientID(uuid.String())
-	opts.SetUsername("admin")
-	opts.SetPassword("publish452131wW452131wW$")
-	opts.SetDefaultPublishHandler(messagePubHandler01)
-	opts.OnConnect = connectHandler01
-	opts.OnConnectionLost = connectLostHandler01
-	client := mqtt.NewClient(opts)
-	if token := client.Connect(); token.Wait() && token.Error() != nil {
-		fmt.Println(token.Error())
-	}
-
-	go timing01(client)
-
-	subTemperature01(client)
-	subAppPush01(client)
-	subAppPushDyw01(client)
-	subAppPushYf01(client)
-
-	for true {
-		time.Sleep(5 * time.Second)
-	}
-}

models/User.go

@@ -8,17 +8,16 @@ import (
 )
 
 type User struct {
-	Username   string `gorm:"primaryKey;size:100"`
-	Password   string `gorm:"size:255"`
-	Date       string `gorm:"size:255"`
-	Imeinum    string `gorm:"size:50"`
-	Sysversion string `gorm:"size:100"`
-	Phonemodel string `gorm:"size:255"`
-	Appversion string `gorm:"size:255"`
-	Name       string `gorm:"size:255"`
+	Username     	string `gorm:"primaryKey;size:255"`
+	Password     	string `gorm:"size:255"`
+	Date     	 	string `gorm:"size:255"`
+	Imeinum     	string `gorm:"size:50"`
+	Sysversion   	string `gorm:"size:100"`
+	Phonemodel     	string `gorm:"size:255"`
+	Appversion 		string `gorm:"size:255"`
+	Name	 		string `gorm:"size:255"`
 }
-
-// Userdyw
+//Userdyw
 func init() {
 	fmt.Println("User init()")
 	mydb.DB.AutoMigrate(&User{})
@@ -41,15 +40,14 @@ func SaveUser(user *User) {
 func UpdateUser(item *User) {
 	fmt.Println("用户存在,更新操作")
 	var user User
-	//mydb.DB.First(&user, item.Username)
-	mydb.DB.Where("username = ?", item.Username).First(&user)
-	user.Password = item.Password
-	user.Date = item.Date
-	user.Imeinum = item.Imeinum
-	user.Sysversion = item.Sysversion
-	user.Phonemodel = item.Phonemodel
-	user.Appversion = item.Appversion
-	user.Name = item.Name
+	mydb.DB.First(&user, item.Username)
+	user.Password=item.Password
+	user.Date=item.Date
+	user.Imeinum=item.Imeinum
+	user.Sysversion=item.Sysversion
+	user.Phonemodel=item.Phonemodel
+	user.Appversion=item.Appversion
+	user.Name=item.Name
 	mydb.DB.Save(&user)
 }
 
@@ -57,8 +55,9 @@ func GetUser(item *User) bool {
 	var user User
 	//mydb.DB.First(&user, item.Username)
 
-	//result := mydb.DB.First(&user, item.Username).Error
-	result := mydb.DB.Where("username = ?", item.Username).First(&user).Error
+
+
+	result := mydb.DB.First(&user, item.Username).Error
 	fmt.Println("-----user---->>")
 	fmt.Println(user)
 

models/Userdyw.go

@@ -8,16 +8,16 @@ import (
 )
 
 type Userdyw struct {
-	Username   string `gorm:"primaryKey;size:100"`
-	Password   string `gorm:"size:255"`
-	Date       string `gorm:"size:255"`
-	Imeinum    string `gorm:"size:50"`
-	Sysversion string `gorm:"size:100"`
-	Phonemodel string `gorm:"size:255"`
-	Appversion string `gorm:"size:255"`
-	Name       string `gorm:"size:255"`
+	Username     	string `gorm:"primaryKey;size:255"`
+	Password     	string `gorm:"size:255"`
+	Date     	 	string `gorm:"size:255"`
+	Imeinum     	string `gorm:"size:50"`
+	Sysversion   	string `gorm:"size:100"`
+	Phonemodel     	string `gorm:"size:255"`
+	Appversion 		string `gorm:"size:255"`
+	Name	 		string `gorm:"size:255"`
 }
-
+//
 func init() {
 	fmt.Println("Userdyw init()")
 	mydb.DB.AutoMigrate(&Userdyw{})
@@ -40,16 +40,14 @@ func SaveUserdyw(user *Userdyw) {
 func UpdateUserdyw(item *Userdyw) {
 	fmt.Println("用户存在,更新操作")
 	var user Userdyw
-	//mydb.DB.First(&user, item.Username)
-	mydb.DB.Where("username = ?", item.Username).First(&user)
-
-	user.Password = item.Password
-	user.Date = item.Date
-	user.Imeinum = item.Imeinum
-	user.Sysversion = item.Sysversion
-	user.Phonemodel = item.Phonemodel
-	user.Appversion = item.Appversion
-	user.Name = item.Name
+	mydb.DB.First(&user, item.Username)
+	user.Password=item.Password
+	user.Date=item.Date
+	user.Imeinum=item.Imeinum
+	user.Sysversion=item.Sysversion
+	user.Phonemodel=item.Phonemodel
+	user.Appversion=item.Appversion
+	user.Name=item.Name
 	mydb.DB.Save(&user)
 }
 
@@ -57,8 +55,9 @@ func GetUserdyw(item *Userdyw) bool {
 	var user Userdyw
 	//mydb.DB.First(&user, item.Username)
 
-	//result := mydb.DB.First(&user, item.Username).Error
-	result := mydb.DB.Where("username = ?", item.Username).First(&user).Error
+
+
+	result := mydb.DB.First(&user, item.Username).Error
 	fmt.Println("-----user---->>")
 	fmt.Println(user)
 
@@ -75,3 +74,4 @@ func GetUserdyw(item *Userdyw) bool {
 	}
 	return false
 }
+

models/Useryf.go

@@ -1,20 +1,20 @@
 package models
 
 import (
-	"errors"
-	"fmt"
-	"go_mqtt/mydb"
-	"gorm.io/gorm"
+"errors"
+"fmt"
+"go_mqtt/mydb"
+"gorm.io/gorm"
 )
 
 type Useryf struct {
-	Username string `gorm:"primaryKey;size:100"`
-	Password string `gorm:"size:255"`
-	Date     string `gorm:"size:32"`
-	Nfc      string `gorm:"size:255"`
-	Name     string `gorm:"size:255"`
+	Username     	string `gorm:"primaryKey;size:255"`
+	Password     	string `gorm:"size:255"`
+	Date     	 	string `gorm:"size:32"`
+	Nfc     		string `gorm:"size:255"`
+	Name	 		string `gorm:"size:255"`
 }
-
+//
 func init() {
 	fmt.Println("Useryf init()")
 	mydb.DB.AutoMigrate(&Useryf{})
@@ -37,12 +37,11 @@ func SaveUseryf(user *Useryf) {
 func UpdateUseryf(item *Useryf) {
 	fmt.Println("用户存在,更新操作")
 	var user Useryf
-	//mydb.DB.First(&user, item.Username)
-	mydb.DB.Where("username = ?", item.Username).First(&user)
-	user.Password = item.Password
-	user.Date = item.Date
-	user.Name = item.Name
-	user.Nfc = item.Nfc
+	mydb.DB.First(&user, item.Username)
+	user.Password=item.Password
+	user.Date=item.Date
+	user.Name=item.Name
+	user.Nfc=item.Nfc
 	mydb.DB.Save(&user)
 }
 
@@ -50,8 +49,9 @@ func GetUseryf(item *Useryf) bool {
 	var user Useryf
 	//mydb.DB.First(&user, item.Username)
 
-	//result := mydb.DB.First(&user, item.Username).Error
-	result := mydb.DB.Where("username = ?", item.Username).First(&user).Error
+
+
+	result := mydb.DB.First(&user, item.Username).Error
 	fmt.Println("-----user---->>")
 	fmt.Println(user)
 
@@ -68,3 +68,4 @@ func GetUseryf(item *Useryf) bool {
 	}
 	return false
 }
+

mqtt/main_mqtt.go

@@ -1,390 +0,0 @@
-package mqtt
-
-import (
-	"bytes"
-	"crypto/rand"
-	"crypto/rsa"
-	"crypto/x509"
-	"encoding/base64"
-	"encoding/json"
-	"encoding/pem"
-	"fmt"
-	mqtt "github.com/eclipse/paho.mqtt.golang"
-	"github.com/google/uuid"
-	"go_mqtt/models"
-	"io/ioutil"
-	"log"
-	"os"
-	"strings"
-	"time"
-)
-
-// RSA_Decrypts RSA解密支持分段解密
-func RSA_Decrypts(cipherText []byte, path string) []byte {
-	//打开文件
-	var bytesDecrypt []byte
-	//file, err := os.Open(path)
-	//if err != nil {
-	//	fmt.Println(err)
-	//}
-	//
-	////获取文件内容
-	//info, _ := file.Stat()
-	//buf := make([]byte, info.Size())
-	//file.Read(buf)
-
-	// 读取私钥文件
-	keyData, err := ioutil.ReadFile(path)
-	if err != nil {
-		return nil
-	}
-
-	//pem解码
-	block, _ := pem.Decode(keyData)
-	//X509解码
-	privateKey, err := x509.ParsePKCS8PrivateKey(block.Bytes)
-	if err != nil {
-		fmt.Println(err.Error())
-		os.Exit(0)
-	}
-	p := privateKey.(*rsa.PrivateKey)
-	keySize := p.Size()
-	srcSize := len(cipherText)
-	log.Println("密钥长度", keySize, "密文长度", srcSize)
-	var offSet = 0
-	var buffer = bytes.Buffer{}
-	for offSet < srcSize {
-		endIndex := offSet + keySize
-		if endIndex > srcSize {
-			endIndex = srcSize
-		}
-		bytesOnce, err := rsa.DecryptPKCS1v15(rand.Reader, p, cipherText[offSet:endIndex])
-		if err != nil {
-			return nil
-		}
-		buffer.Write(bytesOnce)
-		offSet = endIndex
-	}
-	bytesDecrypt = buffer.Bytes()
-	return bytesDecrypt
-}
-
-// RSA_DecryptsOne RSA解密支持分段解密
-func RSA_DecryptsOne(cipherText []byte, privateKeyStr string) []byte {
-	//打开文件
-	var bytesDecrypt []byte
-	// 读取私钥文件转成字节数组
-	keyData := []byte(privateKeyStr)
-
-	//pem解码
-	block, _ := pem.Decode(keyData)
-	//X509解码
-	privateKey, err := x509.ParsePKCS8PrivateKey(block.Bytes)
-	if err != nil {
-		fmt.Println(err.Error())
-		os.Exit(0)
-	}
-	p := privateKey.(*rsa.PrivateKey)
-	keySize := p.Size()
-	srcSize := len(cipherText)
-	log.Println("密钥长度", keySize, "密文长度", srcSize)
-	var offSet = 0
-	var buffer = bytes.Buffer{}
-	for offSet < srcSize {
-		endIndex := offSet + keySize
-		if endIndex > srcSize {
-			endIndex = srcSize
-		}
-		bytesOnce, err := rsa.DecryptPKCS1v15(rand.Reader, p, cipherText[offSet:endIndex])
-		if err != nil {
-			return nil
-		}
-		buffer.Write(bytesOnce)
-		offSet = endIndex
-	}
-	bytesDecrypt = buffer.Bytes()
-	return bytesDecrypt
-}
-
-// RsaEncryptBlock 公钥加密-分段
-func RsaEncryptBlock(src []byte, path string) (bytesEncrypt []byte, err error) {
-	//打开文件
-	//file, err := os.Open(path)
-	//if err != nil {
-	//	return
-	//}
-	//
-	////读取文件的内容
-	//info, _ := file.Stat()
-	//buf := make([]byte, info.Size())
-	//file.Read(buf)
-
-	// 读取公钥文件
-	keyData, err := ioutil.ReadFile(path)
-	if err != nil {
-		return nil, err
-	}
-
-	//pem解码
-	block, _ := pem.Decode(keyData)
-	//x509解码
-	publicKeyInterface, err := x509.ParsePKIXPublicKey(block.Bytes)
-	if err != nil {
-		fmt.Println(err)
-	}
-	//类型断言
-	publicKey := publicKeyInterface.(*rsa.PublicKey)
-	keySize, srcSize := publicKey.Size(), len(src)
-	log.Println("密钥长度", keySize, "明文长度", srcSize)
-	offSet, once := 0, keySize-11
-	buffer := bytes.Buffer{}
-	for offSet < srcSize {
-		endIndex := offSet + once
-		if endIndex > srcSize {
-			endIndex = srcSize
-		}
-		// 加密一部分
-		bytesOnce, err := rsa.EncryptPKCS1v15(rand.Reader, publicKey, src[offSet:endIndex])
-		if err != nil {
-			return nil, err
-		}
-		buffer.Write(bytesOnce)
-		offSet = endIndex
-	}
-	bytesEncrypt = buffer.Bytes()
-	return
-}
-
-func timing(client mqtt.Client) {
-	//定时器，10秒钟执行一次
-	ticker := time.NewTicker(10 * time.Second)
-	for {
-		time := <-ticker.C
-		fmt.Println("定时器====>", time.String())
-		if !client.IsConnectionOpen() {
-			client.Connect()
-		} else {
-			fmt.Println("client has connect")
-		}
-	}
-}
-
-var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
-	fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
-
-	message := fmt.Sprintf("%s", msg.Payload())
-	topic := fmt.Sprintf("%s", msg.Topic())
-	fmt.Println(message)
-	fmt.Println(topic)
-
-	//privatePath := "/Users/edao/GolandProjects/go_mqtt/privateKey.pem"
-	privateKeyPEM := `-----BEGIN PRIVATE KEY-----
-MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL3dDf12MSeIY2jm5QpUSSoMhrJOWLbOt5fXQepPaNO0M30A+3C4SFZrM/9WA5ehazO1u1m1LAkYzoSDRH3MMJsrJC3lCGDeOROteu+safuP9k/npU1YQu/+Ll2xEJNxyvUx4jLGM4LamiMI6ytM3gdnOAGP4YRQo9Etwo6I986yg/seCQC5rza9M4iBamoin7U8h9yOMKrM6xK/k9CcY/vn5+Uhe3Pvk4qj/2Ff3OXkkc1wfdILqdLwLOKL0Tb3ZciwG0p1CKO80yf5hyYoWjqZk5Rcd07nTo2gqTFGfLl9sqI9/+ipMDtnHlAgMBAAECggEATJd5yCC6lusdMRO5FOBUyUaUi9X2i1AU+RZKAynQySvSnbavUgExW58tRCHBUrGW9gJp59ft1N8J8hHhSO18NDY4H7laBlVdnwmYjRqtFo2VQO6sD4G8JRDION5f2iIxn/b2fYDI9H8vILfJRbNgtTSILyGlzTYUZzhLKxCh+8IsN96Nic8wa5COd1vZZmdhf2y8TG8clFWmozaScNSAATx7y+8XLVWjjWiIRZ6xQvx0uQPUParc9KihXXTKR2pA22yPIdz+U4MGD4kC0eczlcFKZ/dYv9e7OIGgnJfT0idSCu7nYb1pxJ1LxD9fS6IScNTF5dSe0OIL98e+XdyoAQKBgQDRep+5cW4iAKrEMH+djmcXAkoMiYtNVtnu0efLE8dP6vjYytQi368X9SdcASbfrQ31eEZmr/xQnlUF8oyHGkI38YS8dpAHzQcrkP3BljbbzB/3gJZaUdghGsDrK0xAJIzzmFKQpeKnGtr23vxUgaGrNsCYvQ0eQ7+5056KXS4r5QKBgQC6r8xtRSaje6L4WIydjWvYywsmRO0Of0aJLMDA/Wt2MWhHfh7ba9oI1cKGN80ap7xB2a9lQLgpv+C53wNtE5SpvjxsikAj96nUMMhGy9ojXrUith6HQhiINETz6Shnznd+AyrXP6KI/RpfA5nkDB5nrJxODwtYLP467IL7Cv7OAQKBgQCl4KxKdH/5fP28jYsAgJsxpSZt9xzQCU5Zxu396ZOSvUaApVyGoQpNtluMh3z48lhzYOKevgzW6gn5w69z7F8zXZT2iAxVoQ1kelP2z7RxKJrHqpNkwhqbXEwX7RlcUZUr8BqxYCqymJl7k+fMIzqaEalBSbLxnEReKi0I8/Bz4QKBgHK4b0ZCtVDHPEmimJ6E9l4dv/c/afF7swu+zaCK2ouiJvOwBCRQbYb6XPR/u/GCXASXUdpF4CX/vIhcDE3uN2/r8FO+zVWM7vbvF1OyF5WesG7pPW9e5ZZlkG3WvLa1wOZV6fCmMSo/ZwI2Q05JSDHrd43cXttLotrw1jiQ9C4BAoGBAKi4SOoOVQ5J5HQCDkBwPbG1AOLHFinzfoDl26GF/8Hy7fmmd1JiRTFldQp/A9VTAABz3sVYmMB92HSIaJhuDMoYJNI2Cf/cZifsv7vUL8cbLn+lPsKsebiuB0m0g4P2qLwLfegfNGEgA7lA5HIz3SELqbdp3iuqJeQl1fsJqD74
------END PRIVATE KEY-----`
-
-	if topic == "app_push" {
-		fmt.Println("珠海电厂APP收到mqtt消息")
-		decodeByte, err := base64.StdEncoding.DecodeString(message)
-		if err != nil {
-			fmt.Println(err.Error())
-		}
-		//decrptCode := RSA_Decrypts(decodeByte, privatePath)
-
-		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
-
-		fmt.Println("解密后的字符串：")
-		fmt.Println(string(decrptCode))
-		fmt.Println("-----user--------")
-		var user models.User
-		json.Unmarshal(decrptCode, &user)
-		fmt.Println(user)
-
-		if models.GetUser(&user) {
-			models.UpdateUser(&user)
-		} else {
-			models.SaveUser(&user)
-		}
-
-	} else if topic == "app_push_dyw" {
-		fmt.Println("大亚湾电厂APP收到mqtt消息")
-		decodeByte, err := base64.StdEncoding.DecodeString(message)
-		if err != nil {
-			fmt.Println(err.Error())
-		}
-		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
-		fmt.Println("解密后的字符串：")
-		fmt.Println(string(decrptCode))
-		fmt.Println("-----userdyw--------")
-		var user models.Userdyw
-		json.Unmarshal(decrptCode, &user)
-		fmt.Println(user)
-
-		if models.GetUserdyw(&user) {
-			models.UpdateUserdyw(&user)
-		} else {
-			models.SaveUserdyw(&user)
-		}
-
-	} else if topic == "app_push_yf" {
-		fmt.Println("云浮电厂APP收到mqtt消息")
-		decodeByte, err := base64.StdEncoding.DecodeString(message)
-		if err != nil {
-			fmt.Println(err.Error())
-		}
-		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
-		fmt.Println("解密后的字符串：")
-		fmt.Println(string(decrptCode))
-		fmt.Println("-----userdyw--------")
-		var user models.Useryf
-		json.Unmarshal(decrptCode, &user)
-		fmt.Println(user)
-
-		if models.GetUseryf(&user) {
-			models.UpdateUseryf(&user)
-		} else {
-			models.SaveUseryf(&user)
-		}
-
-	} else {
-		result := strings.Split(message, " ")
-		fmt.Println(result[0])
-		fmt.Println(result[1])
-
-		now := time.Now()
-		fmt.Println("---------now--------")
-		fmt.Println(now)
-		temperature := new(models.Temperature)
-		temperature.CreateDate = now
-		temperature.DataDate = now.Format("2006-01-02")
-		temperature.DataHour = now.Format("2006-01-02 15")
-		temperature.DataMinute = now.Format("2006-01-02 15:04")
-		temperature.Humidity = result[0]
-		temperature.Temperature = result[1]
-		temperature.Topic = topic
-		if topic == "WifiSHT/7C87CE9CA4E6/SHT20" {
-			temperature.LocationDesc = "广东省珠海市高新区唐家湾镇东岸村水风三街28号501"
-		}
-		if topic == "WifiSHT/7C87CE9F5CBF/SHT20" {
-			temperature.LocationDesc = "广东省珠海市金湾区三灶镇百川路1号1栋1单元1508房"
-		}
-		if topic == "WifiSHT/4CEBD686B6AA/SHT20" {
-			temperature.LocationDesc = "广西壮族自治区崇左市天等县天等镇荣华村弄在屯113号"
-		}
-		fmt.Println("测温传感器地点:", temperature.LocationDesc)
-		models.SaveTemperature(temperature)
-	}
-
-	//uuid := uuid.New()
-	//models.SaveProduct()
-	//models.SaveUser(uuid.String())
-	//models.SaveOrder()
-
-	//var users []models.User
-	//var orders []models.Order
-	//var user models.User
-	//mydb.DB.Where("name = ?", "wenfei").First(&user)
-	//fmt.Println(user)
-
-	// 查询多条记录
-	//mydb.DB.Find(&users) // 查询所有产品信息
-	//mydb.DB.Order("id desc").Limit(2).Offset(0).Find(&users) // 按价格降序排序，取前 10 条记录
-	//fmt.Println("users:", users)
-
-	// 查询多条记录
-	//mydb.DB.Find(&users) // 查询所有产品信息
-	//mydb.DB.Where("id > ? and id < ?", 60,65).Find(&orders)
-	//fmt.Println("orders:", orders)
-
-	// 原生 SQL 查询
-	//var products []models.Product
-	//mydb.DB.Raw("SELECT * FROM product WHERE price > ?", 1000).Scan(&products) // 查询价格大于 1000 的产品信息
-	//fmt.Println("Products:", products)
-
-}
-
-var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
-	fmt.Println("Connected")
-	subTemperature(client)
-	subAppPush(client)
-	subAppPushDyw(client)
-}
-
-var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
-	fmt.Printf("Connect lost: %v", err)
-}
-
-func sub(client mqtt.Client) {
-	topic := "gomqtt01"
-	token := client.Subscribe(topic, 1, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-
-func subTemperature(client mqtt.Client) {
-	topic := "WifiSHT/+/SHT20"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-
-func subAppPush(client mqtt.Client) {
-	topic := "app_push"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-func subAppPushDyw(client mqtt.Client) {
-	topic := "app_push_dyw"
-	token := client.Subscribe(topic, 2, nil)
-	token.Wait()
-	fmt.Printf("Subscribed to topic: %s", topic)
-}
-
-func publish(client mqtt.Client) {
-	num := 999999000000000000
-	for i := 0; i < num; i++ {
-		text := fmt.Sprintf("Message %d", i)
-		token := client.Publish("gomqtt01", 0, false, text)
-		token.Wait()
-		fmt.Println(i)
-		time.Sleep(6 * time.Second)
-	}
-}
-
-func main() {
-
-	uuid := uuid.New()
-	fmt.Println("Generated UUID:", uuid)
-
-	var broker = "47.242.184.139"
-	var port = 1883
-	opts := mqtt.NewClientOptions()
-	opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
-	opts.SetClientID(uuid.String())
-	opts.SetUsername("admin")
-	opts.SetPassword("publish452131wW452131wW$")
-	opts.SetDefaultPublishHandler(messagePubHandler)
-	opts.OnConnect = connectHandler
-	opts.OnConnectionLost = connectLostHandler
-	client := mqtt.NewClient(opts)
-	if token := client.Connect(); token.Wait() && token.Error() != nil {
-		fmt.Println(token.Error())
-	}
-
-	//client.IsConnectionOpen()
-
-	go timing(client)
-
-	//sub(client)
-	subTemperature(client)
-	subAppPush(client)
-	subAppPushDyw(client)
-	//publish(client)
-
-	for true {
-		time.Sleep(5 * time.Second)
-	}
-
-	//client.Disconnect(1000)
-
-}

mydb/initialize.go

@@ -2,17 +2,14 @@ package mydb
 
 import (
 	"fmt"
-	//"gorm.io/driver/postgres"
-
-	"gorm.io/driver/postgres"
-
+	"gorm.io/driver/mysql"
 	"gorm.io/gorm"
 	"log"
 	"time"
 )
 
 func init() {
-	fmt.Println("db init()")
+	fmt.Println("mydb init()")
 	initDatabase()
 }
 
@@ -20,37 +17,22 @@ var DB *gorm.DB
 
 func initDatabase() {
 
-	//mysql
-	//dsn := "root:Skyinno251,@tcp(192.168.2.25:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
+	//dsn := "root:Skyinno251,@tcp(192.168.2.18:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
 	//dsn := "root:Skyinno251,@tcp(47.242.184.139:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
 	//dsn := "root:Skyinno251,@tcp(localhost:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
-	//dsn := "root:Skyinno251,@tcp(192.168.3.9:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
+	dsn := "root:Skyinno251,@tcp(192.168.3.9:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
 	//dsn := "root:Skyinno251,@tcp(localhost:3306)/go_mqtt?charset=utf8mb4&parseTime=True&loc=Local"
 
-	//db, err := gorm.Open(mysql.New(mysql.Config{
-	//	DSN:                       dsn,   // DSN data source name
-	//	DefaultStringSize:         255,   // string 类型字段的默认长度
-	//	DisableDatetimePrecision:  true,  // 禁用 datetime 精度，MySQL 5.6 之前的数据库不支持
-	//	DontSupportRenameIndex:    true,  // 重命名索引时采用删除并新建的方式，MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引
-	//	DontSupportRenameColumn:   true,  // 用 `change` 重命名列，MySQL 8 之前的数据库和 MariaDB 不支持重命名列
-	//	SkipInitializeWithVersion: false, // 根据当前 MySQL 版本自动配置
-	//}), &gorm.Config{})
-	//db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
-
-	//sqlite
-	//db, err := gorm.Open(sqlite.Open("/media/cat/sd/home/cat/go_mqtt/go_mqtt.db"), &gorm.Config{})
-	//db, err := gorm.Open(sqlite.Open("go_mqtt.db"), &gorm.Config{})
-
-	//postgres
-	//3.30: 10.19.1.219   3.29:10.19.1.154  localhost
-	//dsn := "host=localhost user=postgres password=452131wW dbname=postgres port=5432 sslmode=disable"
-	dsn := "host=192.168.2.25 user=postgres password=452131wW dbname=weather port=5432 sslmode=disable"
-	db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
-
-	//sqlserver
-	//dsn := "sqlserver://sa:452131wW@192.168.3.29:1433?database=go_mqtt"
-	//db, err := gorm.Open(sqlserver.Open(dsn), &gorm.Config{})
+	db, err := gorm.Open(mysql.New(mysql.Config{
+		DSN:                       dsn,   // DSN data source name
+		DefaultStringSize:         255,   // string 类型字段的默认长度
+		DisableDatetimePrecision:  true,  // 禁用 datetime 精度，MySQL 5.6 之前的数据库不支持
+		DontSupportRenameIndex:    true,  // 重命名索引时采用删除并新建的方式，MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引
+		DontSupportRenameColumn:   true,  // 用 `change` 重命名列，MySQL 8 之前的数据库和 MariaDB 不支持重命名列
+		SkipInitializeWithVersion: false, // 根据当前 MySQL 版本自动配置
+	}), &gorm.Config{})
 
+	//db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
 	if err != nil {
 		fmt.Println("failed to connect database")
 	}