API for org.eclipse.paho.client.mqttv3

org.eclipse.paho.client.mqttv3的包结构如下：

org.eclipse.paho.client.mqttv3
Interfaces
    IMqttActionListener
    IMqttAsyncClient
    IMqttClient
    IMqttDeliveryToken
    MqttMessageListener
    IMqttToken
    MqttCallback
    MqttCallbackExtended
    MqttClientPersistence
    MqttPersistable
    MqttPingSender
Classes
    BufferedMessage
    DisconnectedBufferOptions
    MqttAsyncClient
    MqttClient
    MqttConnectOptions
    MqttDeliveryToken
    MqttMessage
    MqttToken
    MqttTopic
    TimerPingSender
Exceptions
    MqttException
    MqttPersistenceException
    MqttSecurityException
org.eclipse.paho.client.mqttv3.internal
Interfaces
    DestinationProvider
    IDisconnectedBufferCallback
    NetworkModule
Classes
    ClientComms
    ClientDefaults
    ClientState
    CommsCallback
    CommsReceiver
    CommsSender
    CommsTokenStore
    ConnectActionListener
    DisconnectedMessageBuffer
ExceptionHelper
    FileLock
    LocalNetworkModule
    MessageCatalog
    MqttPersistentData
    ResourceBundleCatalog
    SSLNetworkModule
    TCPNetworkModule
    Token
org.eclipse.paho.client.mqttv3.internal.security
Classes
    SimpleBase64Encoder
    SSLSocketFactoryFactory
org.eclipse.paho.client.mqttv3.internal.websocket
Classes
    Base64
    WebSocketFrame
    WebSocketHandshake
    WebSocketNetworkModule
    WebSocketReceiver
    WebSocketSecureNetworkModule
Exceptions
    HandshakeFailedException
org.eclipse.paho.client.mqttv3.internal.wire
Classes
    CountingInputStream
    MqttAck
    MqttConnack
    MqttConnect
    MqttDisconnect
    MqttInputStream
    MqttOutputStream
    MqttPersistableWireMessage
    MqttPingReq
    MqttPingResp
    MqttPubAck
    MqttPubComp
    MqttPublish
    MqttPubRec
    MqttPubRel
    MqttReceivedMessage
    MqttSuback
    MqttSubscribe
    MqttUnsubAck
    MqttUnsubscribe
    MqttWireMessage
    MultiByteArrayInputStream
    MultiByteInteger
org.eclipse.paho.client.mqttv3.logging
Interfaces
    Logger
Classes
    JSR47Logger
    LoggerFactory
    SimpleLogFormatter
org.eclipse.paho.client.mqttv3.persist
Classes
    MemoryPersistence
    MqttDefaultFilePersistence
org.eclipse.paho.client.mqttv3.util
Classes
    Debug
    Strings

摘要翻译如下：

 org.eclipse.paho.client.mqttv3
 -----Interfaces-----
IMqttActionListener
    void onSuccess(IMqttToken asyncActionToken)
    void onFailure(IMqttToken asyncActionToken, java.lang.Throwable exception)
        当异步操作完成时，将会通知该接口的实现者。监听器在MqttToken上注册，令牌与连接或发布等操作相关联。
        当与MqttAsyncClient上的令牌一起使用时，侦听器将在MQTT客户端的线程上被回调。 如果操作成功或失败，监听器将被通知。
        监听器快速返回控制非常重要，否则MQTT客户端的操作将会停止。
IMqttAsyncClient implements IMqttAsyncClient
        使应用程序能够使用非阻塞方法与MQTT服务器进行通信。使用非阻塞客户端允许应用程序使用阻塞和非阻塞样式的混合。
IMqttClient
        使用阻塞客户端只允许应用程序使用一种样式。 阻塞客户端提供了与早期版本的MQTT客户端的兼容性。
IMqttDeliveryToken extends IMqttToken
        IMqttToken的子类，跟踪消息的传递。
        与IMqttToken交付令牌的实例不同，可以在连接和客户端重新启动时使用。 这样可以在发送失败后跟踪消息。
