Я хочу поэкспериментировать с протоколом mqtt. Для этого я скачал необходимый файл, объясненный по этой ссылке http://www.hascode.com/2016/06/playing-around-with-mqtt-and-java-with-moquette-and-eclipse-paho/.
Код:
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
import io.moquette.interception.AbstractInterceptHandler;
import io.moquette.interception.InterceptHandler;
import io.moquette.interception.messages.InterceptPublishMessage;
import io.moquette.server.Server;
import io.moquette.server.config.ClasspathConfig;
import io.moquette.server.config.IConfig;
public class s1
{
static class PublisherListener extends AbstractInterceptHandler {
@Override
public void onPublish(InterceptPublishMessage message) {
System.out.println("moquette mqtt broker message intercepted, topic: " + message.getTopicName()
+ ", content: " + new String(message.getPayload().array()));
}
public static void main(String args[]) throws IOException
{
// Creating a MQTT Broker using Moquette
final IConfig classPathConfig = new ClasspathConfig();
final Server mqttBroker = new Server();
final List<? extends InterceptHandler> userHandlers = Arrays.asList(new PublisherListener());
mqttBroker.startServer(classPathConfig, userHandlers);
System.out.println("moquette mqtt broker started, press ctrl-c to shutdown..");
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
System.out.println("stopping moquette mqtt broker..");
mqttBroker.stopServer();
System.out.println("moquette mqtt broker stopped");
}
});
}
}
}
Однако, когда я пытаюсь скомпилировать, он показывает эту ошибку.
Exception in thread "main" java.lang.RuntimeException: Can't locate the resource "config/moquette.conf"
at io.moquette.server.config.ClasspathConfig.<init>(ClasspathConfig.java:42)
at mytest.s1$PublisherListener.main(s1.java:27)
Я не могу понять это сообщение об ошибке. Я уже установил mosquito в C: \ Program Files (x86) \ mosquitto. Я проверил это с помощью
Издатель:
mosquitto_pub -m "message from mosquitto_pub client" -t "test"
и подписчик:
mosquitto_sub -t "test".
Пожалуйста, дайте мне совет, чтобы решить эту проблему.