php实现mqtt源码

1. 物联网开发需要什么技术呢

物联网开发需要的技术
一：单片机/嵌入式开发
智能硬件，哎，不就是单片机吗?说到底就是一个微控制器，现在出现的智能手表，调光LED灯，蓝牙开锁，WiFi插座等等，说到底不就是单片机开发嘛?单片机，电子和通信专业一般都会教51或AVR、计算机系接触不到。现在流行的Arino也是单片机开发的一种。
但是要做一款智能硬件，技术上只会单片机编程还是不行的。哎呀嘛什么智能硬件，本质上就是一个电子产品!。所以你要开发一款能拿得出手的智能硬件，电子系统设计必须要会的!
二：网络通信协议
智能硬件与传统的电子产品最大的差别，就是智能硬件连上了网络。要连上网络，就需要用到网络通信模块及学习网络通信协议——TCP/IP。
TCP/IP是一个技术的总称，里面包含两种协议TCP、UDP，位于网络通信分层模型的传输层，同时也是由操作系统管理。而HTTP、DNS、URI等这些技术，属于应用层，位于TCP/UDP之上。同样，最近物联网比较流行的，针对计算能力有限的通讯设备而出的MQTT协议，也属于TCP之上。
为了让电子产品有联网的能力，只要在电路设计上给主控芯片连接一个通信模块，写好收发网络指令的代码，剩下的就是电子产品设计了。
三：服务端开发框架
Client/Server架构，即客户端/服务器架构。智能硬件连上后台服务器后，其就是一个客户端，一个终端。由于单片机中资源受限，实际上是不太可能用HTTP协议的，所以互联网中通用的Web服务器开发并不适合这里。有的厂家会在TCP之上自定义协议，有的就移植别人做好的协议比如MQTT，CoAP等等。
服务端开发就比较复杂了。单片机/嵌入式软件开发还好，只要学习好C语言即可打遍天下无敌手，而服务端开发，用Java呢还是Python还是php?反正Java和Python选一个就好了，嵌入式出身的工程师，一般都会学Python。
Python服务器端的开发框架种类繁多，Web开发的有Django、FlaskTornado WebServer，TCP服务器可以用Twisted，等等。MQTT有已经做好的服务器，像这样的服务器不用自己开发，直接部署即可。

2. 如何实现消息推送功能

3. 怎么实现服务器给android客户端主动推送消息

采用MQTT协议实现Android推送功能是一种解决方案。MQTT是一个轻量级的消息发布/订阅协议，是实现基于手机客户端的消息推送服务器的理想解决方案。

常见的解决方案实现原理：

1、轮询(Pull)方式：客户端定时向服务器发送询问消息，一旦服务器有变化则立即同步消息。

2、SMS(Push)方式：通过拦截SMS消息并且解析消息内容来了解服务器的命令，但这种方式一般用户在经济上很难承受。

3、持久连接(Push)方式：客户端和服务器之间建立长久连接，这样就可以实现消息的及时行和实时性。

(3)php实现mqtt源码扩展阅读：

推送消息注意事项：

1、支持第三方推送内容，是要客户端和服务器都支持的，客户端和服务器都导入推送SDK。

2、服务器推送内容，可以精确指定推送时间，推送的具体接收人，用户群，位置。

3、即推送的维度可以使时间，位置，人群。

4、极光使用了两种不同的通知方式，一种是推送通知，一种是推送消息。

5、如果要使用androidpn，则还需要做大量的工作，需要理解XMPP协议、理解Androidpn的实现机制，需要调试内部存在的BUG。

参考资料来源：网络-服务器

参考资料来源：网络-Android客户端

参考资料来源：网络-信息推送

4. 请教Nodejs实现XMPP和MQTT协议的具体思路

MQTT是一个轻量级的消息发布/订阅协议，它是实现基于手机客户端的消息推送服务器的理想解决方案。 我们可以从这里下载该项目的实例代码，并且可以找到一个采用PHP书写的服务器端实现。 架构如下所示： wmqtt.jar 是IBM提供的MQTT协议的实现。

5. 如何使用ActiveMQ+MQTT实现Android点对点消息通知

2013-12-20
实现点对点消息通知的关键问题
ActiveMQ使用MQTT协议，加上android上的paho包，即可简单实现消息通知功能，但是mqtt协议只支持topic，而且不能用selector，使得点对点的消息投递变成问题。
有两个解决思路：
1、每个clientId，建一个topic...这个办法对解决消息点对点投递非常有效，但是有两个大问题:

随着用户数增多，topic数量增多，对管理性要求增大，对内存的管理也有问题。
消息广播操作也变得非常麻烦，只能一个个的发送了。