IMqttMessageListener
        消息到达时会通知此接口的实现者。
IMqttToken
        提供跟踪异步任务完成的机制。
MqttCallback
        当发生与客户端相关的异步事件时，使应用程序得到通知。实现此接口的类可以在两种类型的客户端上注册：
        IMqttClient.setCallback(MqttCallback)和IMqttAsyncClient.setCallback(MqttCallback)
    void 	connectionLost (java.lang.Throwable cause)         当与服务器的连接丢失时调用此方法。
    void	deliveryComplete ( IMqttDeliveryToken token)    在消息传递完成时调用，并且已收到所有确认。
    void	messageArrived (java.lang.String topic, MqttMessage message)    当消息从服务器到达时调用此方法。
MqttCallbackExtended extends MqttCallback
        扩展MqttCallback以允许新的回调，而不会中断现有应用程序的API。 实现此接口的类可以在两种类型的客户端上注册：
        IMqttClient.setCallback(MqttCallback)和IMqttAsyncClient.setCallback(MqttCallback)
    void	connectComplete (boolean reconnect, java.lang.String serverURI)     当与服务器的连接成功完成时调用。
    继承的方法   connectionLost , deliveryComplete , messageArrived
MqttClientPersistence
        表示一个持久性数据存储，用于存储出站和入站邮件，以便传送到指定的QoS。
        您可以使用MqttClient.MqttClient(String, String, MqttClientPersistence)指定该接口的实现， MqttClient将使用该MqttClient来保持QoS 1 和 2 消息。
        如果定义的方法抛出MqttPersistenceException，那么数据持久化的状态应保持为被调用方法之前的状态。
        例如，如果put(String, MqttPersistable)在任何时候抛出异常，那么数据将被假定为不在持久存储中。
        同样，如果remove(String)抛出一个异常，那么数据将被认为仍然保存在持久性存储中。
        持久性接口由记录在诊断持续性故障时可能需要的任何异常或错误信息。
MqttPersistable
        表示一个对象，用于传递要在MqttClientPersistence接口上持久保存的数据。
        当数据通过接口传递时，标题和有效载荷是分开的，以避免不必要的消息拷贝。
MqttPingSender
        表示每个保持活动时间间隔用于向MQTT代理发送ping数据包的对象。
    void	init ( ClientComms comms)   初始方法。
    void	schedule (long delayInMilliseconds)     安排下一个ping在一定的延迟。
    void	start ()    开始ping发送者。
    void	stop ()     停止ping发件人。
========= Classes ========
BufferedMessage
        一个BufferedMessage包含一个MqttWire消息和令牌，它允许当客户端处于静止状态时缓冲消息和令牌
DisconnectedBufferOptions
        保存用于管理离线（或断开）缓冲消息行为的选项集
MqttAsyncClient
    轻量级客户端，使用允许在后台运行操作的非阻塞方法与MQTT服务器交互。
    默认情况下，使用MqttDefaultFilePersistence将消息存储到文件中。 如果将持久性设置为null，则消息将存储在内存中。
MqttClient implements IMqttClient
    轻量级客户端，使用阻塞操作完成的方法与MQTT服务器交互。
MqttConnectOptions
    保存一组控制客户端连接到服务器的选项。
    static boolean	CLEAN_SESSION_DEFAULT   如果没有指定默认清理会话设置
    static int	CONNECTION_TIMEOUT_DEFAULT  如果没有指定默认的连接超时时间（以秒为单位）
    static int	KEEP_ALIVE_INTERVAL_DEFAULT 如果未指定，则以秒为单位的默认保持活动时间间隔
    static int	MAX_INFLIGHT_DEFAULT    如果没有指定，则默认为最大航程
    static int	MQTT_VERSION_3_1
    static int	MQTT_VERSION_3_1_1
    static int	MQTT_VERSION_DEFAULT    首先默认的MqttVersion是3.1.1 ，如果失败，则返回到3.1
