c#用M2Mqtt传输数据不了数据,是什么原因?

求助各位大佬,mosquitto可以进行MQ传输,为什么C#里用M2Mqtt不行?
图片说明
图片说明
图片说明
如图片上的。我用winform来进行MQ传输怎么没有用?求助!求助!求助!

c#

1个回答

这个分为客户端和服务端,你先搞明白两个端。然后 用客户端连接服务端就可以了。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
数据显示不了,是什么原因?
当我点击返回所有行,总是显示Provider cannot be found,it may not be properly installed,但用查询分析器查询数据又可以查询到。请问这可能是什么原因引起得?有哪些解决办法。
C# M2Mqtt封装类
最近由于自己使用到M2MQTT,在网上综合了一些教程后自己完善了一个封装类。具体用法见代码using System;using System.Collections.Generic;using System.Linq;using System.Net;using System.Net.Security;using System.Security.Cryptography.X509Certifica...
用modem通过电话线传输数据,有延迟,是什么原因?
公司用捷联的猫传输数据,终端用的33600md,公司总部用捷联的列架猫,终端的猫自动拨号,与列架猫建立连接后(v22bis协议,2400速率,异步),传输终端的数据。每次都是刚开始传输的时候比较正常,但逐渐数据就会延迟,延迟有时可达3分钟,但进入modem里面,用at&v1查看线路质量等参数,都没有问题,可能是什么原因,谢谢?
图象显示不了,是什么原因
我作一个图象格式转换的程序,生成一个Tiff文件,调试中已经测得生成文件的大小以及一些Tiff文件中IFD中一些Tag的数据都是对的,但是生成的tif文件用ACDSee打开,就是什么也不显示,请问这大概是什么原因,请大家帮帮我分析一下.
上不了网,是什么原因?
xp系统,可以ping通外网的ip地址,nslookup网址也正确,但ping域名不行,如:rnping www.sina.com.cn不通,ping它的ip地址通。换浏览器如oprea和腾讯tt都不行,rnQQ可以上,就是不能浏览网页。rnrn系统有重要东西不能删除!rn请有过方面经验的高手说一下原因,怎么解决,谢先!
删除不了作业?是什么原因?
删除这个作业的时候,弹出对话框提示:错误14274:无法添加,更新或删除从MSX服务器发起的作业(或步骤或调度)rnrnrn不知这句话所指何意?请各们指点一下。。。。。。。。。。。。。。。谢了。
MQTT协议 C#客户端
1、引入M2MQTT的dll库文件 点击此处下载M2Mqtt.Net.dll 2、建立客户端连接并订阅 //创建客户端实例 MqttClient client = new MqttClient(IPAddress.Parse(MQTT_BROKER_ADDRESS)); //主机为IP时 MqttClient client = new MqttClient(MQTT_BROKER...
c# M2Mqtt 3.5最低版本
在官网上下载的M2Mqtt文件类,3.5不能用,编译过后或是使用.csproj,只有一个4.5的能用,经过整理及测试通过后,发布一个3.5版本,可以直接拿过来编译用。
"采用数据串行化的方式传输数据"是什么意思?
CArchive*m_aSessionIn; //输入数据的串行化rnCArchive*m_aSessionOut; //输出数据的串行化rnCSocketFile*m_sfSocketFile; //专门网络服务的文件rnrn数据的串行化是指什么?rn专门网络服务的文件是指什么?rn
浏览器可以访问ftp 用控制台访问不了是什么原因
我安装了serv-u服务器,局域网IP。同事们都可以通过浏览器访问了。但是通过控制台用命令访问时总是出现connection closed by remote host的语句,访问不了ftp。请问各位高手,这到底是怎么回事?因为要实现远程修改密码功能,所以比较急。rn另外,服务器上的word文档,需要下载到本地才能打开,能否设置成可以在服务器上打开?
用vc编译的dll在vb中引用不了,是什么原因
我用vc写了个dll,用vc测试时是可以用的,可是用vb引用时,却说can't refrence this file,请问这有可能是什么原因?
删除不了session,可能的原因是什么??
rn rn继续购物rnrn删除不了session,可能的原因是什么??rnrn请高手们指教??
一dbf文件中的中文显示不了是什么原因
我从其他单位收到一个dbf文件,该文件有四个字段,但是姓名字段里面的汉字都显示不了(我用visual foxpro6.0 英文版)?请问这是什么原因?
上不了某个网站是什么原因??
上不了某个网站是什么原因?rnrn我是大学生,有个我经常上的网站今天突然上不了了,而且就这个网站上不了其他都能上,而且奇怪的是,用我们宿舍的其他电脑都可以上那个网站。这到底是什么原因?
jsp页面调用不了外部js是什么原因?
jsp页面调用不了外部js是什么原因?rn引用路径没有错,我再另一个jsp页面用了这个js,一点问题都没有
大神帮忙看下是什么原因,表单提交不了
因为这些是别人的代码,所以里面jquery的代码不太懂,总之是页面点login没什么反应rn代码如下:rn[code=HTML][/code]rnrnrnrn rn Animated Form Switching with jQueryrn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn Registerrn rn rn First Name:rn rn This is an errorrn rn rn Last Name:rn rn This is an errorrn rn rn Website:rn rn This is an errorrn rn rn rn rn Username:rn rn This is an errorrn rn rn Email:rn rn This is an errorrn rn rn Password:rn rn This is an errorrn rn rn rn rn rn Send me updatesrn rn rn You have an account already? Log in herern rn rn rn rn rn rn Loginrn rn Username:rn rn This is an errorrn rn rn Password: Forgot your password?rn rn This is an errorrn rn rn rn rn You don't have an account yet? Register herern rn rn rn rn rn rn Forgot Passwordrn rn Username or Email:rn rn This is an errorrn rn rn rn Suddenly remebered? Log in herern You don't have an account? Register herern rn rn rn rn rn rn rn rnrn rn rn rn rn
请问数据库附加不了,是什么原因?
附加数据库的时候出现了 “错误602:未能在sysindexes中找到数据库 id 8 中的索引ID1对应的行。rn请对sysindexes运行DBCC CHECKTABLE.”
上不了某个网站是什么原因?
我是大学生,有个我经常上的网站今天突然上不了了,而且就这个网站上不了其他都能上,而且奇怪的是,用我们宿舍的其他电脑都可以上那个网站。这到底是什么原因?
怎么import导入不了包,原因是什么?
怎么import导入不了包,原因是什么?
字符转换不了,,,是什么原因??,在线等,
代码写的一个datatable,下面这个地方rnDataRow newRow;rnnewRow=dt.NewRow();rnrnNewRow["ProductID"]=System.int32.parse("ProductID").tostring();rn想把ProductID字段转换成整形
编写的.so文件加载不了,是什么原因
linux下写的.so文件,主程序能运行,但是运行到dlopen时,加载不到!请高手
websphere 7.0调试不了是什么原因
websphere 7.0调试不了是什么原因,我的websphere应用服务器以调试的方式运行,在java代码中设置断点,点击查询按钮,就卡死,java程序进不去,调试卡死,请各位高手指点一下,不胜感激!!!
在线点播看不了,不知是什么原因
以前可以看的,系统提示media palyer7 的版本太低,升级到9.0后,在线点播就不能看了,也不报错,以及版本低等提示信息,重装系统也无济于事,不知道是什么原因,请大侠们帮忙解决,谢谢!
VS2005的sp1安装不了是什么原因?
我下一个项目是VS2005打不开,提示不支持该安装项目类型,我去下载一个SP1可是安装不了。
plsql登录不了,一直是ora-12154是什么原因
[img=https://img-bbs.csdn.net/upload/201709/05/1504593154_730194.png][/img]就这个,管理员身份也登录不了,目前的这个oracle11G是32位的,上午刚刚安装完的,plsql也是专门找的32位的,之前电脑用的是64位的oracle用起来完全没问题,但是因为项目需要改换成的32位就一直不能用,谁能给解决下?在线急等,需要什么现场找到给你贴图,本人oracle新手,希望能够说的通俗易懂些
电脑开不了机,请问是什么原因?
rnrn按下开机,只有电源灯亮,整个电脑没有反应,显示器漆黑一片rnrn请问这可能是什么原因导致?rn
在unity3d中接受MQTT消息协议数据C# .net,M2Mqtt
具体关于MQTT是什么具体就不说了,百度一下,你就知道。这里用的是M2Mqtt的类库。可以去查官网然后git下来自己生成一下。接下来直接上unity客户端的本地代码: 需要提前导入生成的DLL。 using UnityEngine; using System.Collections; using System.Net; using System.Text; using uPLibrary.Ne
部分oracle服务启动不了是什么原因?
两个服务启动不了:OracleOraHome92ManagementServer(管理服务器后台服务)和OracleOraHome92Agent(智能代理后台服务).rn不管是手动还是自动都启动不了,
一个老游戏,玩不了是什么原因?
一个很老的叫的游戏,玩不成,我的机子是XP系统,会不会是游戏太老无法兼容?有什么办法解决吗?请帮忙!rn如果要游戏拿去测试,请加QQ12701115,我会发给你!rn最先解决者拿满分100,在线等,及时结贴!
(求助)网站上不了是什么原因
我的网站没有托管,程序直接放在公司的服务器上,而且有专门的IP地址,域名解析也没有问题(因为以前一直都好好的),最近我的网站出现一种怪现象:一会儿能打开,一会儿又打不开。我仔细检查了一下,外网内网都是好的,这应该是什么原因造成的呢?
jsp:usebean编译不了,不知道是什么原因
rnrnregister.htmlrn---------------rnrnrn rn rn用户信息注册: rn rn rn 姓名: rn 密码: rn 年龄: rn rn rn rn rnrnrnrnrnrnrnrnregister.jsprn---------------rn<%@ page contentType="text/html;charset=gb2312"%> rnrnrn rn rn注册成功: rn rn使用bean属性方法: rn rn使用getProperty: rn用户名:<%=user.getUserName() %> rn密码:<%=user.getPassword() %> rn年龄:<%=user.getAge()%> rn用户名: rn密码: rn年龄: rn rn rn===================================================rnTestBean.javarn-----------------------------------rnpackage com.jspdev.ch3;rnrnpublic class TestBeanrnrnpublic String userName;rnpublic String password;rnpublic int age; rnrnpublic void setUserName(String name)rnrnthis.userName=name;rnrnpublic void setPassword(String password)rnrnrnthis.password=password;rnrnpublic String getUserName()rnrnreturn this.userName;rnrnpublic String getPassword()rnrnreturn password;rnrnpublic int getAge()rnrnreturn this.age;rnrnpublic void setAge(int age)rnrnthis.age=age;rnrnrn==========================================rn我现在用的环境是TOMCAT4.1 +JDK1.4.2rnrn我的工作目录是:rnclass放到了:webapps\work\WEB-INF\classes\com\jspdev\ch3\TestBean.classrnrn下面是运行时的错误:rnrnHTTP Status 500 - rnrn--------------------------------------------------------------------------------rntype Exception reportrnrnmessage rnrndescription The server encountered an internal error () that prevented it from fulfilling this request.rnrnexception rnrnorg.apache.jasper.JasperException: com.jspdev.ch3.TestBeanrnat org.apache.jasper.compiler.BeanRepository.getBeanType(BeanRepository.java:135)rnat org.apache.jasper.compiler.Generator$GenerateVisitor.visit(Generator.java:650)rnat org.apache.jasper.compiler.Node$GetProperty.accept(Node.java:507)rnat org.apache.jasper.compiler.Node$Nodes.visit(Node.java:983)rnat org.apache.jasper.compiler.Node$Visitor.visitBody(Node.java:1025)rnat org.apache.jasper.compiler.Node$Visitor.visit(Node.java:1031)rnat org.apache.jasper.compiler.Node$Root.accept(Node.java:187)rnat org.apache.jasper.compiler.Node$Nodes.visit(Node.java:983)rnat org.apache.jasper.compiler.Generator.generate(Generator.java:1891)rnat org.apache.jasper.compiler.Compiler.generateJava(Compiler.java:198)rnat org.apache.jasper.compiler.Compiler.compile(Compiler.java:327)rnat org.apache.jasper.JspCompilationContext.compile(JspCompilationContext.java:427)rnat org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:142)rnat org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:240)rnat org.apache.jasper.servlet.JspServlet.service(JspServlet.java:187)rnat javax.servlet.http.HttpServlet.service(HttpServlet.java:809)rnat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:200)rnat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:146)rnat org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:209)rnat org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:596)rnat org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:433)rnat org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:948)rnat org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:144)rnat org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:596)rnat org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:433)rnat org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:948)rnat org.apache.catalina.core.StandardContext.invoke(StandardContext.java:2358)rnat org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:133)rnat org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:596)rnat org.apache.catalina.valves.ErrorDispatcherValve.invoke(ErrorDispatcherValve.java:118)rnat org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:594)rnat org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:116)rnat org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:594)rnat org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:433)rnat org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:948)rnat org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:127)rnat org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:596)rnat org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:433)rnat org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:948)rnat org.apache.coyote.tomcat4.CoyoteAdapter.service(CoyoteAdapter.java:152)rnat org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:799)rnat org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.processConnection(Http11Protocol.java:705)rnat org.apache.tomcat.util.net.TcpWorkerThread.runIt(PoolTcpEndpoint.java:577)rnat org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:683)rnat java.lang.Thread.run(Unknown Source)rnrnrnrnrn我在work\Standalone\localhost\_\register_.java发现:register_.java居然为0k;而且没有生成rnregister_.class文件rn我不知道是什么原因。rn我用一般的jsp文件能通过,并显示结果。rn我在想一定是jvm不能编译到usebean的中的.class文件。rn可是我就是不知道怎么改。......因为我是初学者。
数据 只读??是什么原因呢?
我刚接触数据库编程,在VC6中,我写了个很简单的程序想先试试,但是当我输入数据后,提示说 :“记录集是只读” 我看了很旧都不知道什么事!那个表是我在SQL里写的,不知道会不会是我在SQL里设置不好!请大家指教指教!
数据泄露的常见原因是什么,后果是什么?
即便是轻微的数据泄漏也会造成经营者无法承受的严重后果。据估测,40%的在线攻击的目标所针对的都是小企业。从为职工或者员工进行额外培训以避免可能造成安全问题的坏习惯,到对各种层出不穷的新的威胁进行跟进,经营者们愿意采取任何能提高他们的数据安全水平的措施。 数据泄漏的后果 从重大安全泄漏事故,到一些连经营者自己都无法察觉的账户信息泄漏的细微状况,如何衡量数据泄漏造成的真正损失通常比较困难。除了较为明面...
C#mqtt库M2Mqtt的使用
目前最好用的C#库是 eclipse出的M2Mqtt库,主页链接:http://www.eclipse.org/paho/clients/dotnet/ 项目的地址是https://github.com/eclipse/paho.mqtt.m2mqtt 使用方式是在vs 的命令中输入 Install-Package M2Mqtt 项目主页上介绍看起来很简单 ... /...
session.save()保存不了数据,不知原因!!
我是用webwork+spring+hibernate做一个实验,把一张表单的数据保存进数据库。但是下面这个错误困惑我两天了,终不得其解,rn错误提示。。 rnjava.lang.NullPointerException rnorg.action.Agentaction.execute(Agentaction.java:28) rnsun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) rnsun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) rnsun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) rnjava.lang.reflect.Method.invoke(Method.java:585) rncom.opensymphony.xwork.DefaultActionInvocation.invokeAction(DefaultActionInvocation.java:364) rncom.opensymphony.xwork.DefaultActionInvocation.invokeActionOnly(DefaultActionInvocation.java:216) rncom.opensymphony.xwork.DefaultActionInvocation.invoke(DefaultActionInvocation.java:190) rncom.opensymphony.xwork.interceptor.DefaultWorkflowInterceptor.doIntercept(DefaultWorkflowInterceptor.java:168) rncom.opensymphony.xwork.interceptor.MethodFilterInterceptor.intercept(MethodFilterInterceptor.java:86) rncom.opensymphony.xwork.DefaultActionInvocation.invoke(DefaultActionInvocation.java:188) rncom.opensymphony.xwork.validator.ValidationInterceptor.doIntercept(ValidationInterceptor.java:115) rncom.opensymphony.xwork.interceptor.MethodFilterInterceptor.intercept(MethodFilterInterceptor.java:86) rncom.opensymphony.xwork.DefaultActionInvocation.invoke(DefaultActionInvocation.java:188) rncom.opensymphony.xwork.interceptor.AroundInterceptor.intercept(AroundInterceptor.java:31) rncom.opensymphony.xwork.DefaultActionInvocation.invoke(DefaultActionInvocation.java:188)rnrn我的ACTION只有一个 rnpublic class Agentaction extends ActionSupport rnprivate Agent agent = new Agent(); rnprivate Agentdao agentdaoimpl; rnpublic Agent getAgent() rnreturn agent; rn rnpublic void setAgent(Agent agent) rnthis.agent = agent; rn rnpublic Agentdao getAgentdaoimpl() rnreturn agentdaoimpl; rn rnpublic void setAgentdaoimpl(Agentdao agentdaoimpl) rnthis.agentdaoimpl = agentdaoimpl; rn rn@Override rnpublic String execute() throws Exception rnrnagentdaoimpl.saveAgent(agent);rnrnreturn SUCCESS; rn rn因为做实验,我就直接连DAO层了,不做SERVICER层,代码如下: rnpublic class Agentdaoimpl extends Basedao implements Agentdao rnprivate Agent agent = new Agent(); rnpublic void saveAgent(Agent agent) rnSession session=getSession(); rnTransaction tx=session.beginTransaction(); rntry rnsession.save(agent); rntx.commit(); rnsession.close(); rn catch (HibernateException e) rn// TODO 自动生成 catch 块 rne.printStackTrace(); rntx.rollback(); rnsession.close(); rnSystem.out.println("保存有错"); rnrnrn rnpublic Agent getAgent() rnreturn agent; rn rnpublic void setAgent(Agent agent) rnthis.agent = agent; rnrnrnrnrn下面这个是BASEDAO。 rnpublic class Basedao rnprivate SessionFactory sessionFactory; rnrnpublic SessionFactory getSessionFactory() rnreturn sessionFactory; rn rnpublic void setSessionFactory(SessionFactory sessionFactory) rnthis.sessionFactory = sessionFactory; rn rnrnpublic Basedao() rnrnpublic Session getSession() rnSession session=sessionFactory.openSession(); rnreturn session; rnrnrnrnrn还有,。我的上下文: rn rnrnrnrnrn rn rncom.mysql.jdbc.Driver rn rn rnjdbc:mysql://127.0.0.1:3000/ywy rn rn rnroot rn rn rn3126672 rn rn rn rn rn rn rn rn rn rnorg.hibernate.dialect.MySQLDialect rn rn rn rn rn rnorg/model/Agent.hbm.xml rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rnrnrnrnrnrnxwork文件:rnrn rn rn rn rn rn rnregister_success.jsp rnagent.jsp rnrnrnrnrnrnrn rnrnrn调试就 rnagentdaoimpl.saveAgent(agent);rnrn这里过不了。。不知道什么原因。。 rn
C# 加密传输数据...............
rn服务端 加密...rnrn客户端 解密...客户端用公匙解密rnrn我准备用 RSA 算法....rnrn可是有些矛盾...rnrnRSA 的私匙保存在服务端, 公匙保存在客户端....(我看了私匙和公匙...公匙就是私匙的一部分..所以私匙不能公开)rnrn我无法用私匙 加密数据....然后用公匙解密数据呀...我试了用私匙加密数据..然后用私匙解密数据...出错rnrn[color=#FF0000]我想问下..有没有什么加密算法......可以保证服务端数据发送到客户端不被修改....rnrn例如私匙加密 公私解密...[/color]rnrnrn
c#通讯传输数据问题
小弟现在在帮老师做任务,制作一个中间服务器,多客户端连接服务器,服务器再根据数据库内容连接对应客户端的终端机器,现在其他部分都完成了,数据通信这块有些问题,以下是我的通讯程序:rn int bytes=0;rn streamToServer=client.GetStream();rn byte[] buffer=new byte[256];rn tryrn rn bytes = streamToServer.Read(buffer, 0, buffer.Length);rn msg = Encoding.Unicode.GetString(buffer, 0, bytes);rn rn catch (IOException)rn rn return;rn rn为什么我进行接收和发送,比如发送“111”,终端和服务器接收的都是“1”,“1”,“1”,字符串都被分开了,求解应该怎么办?除了定义消息尺寸的方法,还有其他方法么?rn
是什么原因
编的程序在visual studio里全部运行通过,调试也没有问题。可做成安装程序安装后,一调试就出错误!生成安装程序都是按网上教程做的,也是生成成功的啊
<>是什么原因
刚学ASP,碰到个头大的问题:rnrn网站的第一个登录界面没什么问题,登录好后在做任何查询,都产生rnHTTP 500 - 内部服务器错误rnrn请问可能是什么原因,应该怎么调试
是什么原因?
我设置了一个JOB按时间来执行一个存储过程,现在JOB也按时的运行但是总是报错!所以我的存储过程也没法工作。上面的情况到底是什么错误原因!存储过程看上去也没有呀!help me!!
相关热词 c# 线程结束时执行 c# kb mb 图片 c# 替换第几位字符 c#项目决定成败 c# 与matlab c# xml缩进 c#传感器基础 c#操作wps c# md5使用方法 c# 引用父窗口的组件