2、另一个思路，就是在消息广播的基础上，进行点对点控制，实现某些特征的消息投递到指定的订阅者。
这个的实现比较简单，而且没有上面方案的大问题。代码稍微改下即可：
其实就只添加了一个新的类： ClientIdFilterDispatchPolicy
可以git clone所在版本源码，然后加上这个类，mvn package以后使用。

使用说明
本修改实现mqtt协议使用单个topic，来做消息广播和点对点的投递。
1、将本文件夹下的activemq-broker-5.9.0.jar、activemq-spring-5.9.0.jar换掉apache-activemq-5.9.0\lib下的jar。
2、参考本文件夹下activemq.xml，在topic上配置
<dispatchPolicy>
<clientIdFilterDispatchPolicy />
</dispatchPolicy>
3、对于此配置下的所有名称以.PTP结尾的队列，
如果要投递消息的properties里包含PTP_CLIENTID，则系统只会将此消息发给clientId为此值的订阅者；如果当前没有此clientId的订阅者，消息不会被任何人接收到。
如果投递消息的properties里不包含PTP_CLIENTID，则消息广播给所有的订阅者。 跟正常消息投递一致。

其中后缀.PTP和键值PTP_CLIENTID，是可以配置的：
<dispatchPolicy>
<clientIdFilterDispatchPolicy ptpSuffix="" ptpClientId="clientId"/>
</dispatchPolicy>
如上配置，使得此policy下的所有topic都起作用，且消息的properties里获取clientId的key变成clientId。

消息发布者，如果要对所有人广播消息，直接发送消息即可。
如果要对指定的消息订阅者发消息，请在消息里设置接收者的clientId：

message.setStringProperty(PTP_CLIENTID, clientId);则此消息只有指定的订阅者可以拿到。
简单测试
两台android设备使用MQTT协议订阅到ActiveMQ的同一个topic，clientId分别为mqtt-1001和mqtt1002；
写代码发两条消息，设置消息属性中PTP_CLIENTID分别为mqtt-1001和mqtt1002；
两个设备分别接收到自己的消息通知，相互之间没有影响。还可以测试下如果消息没有PTP_CLIENTID，两个都能收到。

6. 请教 MQTT+SAM_PHP Android推送

$result = $conn->connect(SAM_MQTT, array(SAM_HOST => '127.0.0.1', SAM_PORT => 1883)); 楼主知道这句话是什么意思吗？推送给全部用户还不知道如何比较好的去做，但是你可以遍历你全部的注册用户，根据这些用户的ID逐一推送，android端连接时设备ID使用用户ID，这方法太笨拙了

7. PHP里 $mqtt->publish("bluerhinos/phpMQTT/patterns",date($patt),0);后面的路径是什么意思

两块钱解决你的问题。一，可以看出来这个是类对一个封装好了的方法进行调用，但是没有具体类的内容，所以不能知道具体作用。既然你知道这个是路径了，那也没错，没啥意思就是路径而已。

8. 如何通过php实现mqtt协议

MQTT是一个轻量级的消息发布/订阅协议，它是实现基于手机客户端的消息推送服务器的理想解决方案。

我们可以从这里下载该项目的实例代码，并且可以找到一个采用PHP书写的服务器端实现。

架构如下所示：

9. 用thinkphp 开发万人在线的聊天室性能跟得上么

首先聊天室主要的瓶颈并不在于用什么语言做后端，而在于整体处理架构。

当你打算做聊天室的时候你可以自己看看如何解决以下问题：

1. 数据的传输（如何及时把收到的数据传输给别人）

2. 数据库的处理（对于数据的操作，万人在线的聊天室数据量产生肯定很大，那么怎么保证数据库能扛得下去）

3. web服务器是否有能力对抗那么大的并发数量

4. 服务器的带宽是否能支撑下去

以上四点是基于B/S架构必有的问题，如果并非B/S架构那么后端也没必要使用PHP吧？

第一点、可以使用websocket进行解决，但缺点是不能支持旧版本的浏览器

（如果需要支持可以使用AJAX轮询进行处理，但会加大服务器压力）

第二点、可以增加缓存层，所有数据先进缓存，然后一定时间把缓存写入数据库。前提是需要内存足够大

（或者可以使用数据库中间件进行读写分离，或者直接分表处理）

第三点、再对WEB服务器优化后你能做的只有创建集群，用几台机去缓解压力

第四点、买带宽

说白了，没有一定的金钱做为支持的背景下thinkphp和c做出来的性能相差不大，因为瓶颈并不在它那