MqttDeliveryToken extends MqttToken implements IMqttDeliveryToken
    提供跟踪消息传递进度的机制。用于以非阻塞方式（在后台运行）跟踪消息的发送进度。
MqttMessage
    MQTT消息包含应用程序有效负载和选项，指定如何传递消息。消息包含表示为byte []的“payload”（消息体）。
MqttToken implements IMqttToken
    提供跟踪异步操作完成的机制。实现ImqttToken接口的令牌从所有非阻塞方法返回，发布除外。
MqttTopic      表示主题目标，用于发布/订阅消息传递。
TimerPingSender implements MqttPingSender
    默认ping发送者执行
    这个类实现了IMqttPingSender pinger接口，允许应用程序在每个活动时间间隔IMqttPingSender服务器发送ping数据包。
==== Exceptions ====
MqttExceptionn extends Exception
MqttPersistenceException extends MqttException
MqttSecurityException extends MqttException
=========================================

-----------  org.eclipse.paho.client.mqttv3.internal -----------------
======== Interfaces ========
DestinationProvider
        这个接口可以作为MqttClient和MqttMIDPClient的一个通用类型，所以它们可以传递给ClientComms而不需要客户端类需要知道另一个。
        具体而言，这允许MIDP客户端在没有非MIDP MqttClient / MqttConnectOptions类的情况下工作。
        MqttTopic	getTopic (java.lang.String topic)
IDisconnectedBufferCallback
    void	publishBufferedMessage ( BufferedMessage bufferedMessage)
NetworkModule
    java.io.InputStream	getInputStream ()
java.io.OutputStream	getOutputStream ()
java.lang.String	getServerURI ()
void	start ()
void	stop ()
======== Classes ========
ClientComms
    处理与服务器的客户端通信。 发送和接收MQTT V3消息。
ClientDefaults
    public static final int MAX_MSG_SIZE = 1024 * 1024 * 256; // 256 MB
ClientState
    客户端的核心，它保存待处理和正在进行的消息的状态信息。 已经被接受发送的消息在被递送的同时在几个对象之间移动。
    1）当客户端没有运行时，消息被存储在一个实现了MqttClientPersistent接口的持久性存储中。
    默认是MqttDefaultFilePersistencew，它可以跨越故障和系统重新启动安全地存储消息。
    如果没有指定持久性，则返回到MemoryPersistence，这将在Mqtt客户端实例化时维护消息。
    2）当客户端或特定的ClientState被实例化时，将消息从持久性存储中读取到：
    - outboundqos2哈希表，如果QoS 2 PUBLISH或PUBREL - outboundqos1哈希表如果QoS 1 PUBLISH（参见restoreState）
    3）On Connect，复制消息以messageid顺序将出站哈希表添加到pendingMessages或pendingFlows向量中。
    - 初始消息发布进入pendingmessages缓冲区。 - PUBREL进入待处理缓冲区（参见restoreInflightMessages）
    4）发送程序线程从待处理流和待处理消息缓冲区中读取消息。 该消息将从pendingbuffer中删除，但保留在出站*哈希表。
    哈希表是将全部未完成消息存储在内存中的地方。 （持久性仅在启动时使用）
    5）接收器线程 - 接收有线消息： - 如果QoS 1则从持久性中移除，outboundqos1 - 如果QoS 2 PUBREC发送PUBREL。
    使用PUBREL更新outboundqos2条目并更新持久性。 - 如果QoS 2 PUBCOMP从持久性和outboundqos2中移除注意：
    由于客户端的多线程特性，对这个类的任何修改都考虑到并发性至关重要。
    例如，只要流量/消息放在线路上，接收线程就可以接收确认并在发送方完成处理之前处理响应。
    例如连接可能被发送，在连接通知发送之前收到的conack已经被处理！
CommsCallback implements Runnable
    Receiver和外部API之间的桥梁。 此类由Receiver调用，然后将以通信为中心的MQTT消息对象转换为由外部API理解的对象。
CommsReceiver implements Runnable
    接收来自服务器的MQTT数据包。
