首页

使用MqttNet自建mqtt服务端(broker)并实现客户端发布订阅消息 入门级示例源码

c#

2021-1-6

本示例主要实现了以下三点:

1. 自建了mqtt 服务端(broker),并可以接收客户端发来的各种topic

2. 实现了客户端发布订阅mqtt消息

3. 实现了 服务端直接向外广播topic,客户端只需要 订阅该topic即可

调试步骤如下:

1. 运行>>cmd>>  cd 至 MQTTnet.TestApp.AspNetCore2 目录,并执行 dotnet run

2. 浏览器输入 http://localhost:5000 即可看到如下截图,浏览器输入 http://localhost:5000/publish 即可通过服务端发布topic

资源下载此资源下载价格为2D币(VIP免费),请先
资源文件列表
.vs/MQTTnet.TestApp.AspNetCore2/DesignTimeBuild/.dtbcache , 1206588
.vs/MQTTnet.TestApp.AspNetCore2/v15/.suo , 50688
.vs/MQTTnet.TestApp.AspNetCore2/v15/Server/sqlite3/db.lock , 0
.vs/MQTTnet.TestApp.AspNetCore2/v15/Server/sqlite3/storage.ide , 1945600
.vs/MQTTnet.TestApp.AspNetCore2/v15/Server/sqlite3/storage.ide-shm , 32768
.vs/MQTTnet.TestApp.AspNetCore2/v15/Server/sqlite3/storage.ide-wal , 4140632
.vs/config/applicationhost.config , 80097
MQTTnet.TestApp.AspNetCore2.csproj , 611
MQTTnet.TestApp.AspNetCore2.csproj.user , 409
MQTTnet.TestApp.AspNetCore2.sln , 1152
Program.cs , 640
Properties/launchSettings.json , 665
Startup.cs , 3905
bin/Debug/netcoreapp2.1/MQTTnet.TestApp.AspNetCore2.deps.json , 241734
bin/Debug/netcoreapp2.1/MQTTnet.TestApp.AspNetCore2.dll , 13312
bin/Debug/netcoreapp2.1/MQTTnet.TestApp.AspNetCore2.pdb , 1872
bin/Debug/netcoreapp2.1/MQTTnet.TestApp.AspNetCore2.runtimeconfig.dev.json , 252
bin/Debug/netcoreapp2.1/MQTTnet.TestApp.AspNetCore2.runtimeconfig.json , 224
node_modules/.bin/leven , 264
node_modules/.bin/leven.cmd , 172
node_modules/.bin/mqtt , 264
node_modules/.bin/mqtt.cmd , 172
node_modules/.bin/mqtt_pub , 270
node_modules/.bin/mqtt_pub.cmd , 178
node_modules/.bin/mqtt_sub , 270
node_modules/.bin/mqtt_sub.cmd , 178
node_modules/.bin/tsc , 276
node_modules/.bin/tsc.cmd , 184
node_modules/.bin/tsserver , 286
node_modules/.bin/tsserver.cmd , 194
node_modules/@types/node/LICENSE , 1183
node_modules/@types/node/README.md , 1308
node_modules/@types/node/index.d.ts , 348594
node_modules/@types/node/inspector.d.ts , 103577
node_modules/@types/node/package.json , 3506
node_modules/async-limiter/.travis.yml , 89
node_modules/async-limiter/LICENSE , 1107
node_modules/async-limiter/coverage/coverage.json , 4959
node_modules/async-limiter/coverage/lcov-report/async-throttle/index.html , 3222
node_modules/async-limiter/coverage/lcov-report/async-throttle/index.js.html , 6569
node_modules/async-limiter/coverage/lcov-report/base.css , 4756
node_modules/async-limiter/coverage/lcov-report/index.html , 3161
node_modules/async-limiter/coverage/lcov-report/prettify.css , 676
node_modules/async-limiter/coverage/lcov-report/prettify.js , 17569
node_modules/async-limiter/coverage/lcov-report/sort-arrow-sprite.png , 209
node_modules/async-limiter/coverage/lcov-report/sorter.js , 5041
node_modules/async-limiter/coverage/lcov.info , 867
node_modules/async-limiter/index.js , 1234
node_modules/async-limiter/package.json , 2822
node_modules/async-limiter/readme.md , 3374
node_modules/balanced-match/.npmignore , 48
node_modules/balanced-match/LICENSE.md , 1096
node_modules/balanced-match/README.md , 3308
node_modules/balanced-match/index.js , 1174
node_modules/balanced-match/package.json , 2770
node_modules/bl/.jshintrc , 1147
node_modules/bl/.travis.yml , 198
node_modules/bl/LICENSE.md , 1216
node_modules/bl/README.md , 10820
node_modules/bl/bl.js , 6400
node_modules/bl/package.json , 2642
node_modules/bl/test/test.js , 17556
node_modules/brace-expansion/LICENSE , 1096
node_modules/brace-expansion/README.md , 4058
node_modules/brace-expansion/index.js , 4792
node_modules/brace-expansion/package.json , 3040
node_modules/buffer-from/LICENSE , 1078
node_modules/buffer-from/index.js , 1595
node_modules/buffer-from/package.json , 3268
node_modules/buffer-from/readme.md , 1990
node_modules/callback-stream/.jshintrc , 1162
node_modules/callback-stream/.npmignore , 76
node_modules/callback-stream/.travis.yml , 46
node_modules/callback-stream/README.md , 2670
node_modules/callback-stream/index.js , 1010
node_modules/callback-stream/package.json , 2395
node_modules/callback-stream/test.js , 1542
node_modules/commist/.npmignore , 535
node_modules/commist/LICENSE , 1081
node_modules/commist/README.md , 1123
node_modules/commist/example.js , 548
node_modules/commist/index.js , 3322
node_modules/commist/package.json , 2052
node_modules/commist/test.js , 3964
node_modules/concat-map/.travis.yml , 43
node_modules/concat-map/LICENSE , 1073
node_modules/concat-map/README.markdown , 1165
node_modules/concat-map/example/map.js , 171
node_modules/concat-map/index.js , 345
node_modules/concat-map/package.json , 2369
node_modules/concat-map/test/map.js , 1075
node_modules/concat-stream/LICENSE , 1084
node_modules/concat-stream/index.js , 3775
node_modules/concat-stream/package.json , 3082
node_modules/concat-stream/readme.md , 3510
node_modules/core-util-is/LICENSE , 1077
node_modules/core-util-is/README.md , 67
node_modules/core-util-is/float.patch , 16278
node_modules/core-util-is/lib/util.js , 3021
node_modules/core-util-is/package.json , 2180
node_modules/core-util-is/test.js , 2101
node_modules/duplexify/.travis.yml , 65
node_modules/duplexify/LICENSE , 1078
node_modules/duplexify/README.md , 2698
node_modules/duplexify/example.js , 370
node_modules/duplexify/index.js , 5861
node_modules/duplexify/package.json , 3560
node_modules/duplexify/test.js , 6041
node_modules/end-of-stream/LICENSE , 1078
node_modules/end-of-stream/README.md , 1570
node_modules/end-of-stream/index.js , 2493
node_modules/end-of-stream/package.json , 2489
node_modules/extend/.editorconfig , 286
node_modules/extend/.eslintrc , 397
node_modules/extend/.jscs.json , 4096
node_modules/extend/.travis.yml , 6899
node_modules/extend/CHANGELOG.md , 2779
node_modules/extend/LICENSE , 1081
node_modules/extend/README.md , 3034
node_modules/extend/component.json , 581
node_modules/extend/index.js , 3321
node_modules/extend/package.json , 3880
node_modules/fs.realpath/LICENSE , 2125
node_modules/fs.realpath/README.md , 881
node_modules/fs.realpath/index.js , 1308
node_modules/fs.realpath/old.js , 8542
node_modules/fs.realpath/package.json , 2269
node_modules/glob/LICENSE , 765
node_modules/glob/README.md , 14664
node_modules/glob/changelog.md , 1430
node_modules/glob/common.js , 6167
node_modules/glob/glob.js , 19433
node_modules/glob/package.json , 3707
node_modules/glob/sync.js , 12002
node_modules/glob-parent/LICENSE , 747
node_modules/glob-parent/README.md , 3569
node_modules/glob-parent/index.js , 763
node_modules/glob-parent/package.json , 2566
node_modules/glob-stream/LICENSE , 1169
node_modules/glob-stream/README.md , 4488
node_modules/glob-stream/index.js , 2365
node_modules/glob-stream/package.json , 3484
node_modules/glob-stream/readable.js , 2684
node_modules/help-me/.npmignore , 587
node_modules/help-me/.travis.yml , 102
node_modules/help-me/LICENSE , 1082
node_modules/help-me/README.md , 868
node_modules/help-me/doc/hello.txt , 20
node_modules/help-me/doc/help.txt , 6
node_modules/help-me/example.js , 156
node_modules/help-me/fixture/basic/hello.txt , 12
最多只能显示150条信息!
没有账号? 忘记密码?

社交账号快速登录