moquette-mqtt源码

moquette-mqtt源码 下载

package org.dna.mqtt.bechnmark;

import java.net.URISyntaxException;
import org.fusesource.mqtt.client.BlockingConnection;
import org.fusesource.mqtt.client.MQTT;
import org.fusesource.mqtt.client.Message;
import org.fusesource.mqtt.client.QoS;
import org.fusesource.mqtt.client.Topic;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 *
 * @author andrea
 */
public class ConsumerBlocking implements Runnable {
    
    private static final Logger LOG = LoggerFactory.getLogger（ConsumerBlocking.class）;
    
    private String m_clientID;

    public ConsumerBlocking（String clientID） {
        m_clientID = clientID;
    }
    
    public void run（） {
        MQTT mqtt = new MQTT（）;
        try {
//            mqtt.setHost（“test.mosquitto.org“ 1883）;
            mqtt.setHost（“local

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

    .......       683  2027-03-24 18:00  pom.xml

    .......      3476  2027-03-24 18:00  benchmarking\pom.xml

    .......      2329  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\ConsumerBlocking.java

    .......      3716  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\ConsumerFuture.java

    .......      1083  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\Main.java

    .......       685  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\mina\DummyClientHandler.java

    .......      4972  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\mina\MQTTBulkClient.java

    .......      1326  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\mina\MQTTDropHandler.java

    .......      4250  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\mina\MQTTDropServer.java

    .......      3683  2027-03-24 18:00  benchmarking\src\main\java\org\dna\mqtt\bechnmark\Producer.java

    .......      5239  2027-03-24 18:00  broker\pom.xml

    .......       126  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\IMatchingCondition.java

    .......       736  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\IMessaging.java

    .......       388  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\DisconnectEvent.java

    .......       116  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\InitEvent.java

    .......       192  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\MessagingEvent.java

    .......      1641  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\NotifyEvent.java

    .......       647  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\ProtocolEvent.java

    .......       495  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\PubAckEvent.java

    .......      1870  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\PublishEvent.java

    .......       377  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\RepublishEvent.java

    .......       184  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\StopEvent.java

    .......       577  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\events\SubscribeEvent.java

    .......      8310  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\HawtDBStorageService.java

    .......     22958  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\SimpleMessaging.java

    .......      2268  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\subscriptions\Subscription.java

    .......      7143  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\subscriptions\SubscriptionsStore.java

    .......      1219  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\subscriptions\Token.java

    .......      3988  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\subscriptions\TreeNode.java

    .......       658  2027-03-24 18:00  broker\src\main\java\org\dna\mqtt\moquette\messaging\spi\impl\ValueEvent.java

............此处省略163个文件信息