CommsSender implements Runnable
CommsTokenStore
    提供基于“令牌”的系统来存储和跟踪跨多个线程的操作。
    发送消息时，令牌与消息相关联，并使用saveToken(MqttToken, MqttWireMessage)方法保存。
    任何对这个状态感兴趣的人都可以调用令牌上的一个等待方法，或者在操作上使用异步监听器回调方法。
    另一个线程上的CommsReceiver类从网络读取响应。 它使用响应来查找相关令牌，然后可以通知它。
    注：Ping，连接和断开连接没有唯一的消息ID，因为每种类型的只有一个未决的请求被允许未完成
ConnectActionListener implements IMqttActionListener
    这个类处理AsyncClient到一个可用URL的连接。
    这些URL在创建客户端时作为单例提供，或作为连接选项中的列表提供。
    这个类使用自己的onSuccess和onFailure回调优先于用户提供的回调。
    尝试连接到列表中的每个URL，直到连接尝试成功或尝试了所有URL
    如果连接成功，则会通知用户令牌，并调用用户onSuccess回调。
    如果连接失败，则尝试列表中的另一个URL，否则将通知用户令牌，并调用用户onFailure回调
    void	connect ()  开始连接处理
    void	onFailure ( IMqttToken token, java.lang.Throwable exception) 连接失败，请尝试列表中的下一个URI。
    void	onSuccess ( IMqttToken token)   如果连接成功，则调用用户onSuccess回调
    void	setMqttCallbackExtended ( MqttCallbackExtended mqttCallbackExtended)    设置MqttCallbackExtened回调接收connectComplete回调
DisconnectedMessageBuffer implements Runnable
ExceptionHelper
    工具类可帮助创建正确类型的例外。
FileLock
LocalNetworkModule implements NetworkModule
    特殊的comms类，允许MQTT客户机在与MQTT服务器运行在同一JRE实例中时，使用非TCP /优化机制与MQTT服务器交谈。
    这个类检查是否存在优化的通信协议类，即提供优化的通信机制的类。 如果不可用，则使用优化机制进行连接的请求将被拒绝。
    实现这一点的唯一已知的服务器是微型经纪人： - 一个与许多IBM产品一起提供的MQTT服务器。
public abstract class MessageCatalog
    private static MessageCatalog INSTANCE = null;
    人类可读的错误信息目录。
MqttPersistentData implements MqttPersistable
ResourceBundleCatalog extends MessageCatalog
SSLNetworkModule extends TCPNetworkModule
        用于通过SSL连接的网络模块。
TCPNetworkModule implements NetworkModule
        一个通过TCP连接的网络模块。
Token
==============================
org.eclipse.paho.client.mqttv3.internal.security
==============================
Classes
SimpleBase64Encoder
    private static final String PWDCHARS_STRING = "./0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
	private static final char[] PWDCHARS_ARRAY = PWDCHARS_STRING.toCharArray();
    public static String encode(byte[] bytes)
    public static byte[] decode(String string)
    private final static String to64(long input, int size)
    private final static long from64(byte[] encoded, int idx, int size)
