实例介绍
【实例简介】
很出名mqtt的开源代码, 这个是java版本。目前支持mqtt3.1.1版本。自测完美。
【实例截图】
【核心代码】
zhyanbadboy_10753959
└── paho.mqtt.java-master
├── about.html
├── CODE_OF_CONDUCT.md
├── CONTRIBUTING.md
├── edl-v10
├── epl-v10
├── notice.html
├── org.eclipse.paho.client.eclipse.feature
│ ├── build.properties
│ ├── epl-v10.html
│ ├── feature.properties
│ ├── feature.xml
│ ├── license.html
│ └── pom.xml
├── org.eclipse.paho.client.eclipse.view
│ ├── build.properties
│ ├── icons
│ │ ├── mqtt_view.png
│ │ └── paho.png
│ ├── META-INF
│ │ └── MANIFEST.MF
│ ├── plugin.properties
│ ├── plugin.xml
│ ├── pom.xml
│ ├── README.md
│ └── src
│ └── org
│ └── eclipse
│ └── paho
│ └── client
│ └── eclipse
│ └── view
│ ├── Activator.java
│ ├── ClientConstants.java
│ ├── Messages.java
│ ├── messages.properties
│ └── MqttClientView.java
├── org.eclipse.paho.client.mqttv3
│ ├── build.properties
│ ├── build.xml
│ ├── META-INF
│ │ └── MANIFEST.MF
│ ├── pom.xml
│ └── src
│ └── main
│ ├── java
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ ├── BufferedMessage.java
│ │ ├── DisconnectedBufferOptions.java
│ │ ├── IMqttActionListener.java
│ │ ├── IMqttAsyncClient.java
│ │ ├── IMqttClient.java
│ │ ├── IMqttDeliveryToken.java
│ │ ├── IMqttMessageListener.java
│ │ ├── IMqttToken.java
│ │ ├── internal
│ │ │ ├── ClientDefaults.java
│ │ │ ├── ClientState.java
│ │ │ ├── CommsCallback.java
│ │ │ ├── CommsReceiver.java
│ │ │ ├── CommsSender.java
│ │ │ ├── CommsTokenStore.java
│ │ │ ├── ConnectActionListener.java
│ │ │ ├── DestinationProvider.java
│ │ │ ├── DisconnectedMessageBuffer.java
│ │ │ ├── ExceptionHelper.java
│ │ │ ├── FileLock.java
│ │ │ ├── IDisconnectedBufferCallback.java
│ │ │ ├── MessageCatalog.java
│ │ │ ├── MqttPersistentData.java
│ │ │ ├── NetworkModule.java
│ │ │ ├── ResourceBundleCatalog.java
│ │ │ ├── security
│ │ │ │ ├── SimpleBase64Encoder.java
│ │ │ │ └── SSLSocketFactoryFactory.java
│ │ │ ├── SSLNetworkModule.java
│ │ │ ├── TCPNetworkModule.java
│ │ │ ├── Token.java
│ │ │ ├── websocket
│ │ │ │ ├── Base64.java
│ │ │ │ ├── ExtendedByteArrayOutputStream.java
│ │ │ │ ├── HandshakeFailedException.java
│ │ │ │ ├── WebSocketFrame.java
│ │ │ │ ├── WebSocketHandshake.java
│ │ │ │ ├── WebSocketNetworkModule.java
│ │ │ │ ├── WebSocketReceiver.java
│ │ │ │ └── WebSocketSecureNetworkModule.java
│ │ │ └── wire
│ │ │ ├── CountingInputStream.java
│ │ │ ├── MqttAck.java
│ │ │ ├── MqttConnack.java
│ │ │ ├── MqttConnect.java
│ │ │ ├── MqttDisconnect.java
│ │ │ ├── MqttInputStream.java
│ │ │ ├── MqttOutputStream.java
│ │ │ ├── MqttPersistableWireMessage.java
│ │ │ ├── MqttPingReq.java
│ │ │ ├── MqttPingResp.java
│ │ │ ├── MqttPubAck.java
│ │ │ ├── MqttPubComp.java
│ │ │ ├── MqttPublish.java
│ │ │ ├── MqttPubRec.java
│ │ │ ├── MqttPubRel.java
│ │ │ ├── MqttReceivedMessage.java
│ │ │ ├── MqttSuback.java
│ │ │ ├── MqttSubscribe.java
│ │ │ ├── MqttUnsubAck.java
│ │ │ ├── MqttUnsubscribe.java
│ │ │ ├── MqttWireMessage.java
│ │ │ ├── MultiByteArrayInputStream.java
│ │ │ └── MultiByteInteger.java
│ │ ├── logging
│ │ │ ├── JSR47Logger.java
│ │ │ ├── jsr47min.properties
│ │ │ ├── LoggerFactory.java
│ │ │ ├── Logger.java
│ │ │ ├── package.html
│ │ │ └── SimpleLogFormatter.java
│ │ ├── MqttAsyncClient.java
│ │ ├── MqttCallbackExtended.java
│ │ ├── MqttCallback.java
│ │ ├── MqttClient.java
│ │ ├── MqttClientPersistence.java
│ │ ├── MqttConnectOptions.java
│ │ ├── MqttDeliveryToken.java
│ │ ├── MqttException.java
│ │ ├── MqttMessage.java
│ │ ├── MqttPersistable.java
│ │ ├── MqttPersistenceException.java
│ │ ├── MqttPingSender.java
│ │ ├── MqttSecurityException.java
│ │ ├── MqttToken.java
│ │ ├── MqttTopic.java
│ │ ├── package.html
│ │ ├── persist
│ │ │ ├── MemoryPersistence.java
│ │ │ ├── MqttDefaultFilePersistence.java
│ │ │ ├── package.html
│ │ │ ├── PersistanceFileFilter.java
│ │ │ └── PersistanceFileNameFilter.java
│ │ ├── ScheduledExecutorPingSender.java
│ │ ├── TimerPingSender.java
│ │ └── util
│ │ ├── Debug.java
│ │ ├── package.html
│ │ └── Strings.java
│ ├── java-templates
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ └── internal
│ │ └── ClientComms.java
│ └── resources
│ ├── bundle.properties
│ └── org
│ └── eclipse
│ └── paho
│ └── client
│ └── mqttv3
│ └── internal
│ └── nls
│ ├── logcat.properties
│ ├── messages_cs.properties
│ ├── messages_de.properties
│ ├── messages_es.properties
│ ├── messages_fr.properties
│ ├── messages_hu.properties
│ ├── messages_it.properties
│ ├── messages_ja.properties
│ ├── messages_ko.properties
│ ├── messages_pl.properties
│ ├── messages.properties
│ ├── messages_pt_BR.properties
│ ├── messages_ru.properties
│ ├── messages_zh_CN.properties
│ └── messages_zh_TW.properties
├── org.eclipse.paho.client.mqttv3.internal.traceformat
│ ├── build.xml
│ └── src
│ └── main
│ └── java
│ └── org
│ └── eclipse
│ └── paho
│ └── client
│ └── mqttv3
│ └── internal
│ └── logBuilder
│ └── LogMessageExtractor.java
├── org.eclipse.paho.client.mqttv3.repository
│ ├── category.xml
│ └── pom.xml
├── org.eclipse.paho.client.mqttv3.test
│ ├── pom.xml
│ └── src
│ └── test
│ ├── java
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ └── test
│ │ ├── automaticReconnect
│ │ │ ├── AutomaticReconnectTest.java
│ │ │ └── OfflineBufferingTest.java
│ │ ├── BasicSSLTest.java
│ │ ├── BasicTest.java
│ │ ├── Bug443142Test.java
│ │ ├── client
│ │ │ ├── MqttAsyncClientPaho.java
│ │ │ ├── MqttClientFactoryPaho.java
│ │ │ └── MqttClientPaho.java
│ │ ├── ConformantTest.java.notrun
│ │ ├── connectionLoss
│ │ │ └── ConnectionLossTest.java
│ │ ├── Issue370Test.java
│ │ ├── LiveTakeOverTest.java
│ │ ├── logging
│ │ │ ├── ConsoleHandler.java
│ │ │ ├── DetailFormatter.java
│ │ │ ├── HumanFormatter.java
│ │ │ ├── LoggerDumper.java
│ │ │ ├── LoggerNode.java
│ │ │ ├── LoggingUtilities.java
│ │ │ ├── ObjectFormatter.java
│ │ │ └── TraceFormatter.java
│ │ ├── ModelTestCase.java
│ │ ├── MqttTopicTest.java
│ │ ├── PerSubscriptionMessageHandlerTest.java
│ │ ├── properties
│ │ │ └── TestProperties.java
│ │ ├── SendReceiveAsyncCallbackTest.java
│ │ ├── SendReceiveAsyncTest.java
│ │ ├── SendReceiveTest.java
│ │ ├── SSLSessionResumptionTest.java
│ │ ├── utilities
│ │ │ ├── ConnectionManipulationProxyServer.java
│ │ │ ├── MqttV3Receiver.java
│ │ │ ├── StringUtilities.java
│ │ │ ├── TestMemoryPersistence.java
│ │ │ └── Utility.java
│ │ └── WebSocketTest.java
│ └── resources
│ ├── clientkeystore.jks
│ ├── iot.eclipse.org.crt
│ ├── logging.properties
│ └── test.properties
├── org.eclipse.paho.jmeclient
│ ├── org.eclipse.paho.jmeclient.mqttv3
│ │ ├── bin
│ │ │ └── org
│ │ │ └── eclipse
│ │ │ └── paho
│ │ │ └── client
│ │ │ └── mqttv3
│ │ │ ├── internal
│ │ │ │ └── nls
│ │ │ │ ├── logcat_cs.properties
│ │ │ │ ├── logcat_de.properties
│ │ │ │ ├── logcat_es.properties
│ │ │ │ ├── logcat_fr.properties
│ │ │ │ ├── logcat_hu.properties
│ │ │ │ ├── logcat_it.properties
│ │ │ │ ├── logcat_ja.properties
│ │ │ │ ├── logcat_ko.properties
│ │ │ │ ├── logcat_pl.properties
│ │ │ │ ├── logcat.properties
│ │ │ │ ├── logcat_pt_BR.properties
│ │ │ │ ├── logcat_ru.properties
│ │ │ │ ├── logcat_zh_CN.properties
│ │ │ │ ├── logcat_zh_TW.properties
│ │ │ │ ├── messages_cs.properties
│ │ │ │ ├── messages_de.properties
│ │ │ │ ├── messages_es.properties
│ │ │ │ ├── messages_fr.properties
│ │ │ │ ├── messages_hu.properties
│ │ │ │ ├── messages_it.properties
│ │ │ │ ├── messages_ja.properties
│ │ │ │ ├── messages_ko.properties
│ │ │ │ ├── messages_pl.properties
│ │ │ │ ├── messages.properties
│ │ │ │ ├── messages_pt_BR.properties
│ │ │ │ ├── messages_ru.properties
│ │ │ │ ├── messages_zh_CN.properties
│ │ │ │ └── messages_zh_TW.properties
│ │ │ ├── package.html
│ │ │ ├── persist
│ │ │ │ └── package.html
│ │ │ └── util
│ │ │ └── package.html
│ │ ├── build.xml
│ │ ├── META-INF
│ │ │ └── MANIFEST.MF
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ ├── internal
│ │ │ ├── MicroCatalog.java
│ │ │ ├── MqttMicroNetworkFactory.java
│ │ │ ├── SSLMicroNetworkModule.java
│ │ │ └── TCPMicroNetworkModule.java
│ │ ├── logging
│ │ │ ├── EmptyLogger.java
│ │ │ ├── LoggerFactory.java
│ │ │ └── Logger.java
│ │ ├── MqttConnectOptions.java
│ │ ├── package.html
│ │ ├── persist
│ │ │ ├── MqttDefaultMicroFilePersistence.java
│ │ │ ├── MqttDefaultMicroPersistence.java
│ │ │ └── package.html
│ │ └── util
│ │ ├── package.html
│ │ └── PropertyResourceBundle.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOBasicSyncTestCase
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── test
│ │ ├── BasicSyncTestCaseMIDP.java
│ │ ├── GPIOTest.java
│ │ ├── Iterator.java
│ │ └── SimpleList.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOSample
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleGPIO
│ │ └── GPIOSample.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOSampleAsyncCallBack
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleGPIO
│ │ └── AsyncCallback
│ │ ├── GPIOSampleAsyncCallback.java
│ │ └── SampleAsyncCallback.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOSampleAsyncWait
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleGPIO
│ │ └── AsyncWait
│ │ ├── GPIOSampleAsyncWait.java
│ │ └── SampleAsyncWait.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.Logging
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ ├── logging
│ │ │ ├── Logging.java
│ │ │ └── SimpleLogFormatter.java
│ │ └── util
│ │ ├── ConsoleHandler.java
│ │ ├── FileHandler.java
│ │ └── MemoryHandler.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.MIDPLogging
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ └── logging
│ │ ├── MIDPLogFormatter.java
│ │ └── MIDPLogging.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.MIDPSample
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── microlog.properties
│ │ ├── res
│ │ │ └── microlog.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleMIDP
│ │ ├── IA92.java
│ │ ├── WmqttGauge.java
│ │ └── WmqttMgr.java
│ └── README.md
├── org.eclipse.paho.sample.mqttv3app
│ ├── launchers
│ │ ├── MqttPublisher.launch
│ │ └── MqttSubscriber.launch
│ ├── META-INF
│ │ └── MANIFEST.MF
│ └── src
│ └── main
│ └── java
│ └── org
│ └── eclipse
│ └── paho
│ └── sample
│ └── mqttv3app
│ ├── SampleAsyncCallBack.java
│ ├── SampleAsyncWait.java
│ └── Sample.java
├── org.eclipse.paho.sample.utility
│ ├── build.xml
│ ├── pom.xml
│ └── src
│ └── main
│ ├── java
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── sample
│ │ └── utility
│ │ ├── ConnOpts.java
│ │ ├── LED.java
│ │ ├── MQTTFrame.java
│ │ ├── MQTTHist.java
│ │ ├── PubPanel.java
│ │ └── SubPanel.java
│ └── resources
│ ├── META-INF
│ │ └── MANIFEST.MF
│ └── mqtt.properties
├── org.eclipse.paho.ui
│ ├── org.eclipse.paho.ui.app
│ │ ├── org.eclipse.paho.ui.app.product
│ │ └── pom.xml
│ ├── org.eclipse.paho.ui.core
│ │ ├── build.properties
│ │ ├── icons
│ │ │ ├── add.gif
│ │ │ ├── add_gray.gif
│ │ │ ├── clear.gif
│ │ │ ├── connection_edit.gif
│ │ │ ├── connection.gif
│ │ │ ├── connection_gray.gif
│ │ │ ├── history.gif
│ │ │ ├── lastmsg.gif
│ │ │ ├── mqtt.gif
│ │ │ ├── options.gif
│ │ │ ├── paho_logo_100.png
│ │ │ ├── paho_logo_400.png
│ │ │ ├── paho_logo.eps
│ │ │ ├── paho_logo_full.png
│ │ │ ├── paho.png
│ │ │ ├── paho-small.png
│ │ │ ├── remove.gif
│ │ │ └── remove_gray.gif
│ │ ├── META-INF
│ │ │ └── MANIFEST.MF
│ │ ├── OSGI-INF
│ │ │ └── l10n
│ │ │ └── bundle.properties
│ │ ├── plugin_customization.ini
│ │ ├── plugin.xml
│ │ ├── pom.xml
│ │ ├── product_lg.png
│ │ ├── splash.bmp
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── mqtt
│ │ └── ui
│ │ ├── actions
│ │ │ └── NewConnectionAction.java
│ │ ├── Activator.java
│ │ ├── ApplicationActionBarAdvisor.java
│ │ ├── Application.java
│ │ ├── ApplicationWorkbenchAdvisor.java
│ │ ├── ApplicationWorkbenchWindowAdvisor.java
│ │ ├── Constants.java
│ │ ├── core
│ │ │ ├── DataBindings.java
│ │ │ ├── event
│ │ │ │ ├── Event.java
│ │ │ │ ├── Events.java
│ │ │ │ ├── IEventHandler.java
│ │ │ │ ├── IEventService.java
│ │ │ │ ├── internal
│ │ │ │ │ ├── EventService.java
│ │ │ │ │ └── Registration.java
│ │ │ │ ├── IRegistration.java
│ │ │ │ ├── Registrations.java
│ │ │ │ └── Selector.java
│ │ │ ├── IConnectionManager.java
│ │ │ ├── internal
│ │ │ │ └── ConnectionManager.java
│ │ │ └── model
│ │ │ ├── Bindable.java
│ │ │ ├── Connection.java
│ │ │ ├── History.java
│ │ │ ├── Login.java
│ │ │ ├── LWT.java
│ │ │ ├── Pair.java
│ │ │ ├── PublishMessage.java
│ │ │ ├── QoS.java
│ │ │ ├── ServerURI.java
│ │ │ ├── SSLOptions.java
│ │ │ └── Topic.java
│ │ ├── nls
│ │ │ ├── Messages.java
│ │ │ ├── messages.properties
│ │ │ └── messages_zh_CN.properties
│ │ ├── PahoException.java
│ │ ├── Paho.java
│ │ ├── Perspective.java
│ │ ├── support
│ │ │ ├── fieldassist
│ │ │ │ ├── ControlDecorationSupport.java
│ │ │ │ └── ControlDecorationUpdater.java
│ │ │ ├── provider
│ │ │ │ ├── IValueFormatter.java
│ │ │ │ └── PropertyCellLabelProvider.java
│ │ │ ├── table
│ │ │ │ ├── TableViewerBuilder.java
│ │ │ │ └── TableViewerColumnBuilder.java
│ │ │ └── tree
│ │ │ ├── TreeViewerBuilder.java
│ │ │ └── TreeViewerColumnBuilder.java
│ │ ├── util
│ │ │ ├── Beans.java
│ │ │ ├── Colors.java
│ │ │ ├── Files.java
│ │ │ ├── Images.java
│ │ │ ├── Strings.java
│ │ │ └── Widgets.java
│ │ └── views
│ │ ├── ConnectionEditorInput.java
│ │ ├── ConnectionEditorPart.java
│ │ ├── editor
│ │ │ ├── ServerUriCellEditor.java
│ │ │ ├── TopicQosCellEditor.java
│ │ │ └── TopicStringCellEditor.java
│ │ ├── HistoryTab.java
│ │ ├── IViewUpdater.java
│ │ ├── LastMessageTab.java
│ │ ├── MessageViewerDialog.java
│ │ ├── MQTTTab.java
│ │ ├── NavigationView.java
│ │ ├── OptionsTab.java
│ │ ├── provider
│ │ │ ├── NavTreeContentProvider.java
│ │ │ └── NavTreeLabelProvider.java
│ │ └── ViewUpdater.java
│ ├── org.eclipse.paho.ui.plugin
│ │ ├── assembly.xml
│ │ ├── plugin.xml
│ │ ├── pom.xml
│ │ └── README.md
│ ├── pom.xml
│ └── README.md
├── pom.xml
├── README.md
├── test
│ └── tls-testing
│ ├── Dockerfile
│ ├── keys
│ │ ├── all-ca.crt
│ │ ├── server
│ │ │ ├── server.crt
│ │ │ ├── server.key
│ │ │ ├── server-mitm.crt
│ │ │ └── server-mitm.key
│ │ ├── test-root-ca.crt
│ │ └── test-signing-ca.crt
│ ├── mosquitto.conf
│ ├── mosquitto-docker.conf
│ └── mosquitto.pw
└── travis-install.sh
221 directories, 392 files
很出名mqtt的开源代码, 这个是java版本。目前支持mqtt3.1.1版本。自测完美。
【实例截图】
【核心代码】
zhyanbadboy_10753959
└── paho.mqtt.java-master
├── about.html
├── CODE_OF_CONDUCT.md
├── CONTRIBUTING.md
├── edl-v10
├── epl-v10
├── notice.html
├── org.eclipse.paho.client.eclipse.feature
│ ├── build.properties
│ ├── epl-v10.html
│ ├── feature.properties
│ ├── feature.xml
│ ├── license.html
│ └── pom.xml
├── org.eclipse.paho.client.eclipse.view
│ ├── build.properties
│ ├── icons
│ │ ├── mqtt_view.png
│ │ └── paho.png
│ ├── META-INF
│ │ └── MANIFEST.MF
│ ├── plugin.properties
│ ├── plugin.xml
│ ├── pom.xml
│ ├── README.md
│ └── src
│ └── org
│ └── eclipse
│ └── paho
│ └── client
│ └── eclipse
│ └── view
│ ├── Activator.java
│ ├── ClientConstants.java
│ ├── Messages.java
│ ├── messages.properties
│ └── MqttClientView.java
├── org.eclipse.paho.client.mqttv3
│ ├── build.properties
│ ├── build.xml
│ ├── META-INF
│ │ └── MANIFEST.MF
│ ├── pom.xml
│ └── src
│ └── main
│ ├── java
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ ├── BufferedMessage.java
│ │ ├── DisconnectedBufferOptions.java
│ │ ├── IMqttActionListener.java
│ │ ├── IMqttAsyncClient.java
│ │ ├── IMqttClient.java
│ │ ├── IMqttDeliveryToken.java
│ │ ├── IMqttMessageListener.java
│ │ ├── IMqttToken.java
│ │ ├── internal
│ │ │ ├── ClientDefaults.java
│ │ │ ├── ClientState.java
│ │ │ ├── CommsCallback.java
│ │ │ ├── CommsReceiver.java
│ │ │ ├── CommsSender.java
│ │ │ ├── CommsTokenStore.java
│ │ │ ├── ConnectActionListener.java
│ │ │ ├── DestinationProvider.java
│ │ │ ├── DisconnectedMessageBuffer.java
│ │ │ ├── ExceptionHelper.java
│ │ │ ├── FileLock.java
│ │ │ ├── IDisconnectedBufferCallback.java
│ │ │ ├── MessageCatalog.java
│ │ │ ├── MqttPersistentData.java
│ │ │ ├── NetworkModule.java
│ │ │ ├── ResourceBundleCatalog.java
│ │ │ ├── security
│ │ │ │ ├── SimpleBase64Encoder.java
│ │ │ │ └── SSLSocketFactoryFactory.java
│ │ │ ├── SSLNetworkModule.java
│ │ │ ├── TCPNetworkModule.java
│ │ │ ├── Token.java
│ │ │ ├── websocket
│ │ │ │ ├── Base64.java
│ │ │ │ ├── ExtendedByteArrayOutputStream.java
│ │ │ │ ├── HandshakeFailedException.java
│ │ │ │ ├── WebSocketFrame.java
│ │ │ │ ├── WebSocketHandshake.java
│ │ │ │ ├── WebSocketNetworkModule.java
│ │ │ │ ├── WebSocketReceiver.java
│ │ │ │ └── WebSocketSecureNetworkModule.java
│ │ │ └── wire
│ │ │ ├── CountingInputStream.java
│ │ │ ├── MqttAck.java
│ │ │ ├── MqttConnack.java
│ │ │ ├── MqttConnect.java
│ │ │ ├── MqttDisconnect.java
│ │ │ ├── MqttInputStream.java
│ │ │ ├── MqttOutputStream.java
│ │ │ ├── MqttPersistableWireMessage.java
│ │ │ ├── MqttPingReq.java
│ │ │ ├── MqttPingResp.java
│ │ │ ├── MqttPubAck.java
│ │ │ ├── MqttPubComp.java
│ │ │ ├── MqttPublish.java
│ │ │ ├── MqttPubRec.java
│ │ │ ├── MqttPubRel.java
│ │ │ ├── MqttReceivedMessage.java
│ │ │ ├── MqttSuback.java
│ │ │ ├── MqttSubscribe.java
│ │ │ ├── MqttUnsubAck.java
│ │ │ ├── MqttUnsubscribe.java
│ │ │ ├── MqttWireMessage.java
│ │ │ ├── MultiByteArrayInputStream.java
│ │ │ └── MultiByteInteger.java
│ │ ├── logging
│ │ │ ├── JSR47Logger.java
│ │ │ ├── jsr47min.properties
│ │ │ ├── LoggerFactory.java
│ │ │ ├── Logger.java
│ │ │ ├── package.html
│ │ │ └── SimpleLogFormatter.java
│ │ ├── MqttAsyncClient.java
│ │ ├── MqttCallbackExtended.java
│ │ ├── MqttCallback.java
│ │ ├── MqttClient.java
│ │ ├── MqttClientPersistence.java
│ │ ├── MqttConnectOptions.java
│ │ ├── MqttDeliveryToken.java
│ │ ├── MqttException.java
│ │ ├── MqttMessage.java
│ │ ├── MqttPersistable.java
│ │ ├── MqttPersistenceException.java
│ │ ├── MqttPingSender.java
│ │ ├── MqttSecurityException.java
│ │ ├── MqttToken.java
│ │ ├── MqttTopic.java
│ │ ├── package.html
│ │ ├── persist
│ │ │ ├── MemoryPersistence.java
│ │ │ ├── MqttDefaultFilePersistence.java
│ │ │ ├── package.html
│ │ │ ├── PersistanceFileFilter.java
│ │ │ └── PersistanceFileNameFilter.java
│ │ ├── ScheduledExecutorPingSender.java
│ │ ├── TimerPingSender.java
│ │ └── util
│ │ ├── Debug.java
│ │ ├── package.html
│ │ └── Strings.java
│ ├── java-templates
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ └── internal
│ │ └── ClientComms.java
│ └── resources
│ ├── bundle.properties
│ └── org
│ └── eclipse
│ └── paho
│ └── client
│ └── mqttv3
│ └── internal
│ └── nls
│ ├── logcat.properties
│ ├── messages_cs.properties
│ ├── messages_de.properties
│ ├── messages_es.properties
│ ├── messages_fr.properties
│ ├── messages_hu.properties
│ ├── messages_it.properties
│ ├── messages_ja.properties
│ ├── messages_ko.properties
│ ├── messages_pl.properties
│ ├── messages.properties
│ ├── messages_pt_BR.properties
│ ├── messages_ru.properties
│ ├── messages_zh_CN.properties
│ └── messages_zh_TW.properties
├── org.eclipse.paho.client.mqttv3.internal.traceformat
│ ├── build.xml
│ └── src
│ └── main
│ └── java
│ └── org
│ └── eclipse
│ └── paho
│ └── client
│ └── mqttv3
│ └── internal
│ └── logBuilder
│ └── LogMessageExtractor.java
├── org.eclipse.paho.client.mqttv3.repository
│ ├── category.xml
│ └── pom.xml
├── org.eclipse.paho.client.mqttv3.test
│ ├── pom.xml
│ └── src
│ └── test
│ ├── java
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ └── test
│ │ ├── automaticReconnect
│ │ │ ├── AutomaticReconnectTest.java
│ │ │ └── OfflineBufferingTest.java
│ │ ├── BasicSSLTest.java
│ │ ├── BasicTest.java
│ │ ├── Bug443142Test.java
│ │ ├── client
│ │ │ ├── MqttAsyncClientPaho.java
│ │ │ ├── MqttClientFactoryPaho.java
│ │ │ └── MqttClientPaho.java
│ │ ├── ConformantTest.java.notrun
│ │ ├── connectionLoss
│ │ │ └── ConnectionLossTest.java
│ │ ├── Issue370Test.java
│ │ ├── LiveTakeOverTest.java
│ │ ├── logging
│ │ │ ├── ConsoleHandler.java
│ │ │ ├── DetailFormatter.java
│ │ │ ├── HumanFormatter.java
│ │ │ ├── LoggerDumper.java
│ │ │ ├── LoggerNode.java
│ │ │ ├── LoggingUtilities.java
│ │ │ ├── ObjectFormatter.java
│ │ │ └── TraceFormatter.java
│ │ ├── ModelTestCase.java
│ │ ├── MqttTopicTest.java
│ │ ├── PerSubscriptionMessageHandlerTest.java
│ │ ├── properties
│ │ │ └── TestProperties.java
│ │ ├── SendReceiveAsyncCallbackTest.java
│ │ ├── SendReceiveAsyncTest.java
│ │ ├── SendReceiveTest.java
│ │ ├── SSLSessionResumptionTest.java
│ │ ├── utilities
│ │ │ ├── ConnectionManipulationProxyServer.java
│ │ │ ├── MqttV3Receiver.java
│ │ │ ├── StringUtilities.java
│ │ │ ├── TestMemoryPersistence.java
│ │ │ └── Utility.java
│ │ └── WebSocketTest.java
│ └── resources
│ ├── clientkeystore.jks
│ ├── iot.eclipse.org.crt
│ ├── logging.properties
│ └── test.properties
├── org.eclipse.paho.jmeclient
│ ├── org.eclipse.paho.jmeclient.mqttv3
│ │ ├── bin
│ │ │ └── org
│ │ │ └── eclipse
│ │ │ └── paho
│ │ │ └── client
│ │ │ └── mqttv3
│ │ │ ├── internal
│ │ │ │ └── nls
│ │ │ │ ├── logcat_cs.properties
│ │ │ │ ├── logcat_de.properties
│ │ │ │ ├── logcat_es.properties
│ │ │ │ ├── logcat_fr.properties
│ │ │ │ ├── logcat_hu.properties
│ │ │ │ ├── logcat_it.properties
│ │ │ │ ├── logcat_ja.properties
│ │ │ │ ├── logcat_ko.properties
│ │ │ │ ├── logcat_pl.properties
│ │ │ │ ├── logcat.properties
│ │ │ │ ├── logcat_pt_BR.properties
│ │ │ │ ├── logcat_ru.properties
│ │ │ │ ├── logcat_zh_CN.properties
│ │ │ │ ├── logcat_zh_TW.properties
│ │ │ │ ├── messages_cs.properties
│ │ │ │ ├── messages_de.properties
│ │ │ │ ├── messages_es.properties
│ │ │ │ ├── messages_fr.properties
│ │ │ │ ├── messages_hu.properties
│ │ │ │ ├── messages_it.properties
│ │ │ │ ├── messages_ja.properties
│ │ │ │ ├── messages_ko.properties
│ │ │ │ ├── messages_pl.properties
│ │ │ │ ├── messages.properties
│ │ │ │ ├── messages_pt_BR.properties
│ │ │ │ ├── messages_ru.properties
│ │ │ │ ├── messages_zh_CN.properties
│ │ │ │ └── messages_zh_TW.properties
│ │ │ ├── package.html
│ │ │ ├── persist
│ │ │ │ └── package.html
│ │ │ └── util
│ │ │ └── package.html
│ │ ├── build.xml
│ │ ├── META-INF
│ │ │ └── MANIFEST.MF
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ ├── internal
│ │ │ ├── MicroCatalog.java
│ │ │ ├── MqttMicroNetworkFactory.java
│ │ │ ├── SSLMicroNetworkModule.java
│ │ │ └── TCPMicroNetworkModule.java
│ │ ├── logging
│ │ │ ├── EmptyLogger.java
│ │ │ ├── LoggerFactory.java
│ │ │ └── Logger.java
│ │ ├── MqttConnectOptions.java
│ │ ├── package.html
│ │ ├── persist
│ │ │ ├── MqttDefaultMicroFilePersistence.java
│ │ │ ├── MqttDefaultMicroPersistence.java
│ │ │ └── package.html
│ │ └── util
│ │ ├── package.html
│ │ └── PropertyResourceBundle.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOBasicSyncTestCase
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── test
│ │ ├── BasicSyncTestCaseMIDP.java
│ │ ├── GPIOTest.java
│ │ ├── Iterator.java
│ │ └── SimpleList.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOSample
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleGPIO
│ │ └── GPIOSample.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOSampleAsyncCallBack
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleGPIO
│ │ └── AsyncCallback
│ │ ├── GPIOSampleAsyncCallback.java
│ │ └── SampleAsyncCallback.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.GPIOSampleAsyncWait
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── logging.properties
│ │ ├── res
│ │ │ └── logging.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleGPIO
│ │ └── AsyncWait
│ │ ├── GPIOSampleAsyncWait.java
│ │ └── SampleAsyncWait.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.Logging
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ ├── logging
│ │ │ ├── Logging.java
│ │ │ └── SimpleLogFormatter.java
│ │ └── util
│ │ ├── ConsoleHandler.java
│ │ ├── FileHandler.java
│ │ └── MemoryHandler.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.MIDPLogging
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── client
│ │ └── mqttv3
│ │ └── logging
│ │ ├── MIDPLogFormatter.java
│ │ └── MIDPLogging.java
│ ├── org.eclipse.paho.jmeclient.mqttv3.MIDPSample
│ │ ├── Application Descriptor
│ │ ├── bin
│ │ │ └── microlog.properties
│ │ ├── res
│ │ │ └── microlog.properties
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── jmeclient
│ │ └── mqttv3
│ │ └── sampleMIDP
│ │ ├── IA92.java
│ │ ├── WmqttGauge.java
│ │ └── WmqttMgr.java
│ └── README.md
├── org.eclipse.paho.sample.mqttv3app
│ ├── launchers
│ │ ├── MqttPublisher.launch
│ │ └── MqttSubscriber.launch
│ ├── META-INF
│ │ └── MANIFEST.MF
│ └── src
│ └── main
│ └── java
│ └── org
│ └── eclipse
│ └── paho
│ └── sample
│ └── mqttv3app
│ ├── SampleAsyncCallBack.java
│ ├── SampleAsyncWait.java
│ └── Sample.java
├── org.eclipse.paho.sample.utility
│ ├── build.xml
│ ├── pom.xml
│ └── src
│ └── main
│ ├── java
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── sample
│ │ └── utility
│ │ ├── ConnOpts.java
│ │ ├── LED.java
│ │ ├── MQTTFrame.java
│ │ ├── MQTTHist.java
│ │ ├── PubPanel.java
│ │ └── SubPanel.java
│ └── resources
│ ├── META-INF
│ │ └── MANIFEST.MF
│ └── mqtt.properties
├── org.eclipse.paho.ui
│ ├── org.eclipse.paho.ui.app
│ │ ├── org.eclipse.paho.ui.app.product
│ │ └── pom.xml
│ ├── org.eclipse.paho.ui.core
│ │ ├── build.properties
│ │ ├── icons
│ │ │ ├── add.gif
│ │ │ ├── add_gray.gif
│ │ │ ├── clear.gif
│ │ │ ├── connection_edit.gif
│ │ │ ├── connection.gif
│ │ │ ├── connection_gray.gif
│ │ │ ├── history.gif
│ │ │ ├── lastmsg.gif
│ │ │ ├── mqtt.gif
│ │ │ ├── options.gif
│ │ │ ├── paho_logo_100.png
│ │ │ ├── paho_logo_400.png
│ │ │ ├── paho_logo.eps
│ │ │ ├── paho_logo_full.png
│ │ │ ├── paho.png
│ │ │ ├── paho-small.png
│ │ │ ├── remove.gif
│ │ │ └── remove_gray.gif
│ │ ├── META-INF
│ │ │ └── MANIFEST.MF
│ │ ├── OSGI-INF
│ │ │ └── l10n
│ │ │ └── bundle.properties
│ │ ├── plugin_customization.ini
│ │ ├── plugin.xml
│ │ ├── pom.xml
│ │ ├── product_lg.png
│ │ ├── splash.bmp
│ │ └── src
│ │ └── org
│ │ └── eclipse
│ │ └── paho
│ │ └── mqtt
│ │ └── ui
│ │ ├── actions
│ │ │ └── NewConnectionAction.java
│ │ ├── Activator.java
│ │ ├── ApplicationActionBarAdvisor.java
│ │ ├── Application.java
│ │ ├── ApplicationWorkbenchAdvisor.java
│ │ ├── ApplicationWorkbenchWindowAdvisor.java
│ │ ├── Constants.java
│ │ ├── core
│ │ │ ├── DataBindings.java
│ │ │ ├── event
│ │ │ │ ├── Event.java
│ │ │ │ ├── Events.java
│ │ │ │ ├── IEventHandler.java
│ │ │ │ ├── IEventService.java
│ │ │ │ ├── internal
│ │ │ │ │ ├── EventService.java
│ │ │ │ │ └── Registration.java
│ │ │ │ ├── IRegistration.java
│ │ │ │ ├── Registrations.java
│ │ │ │ └── Selector.java
│ │ │ ├── IConnectionManager.java
│ │ │ ├── internal
│ │ │ │ └── ConnectionManager.java
│ │ │ └── model
│ │ │ ├── Bindable.java
│ │ │ ├── Connection.java
│ │ │ ├── History.java
│ │ │ ├── Login.java
│ │ │ ├── LWT.java
│ │ │ ├── Pair.java
│ │ │ ├── PublishMessage.java
│ │ │ ├── QoS.java
│ │ │ ├── ServerURI.java
│ │ │ ├── SSLOptions.java
│ │ │ └── Topic.java
│ │ ├── nls
│ │ │ ├── Messages.java
│ │ │ ├── messages.properties
│ │ │ └── messages_zh_CN.properties
│ │ ├── PahoException.java
│ │ ├── Paho.java
│ │ ├── Perspective.java
│ │ ├── support
│ │ │ ├── fieldassist
│ │ │ │ ├── ControlDecorationSupport.java
│ │ │ │ └── ControlDecorationUpdater.java
│ │ │ ├── provider
│ │ │ │ ├── IValueFormatter.java
│ │ │ │ └── PropertyCellLabelProvider.java
│ │ │ ├── table
│ │ │ │ ├── TableViewerBuilder.java
│ │ │ │ └── TableViewerColumnBuilder.java
│ │ │ └── tree
│ │ │ ├── TreeViewerBuilder.java
│ │ │ └── TreeViewerColumnBuilder.java
│ │ ├── util
│ │ │ ├── Beans.java
│ │ │ ├── Colors.java
│ │ │ ├── Files.java
│ │ │ ├── Images.java
│ │ │ ├── Strings.java
│ │ │ └── Widgets.java
│ │ └── views
│ │ ├── ConnectionEditorInput.java
│ │ ├── ConnectionEditorPart.java
│ │ ├── editor
│ │ │ ├── ServerUriCellEditor.java
│ │ │ ├── TopicQosCellEditor.java
│ │ │ └── TopicStringCellEditor.java
│ │ ├── HistoryTab.java
│ │ ├── IViewUpdater.java
│ │ ├── LastMessageTab.java
│ │ ├── MessageViewerDialog.java
│ │ ├── MQTTTab.java
│ │ ├── NavigationView.java
│ │ ├── OptionsTab.java
│ │ ├── provider
│ │ │ ├── NavTreeContentProvider.java
│ │ │ └── NavTreeLabelProvider.java
│ │ └── ViewUpdater.java
│ ├── org.eclipse.paho.ui.plugin
│ │ ├── assembly.xml
│ │ ├── plugin.xml
│ │ ├── pom.xml
│ │ └── README.md
│ ├── pom.xml
│ └── README.md
├── pom.xml
├── README.md
├── test
│ └── tls-testing
│ ├── Dockerfile
│ ├── keys
│ │ ├── all-ca.crt
│ │ ├── server
│ │ │ ├── server.crt
│ │ │ ├── server.key
│ │ │ ├── server-mitm.crt
│ │ │ └── server-mitm.key
│ │ ├── test-root-ca.crt
│ │ └── test-signing-ca.crt
│ ├── mosquitto.conf
│ ├── mosquitto-docker.conf
│ └── mosquitto.pw
└── travis-install.sh
221 directories, 392 files
标签：
好例子网口号：伸出你的我的手 — 分享！
相关软件
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论