iOS开发 mqtt怎么使用ssl加密?

ios开发的时候要用到ssl mqtt 加密 但是一直连接不上 ,有没有有经验的大神 可以指点一下

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
关于java通过ssl连接mqtt

我这边java在没有通过ssl连接mqtt的时候是可以连接的(可以订阅与发布), 但是通过ssl就不行了,发现是读取证书的时候出错了,错误是这样的: java.security.cert.CertificateException: Unable to initialize, java.io.IOException: extra data given to DerValue constructor at sun.security.x509.X509CertImpl.<init>(Unknown Source) at sun.security.provider.X509Factory.engineGenerateCertificate(Unknown Source) at java.security.cert.CertificateFactory.generateCertificate(Unknown Source) at com.test.mqtt.AppTest.main(AppTest.java:51) Caused by: java.io.IOException: extra data given to DerValue constructor at sun.security.util.DerValue.init(Unknown Source) at sun.security.util.DerValue.<init>(Unknown Source) at sun.security.util.DerValue.<init>(Unknown Source) ... 4 more 具体代码是: CertificateFactory cf; try { cf = CertificateFactory.getInstance("X.509"); FileInputStream crtIn = new FileInputStream("D:\\test\\client.crt"); X509Certificate caCert = (X509Certificate) cf.generateCertificate(crtIn); //Certificate caCert = cf.generateCertificate(crtIn); crtIn.close(); } catch (CertificateException e) { // TODO Auto-generated catch block e.printStackTrace(); }

MQTT TLS加密传输证书验证不过去。

嵌入式设备客户端: ./mosquitto_sub -h 172.22.50.2 -u sub_client -P 123456 -p 8883 -t hh --cafile ./ca.crt --tls-version tlsv1 linux服务器: mosquitto -c ./mosquitto.conf -v mosquitto.conf ``` pid_file /var/run/mosquitto.pid persistence true persistence_location /var/lib/mosquitto/ port 8883 cafile /etc/mosquitto/myca/ca.crt certfile /etc/mosquitto/myca/server.crt keyfile /etc/mosquitto/myca/server.key tls_version tlsv1 `` 服务器报错: ``` 1552620704: OpenSSL Error: error:1409441B:SSL routines:SSL3_READ_BYTES:tlsv1 alert decrypt error 1552620704: OpenSSL Error: error:140940E5:SSL routines:SSL3_READ_BYTES:ssl handshake failure ```

RabbitMQ 插件MQTT使用

如何开MQTT的SSL连接,Java如何使用 RabbitMQ如何开启SSL连接,并进行使用

rabbitmq mqtt adapter 没办法做ssl证书验证

rabbitmq mqtt adapter 没办法做ssl证书验证,客户端用证书一直连接不上,不知道哪位有这方面经验?

RabbitMQ 插件MQTT使用 mqtt需要大量连接设备 for Java

RabbitMQ 插件MQTT使用 mqtt需要大量连接设备 for Java 使用RabbitMQ作为mqtt的服务器,如何管理mqtt创建大量连接进行发布与订阅消息。(云端服务器)设备与云端服务器建立长连接

急急急,QT 官方自带SSL/TLS当用ip地址的时候认证不成功

``` Client(const QHostAddress& host = QHostAddress::LocalHost, const quint16 port = 1883, QObject* parent = NULL); #ifndef QT_NO_SSL Client(const QString& hostName, const quint16 port, const QSslConfiguration& config, const bool ignoreSelfSigned=false, QObject* parent = NULL); #endif // QT_NO_SSL 这个是官网自带的MQTT,可以好清楚看到,当使用SSL认证的时候,是用QString& hostName,如果不用SSL认证就是用const QHostAddress& host; 这里有一个参考使用方法http://www.mamicode.com/info-detail-2597790.html,大概是这样子的, QSslConfiguration sslConfig = QSslConfiguration::defaultConfiguration(); // Add custom SSL options here (for example extra certificates) QMQTT::Client *client = new QMQTT::Client("example.com", 8883, sslConfig); client->setClientId("clientId"); client->setUsername("user"); client->setPassword("password"); client->connectToHost(); 可以看到,这是用了.com的域名的,现在有一个MQTT的服务器,同事给了我ip和port,有帐户名和密码,还有ca证书,pem格式的,我把实例中的example.com用ip代替,发现是连接不上的,现在我的问题是,我有ip地址,port,帐户密码,ca证书,怎么才能通过ssl认证连接上MQTT服务器 ```

使用PHP在Laravel上使用mqtt

<div class="post-text" itemprop="text"> <p>I'm using the MQTT on my raspberry and on my Ubuntu. I use terminal for start subscriber and publisher and it works so good. But now I want to create a website (using laravel) with this features. I googled it, but I don't find anything interesting. Is it possible to do and how?</p> </div>

mqtt使用线程开启多个服务器发布数据 并实现多个客户端的订阅

mqtt使用线程开启多个服务器发布数据 并实现多个客户端的订阅

MQTT 请求/响应模式的使用。

在使用MQTT协议的过程中需用到请求/响应模式,在MQTT5.0新特性中新增了Request/Response模式,但未找到测试程序,不知哪位大神用过这个模式阿,能否给一份测试代码,感激不尽! 目的是实现A向B发一条指令,B根据这个条指令回复一条信息,有类似的程序都可以啊。还要求只能是C语言的程序。 编程能力较弱,可能问题提问比较菜,希望各位大神帮帮忙啊。 各位大神,帮帮孩子吧

mqtt和activemq有哪些共同点和区别

本人刚接触mqtt,看网上的例子发现mqtt的demo可以不使用消息队列,那如果 不使用消息队列,那mqtt与消息队列有什么区别呢? 或者如果只使用消息队列,不使用mqtt,那是不是也可以呢?

adnroid 开发编译mqtt报错

android studio 下载并打开paho.mqtt.android 编译报错,我的gradle版本4.4 as版本3.1.3 下载地址https://github.com/eclipse/paho.mqtt.android 直接git到的原始的项目,打开编译就报错,我本地新建空内容项目都能编译成功,adnroid 开发编译mqtt报错× 报错如下: Cannot create variant 'android-lint' after configuration ':org.eclipse.paho.android.service:debugRuntimeElements' has been resolved ![图片说明](https://img-ask.csdn.net/upload/201808/10/1533894738_767361.png) org.gradle.initialization.ReportedException: org.gradle.internal.exceptions.LocationAwareException: A problem occurred configuring project ':org.eclipse.paho.android.service'. at org.gradle.initialization.DefaultGradleLauncher.doBuildStages(DefaultGradleLauncher.java:139) at org.gradle.initialization.DefaultGradleLauncher.executeTasks(DefaultGradleLauncher.java:109) at org.gradle.internal.invocation.GradleBuildController$1.call(GradleBuildController.java:78) at org.gradle.internal.invocation.GradleBuildController$1.call(GradleBuildController.java:75) at org.gradle.internal.work.DefaultWorkerLeaseService.withLocks(DefaultWorkerLeaseService.java:152) at org.gradle.internal.invocation.GradleBuildController.doBuild(GradleBuildController.java:100) at org.gradle.internal.invocation.GradleBuildController.run(GradleBuildController.java:75) at org.gradle.tooling.internal.provider.runner.BuildModelActionRunner.run(BuildModelActionRunner.java:53) at org.gradle.launcher.exec.ChainingBuildActionRunner.run(ChainingBuildActionRunner.java:35) at org.gradle.launcher.exec.ChainingBuildActionRunner.run(ChainingBuildActionRunner.java:35) 。。。 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55) at java.lang.Thread.run(Thread.java:745) Caused by: org.gradle.internal.exceptions.LocationAwareException: A problem occurred configuring project ':org.eclipse.paho.android.service'. at org.gradle.initialization.DefaultExceptionAnalyser.transform(DefaultExceptionAnalyser.java:74) at org.gradle.initialization.MultipleBuildFailuresExceptionAnalyser.transform(MultipleBuildFailuresExceptionAnalyser.java:47) at org.gradle.initialization.StackTraceSanitizingExceptionAnalyser.transform(StackTraceSanitizingExceptionAnalyser.java:30) at org.gradle.initialization.DefaultGradleLauncher.doBuildStages(DefaultGradleLauncher.java:137) at org.gradle.initialization.DefaultGradleLauncher.executeTasks(DefaultGradleLauncher.java:109) at org.gradle.internal.invocation.GradleBuildController$1.call(GradleBuildController.java:78) at org.gradle.internal.invocation.GradleBuildController$1.call(GradleBuildController.java:75) at org.gradle.internal.work.DefaultWorkerLeaseService.withLocks(DefaultWorkerLeaseService.java:152) at org.gradle.internal.invocation.GradleBuildController.doBuild(GradleBuildController.java:100) at org.gradle.internal.invocation.GradleBuildController.run(GradleBuildController.java:75) at org.gradle.tooling.internal.provider.runner.BuildModelActionRunner.run(BuildModelActionRunner.java:53) at org.gradle.launcher.exec.ChainingBuildActionRunner.run(ChainingBuildActionRunner.java:35) at org.gradle.launcher.exec.ChainingBuildActionRunner.run(ChainingBuildActionRunner.java:35) at org.gradle.tooling.internal.provider.ValidatingBuildActionRunner.run(ValidatingBuildActionRunner.java:32) at org.gradle.launcher.exec.RunAsBuildOperationBuildActionRunner$1.run(RunAsBuildOperationBuildActionRunner.java:43) at org.gradle.internal.progress.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:336) at org.gradle.internal.progress.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:328) at org.gradle.internal.progress.DefaultBuildOperationExecutor.execute(DefaultBuildOperationExecutor.java:199) at org.gradle.internal.progress.DefaultBuildOperationExecutor.run(DefaultBuildOperationExecutor.java:110) at org.gradle.launcher.exec.RunAsBuildOperationBuildActionRunner.run(RunAsBuildOperationBuildActionRunner.java:40) 。。。 at org.gradle.launcher.daemon.server.exec.BuildCommandOnly.execute(BuildCommandOnly.java:36) at org.gradle.launcher.daemon.server.api.DaemonCommandExecution.proceed(DaemonCommandExecution.java:122) at org.gradle.launcher.daemon.server.exec.EstablishBuildEnvironment.doBuild(EstablishBuildEnvironment.java:82) at org.gradle.launcher.daemon.server.exec.BuildCommandOnly.execute(BuildCommandOnly.java:36) at org.gradle.launcher.daemon.server.api.DaemonCommandExecution.proceed(DaemonCommandExecution.java:122) at org.gradle.launcher.daemon.server.exec.StartBuildOrRespondWithBusy$1.run(StartBuildOrRespondWithBusy.java:50) at org.gradle.launcher.daemon.server.DaemonStateCoordinator$1.run(DaemonStateCoordinator.java:295) at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63) at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46) at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55) Caused by: org.gradle.api.ProjectConfigurationException: A problem occurred configuring project ':org.eclipse.paho.android.service'. at org.gradle.configuration.project.LifecycleProjectEvaluator.addConfigurationFailure(LifecycleProjectEvaluator.java:94) at org.gradle.configuration.project.LifecycleProjectEvaluator.notifyAfterEvaluate(LifecycleProjectEvaluator.java:89) 。。。 ... 62 more Caused by: org.gradle.api.InvalidUserCodeException: Cannot create variant 'android-lint' after configuration ':org.eclipse.paho.android.service:debugRuntimeElements' has been resolved at org.gradle.api.internal.artifacts.configurations.DefaultConfigurationPublications$ConfigurationVariantFactory.create(DefaultConfigurationPublications.java:158) at org.gradle.api.internal.artifacts.configurations.DefaultConfigurationPublications$ConfigurationVariantFactory.create(DefaultConfigurationPublications.java:151) at org.gradle.api.internal.FactoryNamedDomainObjectContainer.doCreate(FactoryNamedDomainObjectContainer.java:100) at org.gradle.api.internal.AbstractNamedDomainObjectContainer.create(AbstractNamedDomainObjectContainer.java:67) at com.android.build.gradle.internal.scope.VariantScopeImpl.lambda$publishArtifactToConfiguration$2(VariantScopeImpl.java:378) at org.gradle.api.internal.artifacts.configurations.DefaultConfigurationPublications.variants(DefaultConfigurationPublications.java:139) at com.android.build.gradle.internal.scope.VariantScopeImpl.publishArtifactToConfiguration(VariantScopeImpl.java:376) at com.android.build.gradle.internal.scope.VariantScopeImpl.publishIntermediateArtifact(VariantScopeImpl.java:347) at com.android.build.gradle.internal.scope.VariantScopeImpl.addTaskOutput(VariantScopeImpl.java:298) at com.android.build.gradle.internal.TaskManager.configureGlobalLintTask(TaskManager.java:536) at com.android.build.gradle.BasePlugin.createAndroidTasks(BasePlugin.java:7

MQTT客户端Paho MQTT和mosquitto有什么区别?

最近要使用C语言在路由器上开发MQTT客户端,是直接使用共享库或静态库的库函数来连接Broker,不是直接使用sample里面的可执行程序。 在网上搜了下,Paho MQTT和mosquitto都可以作为MQTT客户端,不知道两者有什么区别?可以的话麻烦从库的大小、编译时是否依赖其他第三方库、功能的完整性等几方面比较一下

安卓使用MQTT向服务器发送请求

百度出的内容全都是一堆乱七八糟的写法(类似订阅主题之类的,看着看着就不懂了),没有找到面向新手的代码,想问一下大佬有没有单独的只发送数据部分的代码(要能运行的那种)。 目前已经有服务器了,只是不知该如何发送。

使用Goroutine订阅MQTT消息

<div class="post-text" itemprop="text"> <p>I currently have a Go code that can subscribe and print sensor data that is published to a certain topic. Here is my code: </p> <pre><code>package main import ( "crypto/tls" "flag" "fmt" //"log" "os" "os/signal" "strconv" "syscall" "time" MQTT "github.com/eclipse/paho.mqtt.golang" ) func onMessageReceived(client MQTT.Client, message MQTT.Message) { //fmt.Printf("Received message on topic: %s Message: %s ", message.Topic(), message.Payload()) fmt.Printf("%s ", message.Payload()) } func main() { //MQTT.DEBUG = log.New(os.Stdout, "", 0) //MQTT.ERROR = log.New(os.Stdout, "", 0) c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt, syscall.SIGTERM) hostname, _ := os.Hostname() server := flag.String("server", "tcp://test.mosquitto.org:1883", "The full url of the MQTT server to connect to ex: tcp://127.0.0.1:1883") topic := flag.String("topic", "topic/sensorTemperature", "Topic to subscribe to") qos := flag.Int("qos", 0, "The QoS to subscribe to messages at") clientid := flag.String("clientid", hostname+strconv.Itoa(time.Now().Second()), "A clientid for the connection") username := flag.String("username", "", "A username to authenticate to the MQTT server") password := flag.String("password", "", "Password to match username") flag.Parse() connOpts := MQTT.NewClientOptions().AddBroker(*server).SetClientID(*clientid).SetCleanSession(true) if *username != "" { connOpts.SetUsername(*username) if *password != "" { connOpts.SetPassword(*password) } } tlsConfig := &amp;tls.Config{InsecureSkipVerify: true, ClientAuth: tls.NoClientCert} connOpts.SetTLSConfig(tlsConfig) connOpts.OnConnect = func(c MQTT.Client) { if token := c.Subscribe(*topic, byte(*qos), onMessageReceived); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } } client := MQTT.NewClient(connOpts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } else { fmt.Printf("Connected to %s ", *server) } &lt;-c } </code></pre> <p>Instead of subscribing to messages like this, I want to put the part of the code that subscribes in a <strong>Goroutine</strong>. I want to be able to call <code>go func onMessageReceived</code>. How can I do that if this function is called in <code>c.Subscribe</code>? And how can I add a <code>sync.WaitGroup</code> parameter in? Thank you.</p> </div>

golang mqtt发布并订阅

<div class="post-text" itemprop="text"> <p>Does anybody know where I can get some example MQTT client Go (golang) code that does both publish and subscribe in an infinite loop ?</p> <p>I am messaging with a Mosquitto broker running on MacOs.</p> <p>In more detail... </p> <ol> <li>Get a message from the network (a topic)</li> <li>Compute something based on that message</li> <li>Send the result of the computation back to the network (topic)</li> </ol> <p>Here is the code I am using:</p> <pre><code>package main import ( "fmt" MQTT "github.com/eclipse/paho.mqtt.golang" "os" "time" ) var knt int var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { fmt.Printf("MSG: %s ", msg.Payload()) text:= fmt.Sprintf("this is result msg #%d!", knt) knt++ token := client.Publish("nn/result", 0, false, text) token.Wait() } func main() { knt = 0 opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883") opts.SetClientID("mac-go") opts.SetDefaultPublishHandler(f) c := MQTT.NewClient(opts) if token := c.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } if token := c.Subscribe("nn/sensors", 0, nil); token.Wait() &amp;&amp; token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } time.Sleep(3 * time.Second) } //end of main </code></pre> <p>I looked through the GoDocs for some hint as to how to keep the connections open but nothing seems pertinent. I can certainly do an infinite loop over the 'subscribe' but that seems inefficient. </p> </div>

如何使用paho.mqtt.golang库订阅多个MQTT主题?

<div class="post-text" itemprop="text"> <p>I try to connect to a MQTT broker running on an external server where I need to handle multiple different topics. The problem is, that <strong>only the last subscribed handler is called</strong>, even if the topic does not match the one passed as parameter to the <code>Subscribe()</code> method.</p> <p><strong>Example:</strong> sending any content to <code>p1/test</code> triggers the registrationHandler which only should listen for "<em>P1/controller/registration</em>". The other handlers or the DefaultPublishHandler are never called.</p> <p>A simplified version of my program:</p> <pre><code>func main(){ var opts = MQTT.NewClientOptions() opts.AddBroker(address) opts.SetClientID("go-controller") opts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) { log.Printf("topic: %s ", msg.Topic()) }) client = MQTT.NewClient(opts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { log.Panicln(token.Error()) } client.Subscribe("P1/#", 0, logHandler) client.Subscribe("P1/controller/registration", 0, registrationHandler) } var logHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { ... log.Printf("Topic %s logged... ", msg.Topic()) } var registrationHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { ... log.Printf("Topic %s registered... ", message.Value) } </code></pre> <p><strong>EDIT #1</strong></p> <p>I found out that the oder of subscribing to topics matters. When I swap both subscription calls the correct handlers get called.</p> </div>

LinkIT One使用paho mqtt连接服务器失败

背景描述: 使用LinkIT One基于paho的mqtt客户端,当代码执行到rc=client.connect(data);,超时然后返回rc=-1。 测试连接的服务端包括IBM Watson、中移OneNet还有自己搭建的mosquitto,都是一样的错误。查了一下paho的实现代码,把MQTTClient.h中的connect实现改了一下就connect成功了,但subscribe又超时并返回错误了(如下所示)。 在网上查到了和我类似的错误,貌似LinkIT One并不能使用paho的mqtt。但将mqtt客户端换成pubsub后却能够正常工作。 下面是我的测试代码(mqtt服务器是本地局域网的mosquitto) ``` #include <LWiFi.h> #include <LWiFiClient.h> #include <IPStack.h> #include <Countdown.h> #include <MQTTClient.h> #define WIFI_AP "SSID" #define WIFI_PASSWORD "PASSWD" #define WIFI_AUTH LWIFI_WPA int port = 1883; char servername[]="10.214.149.119"; char clientName[] = "myaccount"; char topicName[] = "@tp"; char userName[] = "myaccount"; char password[] = "12345"; LWiFiClient tcpClient; IPStack ipstack(tcpClient); MQTT::Client<IPStack, Countdown, 200> client = MQTT::Client<IPStack, Countdown, 200>(ipstack); void messageArrived(MQTT::MessageData& md){ MQTT::Message &message = md.message; char res[100]; int len = message.payloadlen; strncpy(res, (char*)message.payload, len); res[len] = '\0'; Serial.println(res); } void setup(){ Serial.begin(9600); while(!Serial.available()); InitWiFi(); if (!client.isConnected()) reconnect(); int rc = client.subscribe(topicName, MQTT::QOS0, messageArrived); if (rc != 0) Serial.println(String("rc from MQTT subscribe is ")+rc); else Serial.println(String("rc from MQTT subscribe is ")+rc); } void loop(){ Serial.println("loop"); client.yield(100); delay(2000); } void InitWiFi(){ LWiFi.begin(); // Keep retrying until connected to AP Serial.println("Connecting to AP"); while (0 == LWiFi.connect(WIFI_AP, LWiFiLoginInfo(WIFI_AUTH, WIFI_PASSWORD))) { Serial.println("Retry connect AP ... "); delay(1000); } Serial.println("Connected to AP"); } void reconnect() { // Loop until we're reconnected if(!client.isConnected()) { int rc = ipstack.connect(servername, port); if (rc == 1){ Serial.println("IPStack Success"); }else{ Serial.println("IPStack Failed"); } Serial.print("Connecting to IOT platform ..."); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.MQTTVersion = 4; data.clientID.cstring = clientName; data.username.cstring = userName; data.password.cstring = password; rc = client.connect(data); if (rc == 0) { Serial.println( "[DONE]" ); } else { Serial.println( "[FAILED]"); delay(5000); } } } ``` 我的问题是: 有没有大神使用LinkIT One基于paho的mqtt实现了客户端,可以正常pub/sub话题,测试的mqtt代理可以是mosquitto或IBM Watson或中移OneNet?允许修改paho或LWiFiClient的源码?(我只要基于paho的实现) 提示: 1.通过之前在Arduino UNO、BeagleBone Black、树莓派2的实验感觉各种mqtt的代理基本都一样的,能在mosquitto上测试通过的基本都能在IBM Watson或OneNet上测试通过; 2.LinkIt One用pubsub测试没有问题,这说明LWiFiClient很大概率是没问题的,估计要修改paho的实现代码

使用Goroutine订阅MQTT不打印消息

<div class="post-text" itemprop="text"> <p>I currently have Go code that subscribes to a topic and prints out sensor data. The part that prints out the sensor data is in a <strong>Goroutine</strong>, however, nothing is printing out currently. This is my code: </p> <pre><code>package main import ( "fmt" MQTT "github.com/eclipse/paho.mqtt.golang" "os" "os/signal" "syscall" "sync" ) var wg sync.WaitGroup func subscriber(client MQTT.Client, message MQTT.Message) { wg.Add(1) go func() { defer wg.Done() fmt.Printf("%s ", message.Payload()) }() } func main() { c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt, syscall.SIGTERM) opts := MQTT.NewClientOptions().AddBroker("tcp://test.mosquitto.org:1883") //opts.SetDefaultPublishHandler(f) // Topic to subscribe to for sensor data topic := "sensor/data" client := MQTT.NewClient(opts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } else { fmt.Printf("Connected to server ") } opts.OnConnect = func(c MQTT.Client) { //if token := c.Subscribe(topic, 0, f); token.Wait() &amp;&amp; token.Error() != nil { if token := c.Subscribe(topic, 0, subscriber); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } } wg.Wait() &lt;-c } </code></pre> <p>I'm wondering if it has to do with the way I coded the sync.WaitGroup? Any ideas are appreciated. </p> </div>

Paho MQTT Golang协议

<div class="post-text" itemprop="text"> <p>I'm new on Golang and mqtt.</p> <p>I'm trying to connect to a broker. It works when I'm using MQTT.fx or my terminal with mosquitos.</p> <p>But in my program, I create my opts with the address &amp; clientID and when I try to connect there is an error "Unknow protocol"</p> <blockquote> <p>panic: Network Error : Unknown protocol</p> <p>goroutine 1 [running]:</p> <p>panic(0x347b20, 0xc820072fe0)</p> <p>/usr/local/go/src/runtime/panic.go:481 +0x3e6</p> <p>main.main()</p> <p>test.go:29 +0x1cd</p> </blockquote> <p>I checked the protocol version on MQTT.fx and it's TLSv1.2.</p> <p>The Paho library support TLS protocol. I'm a bit confused</p> <p>Is there someone who got the same issue ?</p> <p>Cheers</p> </div>

大学四年自学走来,这些私藏的实用工具/学习网站我贡献出来了

大学四年,看课本是不可能一直看课本的了,对于学习,特别是自学,善于搜索网上的一些资源来辅助,还是非常有必要的,下面我就把这几年私藏的各种资源,网站贡献出来给你们。主要有:电子书搜索、实用工具、在线视频学习网站、非视频学习网站、软件下载、面试/求职必备网站。 注意:文中提到的所有资源,文末我都给你整理好了,你们只管拿去,如果觉得不错,转发、分享就是最大的支持了。 一、电子书搜索 对于大部分程序员...

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

springboot+jwt实现token登陆权限认证

一 前言 此篇文章的内容也是学习不久,终于到周末有时间码一篇文章分享知识追寻者的粉丝们,学完本篇文章,读者将对token类的登陆认证流程有个全面的了解,可以动态搭建自己的登陆认证过程;对小项目而已是个轻量级的认证机制,符合开发需求;更多精彩原创内容关注公主号知识追寻者,读者的肯定,就是对作者的创作的最大支持; 二 jwt实现登陆认证流程 用户使用账号和面发出post请求 服务器接受到请求后使用私...

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

总结了 150 余个神奇网站,你不来瞅瞅吗?

原博客再更新,可能就没了,之后将持续更新本篇博客。

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

程序员写出这样的代码,能不挨骂吗?

当你换槽填坑时,面对一个新的环境。能够快速熟练,上手实现业务需求是关键。但是,哪些因素会影响你快速上手呢?是原有代码写的不够好?还是注释写的不够好?昨夜...

外包程序员的幸福生活

今天给你们讲述一个外包程序员的幸福生活。男主是Z哥,不是在外包公司上班的那种,是一名自由职业者,接外包项目自己干。接下来讲的都是真人真事。 先给大家介绍一下男主,Z哥,老程序员,是我十多年前的老同事,技术大牛,当过CTO,也创过业。因为我俩都爱好喝酒、踢球,再加上住的距离不算远,所以一直也断断续续的联系着,我对Z哥的状况也有大概了解。 Z哥几年前创业失败,后来他开始干起了外包,利用自己的技术能...

优雅的替换if-else语句

场景 日常开发,if-else语句写的不少吧??当逻辑分支非常多的时候,if-else套了一层又一层,虽然业务功能倒是实现了,但是看起来是真的很不优雅,尤其是对于我这种有强迫症的程序"猿",看到这么多if-else,脑袋瓜子就嗡嗡的,总想着解锁新姿势:干掉过多的if-else!!!本文将介绍三板斧手段: 优先判断条件,条件不满足的,逻辑及时中断返回; 采用策略模式+工厂模式; 结合注解,锦...

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

2020阿里全球数学大赛:3万名高手、4道题、2天2夜未交卷

阿里巴巴全球数学竞赛( Alibaba Global Mathematics Competition)由马云发起,由中国科学技术协会、阿里巴巴基金会、阿里巴巴达摩院共同举办。大赛不设报名门槛,全世界爱好数学的人都可参与,不论是否出身数学专业、是否投身数学研究。 2020年阿里巴巴达摩院邀请北京大学、剑桥大学、浙江大学等高校的顶尖数学教师组建了出题组。中科院院士、美国艺术与科学院院士、北京国际数学...

为什么你不想学习?只想玩?人是如何一步一步废掉的

不知道是不是只有我这样子,还是你们也有过类似的经历。 上学的时候总有很多光辉历史,学年名列前茅,或者单科目大佬,但是虽然慢慢地长大了,你开始懈怠了,开始废掉了。。。 什么?你说不知道具体的情况是怎么样的? 我来告诉你: 你常常潜意识里或者心理觉得,自己真正的生活或者奋斗还没有开始。总是幻想着自己还拥有大把时间,还有无限的可能,自己还能逆风翻盘,只不是自己还没开始罢了,自己以后肯定会变得特别厉害...

男生更看重女生的身材脸蛋,还是思想?

往往,我们看不进去大段大段的逻辑。深刻的哲理,往往短而精悍,一阵见血。问:产品经理挺漂亮的,有点心动,但不知道合不合得来。男生更看重女生的身材脸蛋,还是...

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试:第十六章:Java中级开发

HashMap底层实现原理,红黑树,B+树,B树的结构原理 Spring的AOP和IOC是什么?它们常见的使用场景有哪些?Spring事务,事务的属性,传播行为,数据库隔离级别 Spring和SpringMVC,MyBatis以及SpringBoot的注解分别有哪些?SpringMVC的工作原理,SpringBoot框架的优点,MyBatis框架的优点 SpringCould组件有哪些,他们...

早上躺尸,晚上干活:硅谷科技公司这么流行迟到?

硅谷科技公司上班时间OPEN早已不是什么新鲜事,早九晚五是常态,但有很多企业由于不打卡,员工们10点、11点才“姗姗来迟”的情况也屡见不鲜。 这种灵活的考勤制度为人羡慕,甚至近年来,国内某些互联网企业也纷纷效仿。不过,硅谷普遍弹性的上班制度是怎么由来的呢?这种“流行性迟到”真的有那么轻松、悠哉吗? 《动态规划专题班》 课程试听内容: 动态规划的解题要领 动态规划三大类 求最值/计数/可行性 常...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

终于懂了TCP和UDP协议区别

终于懂了TCP和UDP协议区别

Python爬虫,高清美图我全都要(彼岸桌面壁纸)

爬取彼岸桌面网站较为简单,用到了requests、lxml、Beautiful Soup4

无代码时代来临,程序员如何保住饭碗?

编程语言层出不穷,从最初的机器语言到如今2500种以上的高级语言,程序员们大呼“学到头秃”。程序员一边面临编程语言不断推陈出新,一边面临由于许多代码已存在,程序员编写新应用程序时存在重复“搬砖”的现象。 无代码/低代码编程应运而生。无代码/低代码是一种创建应用的方法,它可以让开发者使用最少的编码知识来快速开发应用程序。开发者通过图形界面中,可视化建模来组装和配置应用程序。这样一来,开发者直...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

Java岗开发3年,公司临时抽查算法,离职后这几题我记一辈子

前几天我们公司做了一件蠢事,非常非常愚蠢的事情。我原以为从学校出来之后,除了找工作有测试外,不会有任何与考试有关的事儿。 但是,天有不测风云,公司技术总监、人事总监两位大佬突然降临到我们事业线,叫上我老大,给我们组织了一场别开生面的“考试”。 那是一个风和日丽的下午,我翘着二郎腿,左手端着一杯卡布奇诺,右手抓着我的罗技鼠标,滚动着轮轴,穿梭在头条热点之间。 “淡黄的长裙~蓬松的头发...

大胆预测下未来5年的Web开发

在2019年的ReactiveConf 上,《Elm in Action》的作者Richard Feldman对未来5年Web开发的发展做了预测,很有意思,分享给大家。如果你有机会从头...

立即提问
相关内容推荐