SSLSocketFactoryFactory
    一个SSLSocketFactoryFactory提供了一个套接字工厂和一个服务器套接字工厂，然后可以用来创建SSL客户端套接字或SSL服务器套接字。
    SSLSocketFactoryFactory使用IBM SSL属性进行配置，即格式为“com.ibm.ssl.propertyName”的属性，例如“com.ibm.ssl.keyStore”。 该类支持多种配置，每种配置都使用名称或配置ID进行标识。 使用“null”的配置ID作为默认配置。 当为给定配置创建套接字工厂时，首先会选择该配置的属性。 如果在那里没有定义属性，那么在默认配置中查找该属性。 最后，如果还没有找到属性元素，则检查相应的系统属性，即javax.net.ssl.keyStore。 如果系统属性没有设置，那么使用系统的默认值（如果可用）或引发异常。
    SSLSocketFacotryFactory可以在任何时候重新配置。 重新配置不会影响现有套接字工厂。
    所有的属性共享相同的密钥空间; 即配置ID不是属性键的一部分。
    应按以下顺序调用方法：
    isSupportedOnJVM（） ：检查此类是否在运行时平台上受支持。 并非所有运行时支持SSL / TLS。
    SSLSocketFactoryFactory（） ：构造函数。 客户端（在同一个JVM中）可能共享一个SSLSocketFactoryFactory，或者每个都有一个。
    initialize（properties，configID） ：用配置所需的SSL属性初始化此对象。 这可能会被调用多次，每次需要配置一次。它可能会被再次调用来更改特定配置所需的SSL属性
    getEnabledCipherSuites（configID） ：稍后在套接字上设置启用的密码套件[见下文]。
    对于MQTT服务器：
    getKeyStore（configID） ：或者，要检查是否没有密钥库，那么所有启用的密码套件都是匿名的。
    createServerSocketFactory（configID） ：创建一个SSLServerSocketFactory。
    getClientAuthentication（configID） ：稍后在SSLServerSocket（自身从SSLServerSocketFactory创建）上设置是否需要客户端身份验证。
    对于MQTT客户端：
    createSocketFactory（configID） ：创建一个SSLSocketFactory。
================================
org.eclipse.paho.client.mqttv3.internal.websocket
==== Classes ====
Base64
	private static final Base64 instance = new Base64();
	private static final Base64Encoder encoder = instance.new Base64Encoder();
    public static String encode (String s)
    public static String encodeBytes (byte[] b)
    public class Base64Encoder extends AbstractPreferences
WebSocketFrame  公共类
WebSocketHandshake  公共类。Helper类执行WebSocket握手。
WebSocketNetworkModule extends TCPNetworkModule
WebSocketReceiver implements Runnable
WebSocketSecureNetworkModule extends SSLNetworkModule
==== Exceptions ====
HandshakeFailedException extends Exception
	{ private static final long serialVersionUID = 1L; }
==============================
org.eclipse.paho.client.mqttv3.internal.wire
==============================
==== Classes ====
CountingInputStream extends InputStream
    计数从中读取的字节的输入流。
   	private InputStream in;
	private int counter;
    public CountingInputStream(InputStream in)
    public int read() throws IOException
    public int getCounter() {		return counter;	}
    public void resetCounter() {		counter = 0;	}
MqttAck extends MqttWireMessage
    所有确认消息的抽象超类。
   	public MqttAck(byte type) {	super(type);	}
	protected byte getMessageInfo() {		return 0;	}
MqttConnack extends MqttAck
    MQTT CONNACK的在线表示。
    	public static final String KEY = "Con";
        private int returnCode;
        private boolean sessionPresent;
MqttConnect extends MqttWireMessage
	private String clientId;
	private boolean cleanSession;
	private MqttMessage willMessage;
	private String userName;
	private char[] password;
	private int keepAliveInterval;
	private String willDestination;
	private int MqttVersion;
MqttDisconnect extends MqttWireMessage

MqttInputStream extends InputStream
    一个MqttInputStream让应用程序读取MqttWireMessage实例。
    private static final String CLASS_NAME = MqttInputStream.class.getName();
	private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
	private ClientState clientState = null;
	private DataInputStream in;
MqttOutputStream extends OutputStream
    一个MqttOutputStream让应用程序编写MqttWireMessage实例。
    private static final String CLASS_NAME = MqttOutputStream.class.getName();
	private static final Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);
	private ClientState clientState = null;
	private BufferedOutputStream out;
MqttPersistableWireMessage extends MqttWireMessage	implements MqttPersistable
MqttPingReq extends MqttWireMessage
MqttPingResp extends MqttAck
MqttPubAck extends MqttAck
MqttPubComp extends MqttAck
MqttPublish extends MqttPersistableWireMessage
MqttPubRec extends MqttAck
MqttPubRel extends MqttPersistableWireMessage
MqttReceivedMessage extends MqttMessage
MqttSuback extends MqttAck
MqttSubscribe extends MqttWireMessage
MqttUnsubAck extends MqttAck
MqttUnsubscribe extends MqttWireMessage
public abstract class MqttWireMessage
MultiByteArrayInputStream extends InputStream
	private byte[] bytesA;
	private int offsetA;
	private int lengthA;
	private byte[] bytesB;
	private int offsetB;
	private int lengthB;
	private int pos = 0;
	public MultiByteArrayInputStream(byte[] bytesA, int offsetA, int lengthA, byte[] bytesB, int offsetB, int lengthB){ }
    public int read() throws IOException{ }
MultiByteInteger
    表示由MQTT V3规范定义的多字节整数（MBI）。
    private long value;
	private int length;
    public MultiByteInteger(long value)
    public MultiByteInteger(long value, int length)
    public int getEncodedLength()
    public long getValue()
========================
org.eclipse.paho.client.mqttv3.logging
========================
==== Interfaces ====
Logger
==== Classes ====
JSR47Logger implements Logger
    使用java.uti.logging的记录器接口的实现使用Java内置日志记录工具的记录器 - java.util.logging。
    提供了一个示例java.util.logging属性文件 - jsr47min.properties，演示了如何使用基于内存的跟踪工具运行，该工具以最低的性能开销运行。
    当记录/跟踪记录被写入与MemoryHandler触发器级别匹配或在MemoryHandler上调用push方法时，可以转储内存缓冲区。
    Debug提供的方法可以很容易地转储内存缓冲区以及其他有用的调试信息。
LoggerFactory
    返回记录器以供MQTT客户端使用的工厂。 默认的日志和跟踪工具使用Java在日志工具中的构建：
    - java.util.logging。 对于不可用的系统或需要替代日志框架的系统，可以使用setLogger(String)来替换日志工具，该日志工具需要实现Logger接口。
SimpleLogFormatter extends Formatter
    以可读形式打印单行日志记录。
========================
org.eclipse.paho.client.mqttv3.persist
==== Classes ====
MemoryPersistence implements MqttClientPersistence
    使用内存的持久性在客户端或设备不需要可靠性重新启动内存的情况下，可以使用该内存持久性。
    在需要可靠性的情况下，例如当clean session设置为false时，应使用非易失性形式的持久性。
MqttDefaultFilePersistence implements MqttClientPersistence
    提供基于文件的持久性的MqttClientPersistence接口的实现。 当创建Persistence对象时指定一个目录。
    当持久性被打开时（见open(String, String) ），在这个客户端ID和连接键的基础下创建一个子目录。
    这允许一个持久性基目录被多个客户共享。
    子目录的名称是通过将客户端ID和连接键与‘/‘，‘\\‘，‘：‘或‘‘的任何实例连接而创建的。
========================
org.eclipse.paho.client.mqttv3.util
==== Classes ====
Debug
    用于帮助调试Paho MQTT客户端问题的实用程序一旦初始化对dumpClientDebug的调用，将强制将任何内存跟踪与相关客户端和系统状态一起加载到主日志设施。
    转储进行时，不会执行客户端宽锁。 这意味着客户端状态的集合可能不一致，因为客户端在转储过程中仍可能正在处理工作。
Strings
    字符串助手
========= END ===========
时间： 2024-11-04 20:10:58

API for org.eclipse.paho.client.mqttv3的相关文章

org.eclipse.paho.client mqtt客户端连接超时

客户端订阅mqtt 的时候 显示超时.第二次重起服务可能就好了,但是可能会丢消息. 报错如下 org.eclipse.paho.client.mqttv3.MqttException: 等待来自服务器的响应时超时 at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:31) ~[org.eclipse.paho.client.mqttv3-1.2.1.

MQTT协议实现Eclipse Paho学习总结二

一.概述 前一篇博客(MQTT协议实现Eclipse Paho学习总结一) 写了一些MQTT协议相关的一些概述和其实现Eclipse Paho的报文类别,同时对心跳包进行了分析.这篇文章,在不涉及MQTT逻辑实现的基础之上分析一下Eclipse Paho中Socket通信的实现,这里我们主要阐述其采用Java同步技术将同步的Socket通信异步化的过程. 二.上菜 先看一下在org.eclipse.paho.client.mqttv3.internal有两个类,CommsSender,Comms

MQTT协议实现Eclipse Paho学习总结

转载自:http://xiaoxinzhou.blog.163.com/blog/static/20704538620145411306821/ 一.概述 遥测传输 (MQTT) 是轻量级基于代理的发布/订阅的消息传输协议,设计思想是开放.简单.轻量.易于实现.这些特点使它适用于受限环境.例如,但不仅限于此: 网络代价昂贵,带宽低.不可靠. 在嵌入设备中运行,处理器和内存资源有限. 该协议的特点有: 使用发布/订阅消息模式,提供一对多的消息发布,解除应用程序耦合. 对负载内容屏蔽的消息传输. 使

[3] MQTT,mosquitto,Eclipse Paho---如何使用 Eclipse Paho MQTT工具来发送订阅MQTT消息？

在上两节,笔者主要介绍了 MQTT,mosquitto,Eclipse Paho的基本概念已经如何安装mosquitto. 在这个章节我们就来看看如何用 Eclipse Paho MQTT工具来发送接收MQTT消息.Eclipse Paho MQTT工具是一个基于Java的Eclipse桌面客户端程序,其底层的和MQTT服务器进行的交互的java类库就是Eclipse Paho java库.假设我们在本机(127.0.0.1)已经启动了一个mosquitto MQTT服务器,其端口为1883.如

eclipse中Client/Server程序生成exe

先建两个Java Project项目,一个写Client,一个写Server端程序,程序大致为一个Server端建立监听某个端口,多个Client端可以连接,实现如下: 1.      Server端 importjava.io.*; importjava.net.*; importjava.util.*; publicclass SimpleChatServer { ArrayList<PrintWriter>clientOutputStreams; public static void m

[8] MQTT,mosquitto,Eclipse Paho---MQTT消息格式之SUBSCRIBE(消息订阅)消息分析

0.前言 我们在上几节的协议分析中,发送连接的请求用的是Eclipse Paho MQTT工具,那么笔者这一次改一下,咱们这次用代码来发送Subscribe的MQTT消息,请注意,下面的代码是基于Eclipse Paho Java API之上的代码,在运行下面的代码前,请先去下载Eclipse Paho Java库,其下载地址为:https://www.eclipse.org/paho/clients/java/. 下面我们正式切入正题. 1.准备步骤 (1) 首先打开WireShark软件,并

[9] MQTT,mosquitto,Eclipse Paho---MQTT消息格式之SUBACK(消息订阅应答)消息分析

0.前言 在上一节中(MQTT消息格式之SUBSCRIBE(消息订阅)消息分析),客户端发送了订阅的消息,这个时候,服务器端收到订阅主题的MQTT消息之后,肯定需要给一个应答,这个应答信息就是SUBACK(消息订阅应答).消息订阅应答相对来说比较简单. 1.准备步骤 (1) 首先打开WireShark软件,并启动监听 (2) 在Eclipse里面运行下面的代码 [java] view plaincopy import org.eclipse.paho.client.mqttv3.MqttClie

MQTT 消息 发布 订阅

当连接向一个mqtt服务器时,clientId必须是唯一的.设置一样,导致client.setCallback总是走到 connectionLost回调.报connection reset.调查一天才发现是clientid重复导致. client = new MqttAsyncClient(serverURIString, "client-id"); clientId是用来保存会话信息. MqttConnectOptions options = new MqttConnectOptio

MQTT协议的简单介绍和服务器的安装

转:http://blog.csdn.net/djun100/article/details/25752491 最近公司做的项目中有用到消息推送,经过多方面的筛选之后确定了使用MQTT协议,相对于XMPP,MQTT更加轻量级,并且占用用户很少的带宽. MQTT是IBM推出的一种针对移动终端设备的基于TCP/IP的发布/预订协议,可以连接大量的远程传感器和控制设备. MQTT的官网见:http://mqtt.org/.其中http://mqtt.org/software里面提供了官方推荐的各种服务