|
|
Sponsored Content
Top Forums
UNIX for Dummies Questions & Answers
NS3 with MQTT integration. HELP !!!!
Post 302599147 by KishIsrael on Thursday 16th of February 2012 10:35:57 AM
02-16-2012
NS3 with MQTT integration. HELP !!!!
Hi, I'm doing my thesis on the NS3 environment. I need to integrate it with mqtt. Mqtt provides a (mosquitto) broker / server, and it expects to have clients connect to it. A client could be a publisher (publishes data on the broker) or a subscriber (receives data from the broker it has subscribed to).
SOOOO, i need to have an NS3 node as a publisher client. I have set everything working (Nodes, WiFi, TAP NET device etc) and i do have a connection made to the broker.
THE PROBLEM IS THAT: as soon as the connection is made, and the broker recognizes my NS3 node using my ID "publisher" , the connection is subsequently disconnected, so fast almost in a flash. Here is the output from the mosquitto broker:
1329401026: New connection from 191.13.13.2.
1329401026: New client connected from 191.13.13.2 as publisher.
1329401026: Socket read error on client publisher, disconnecting.
I have delved into the broker code and the error seems to be coming from the file: - loop.c in function 'loop_handle_reads_writes() at if(mqtt3_net_read(db, i)) line 267'
- or then from mosquitto.c after pselect() at point if(mqtt3_net_read(contexts[i]) line 280.
I DO NOT EXPLICITELY CLOSE my NS3 node socket after opening it. I am using an altered version of bulk-send-application.cc to include capability to also receive data from a server, and then i create a custom mosquitto namespace to add the mosquitto client functions which i will call from the bulk-send-applicaiton.cc.
WHY IS THE BROKER ACCEPTING MY CONNECTION, RECEIVES MY INFORMATION I SEND TO IT, SINCE IT DISPLAYS MY ID ('publisher'), THEN ALMOST IMMEDIATELY DISCONNECTS ME WITH A SOCKET-READ-ERROR WHILE I HAVE NOT EXPLICITELY CLOSED MY NS3 SOCKET ?
SOOOO, i need to have an NS3 node as a publisher client. I have set everything working (Nodes, WiFi, TAP NET device etc) and i do have a connection made to the broker.
THE PROBLEM IS THAT: as soon as the connection is made, and the broker recognizes my NS3 node using my ID "publisher" , the connection is subsequently disconnected, so fast almost in a flash. Here is the output from the mosquitto broker:
1329401026: New connection from 191.13.13.2.
1329401026: New client connected from 191.13.13.2 as publisher.
1329401026: Socket read error on client publisher, disconnecting.
I have delved into the broker code and the error seems to be coming from the file: - loop.c in function 'loop_handle_reads_writes() at if(mqtt3_net_read(db, i)) line 267'
- or then from mosquitto.c after pselect() at point if(mqtt3_net_read(contexts[i]) line 280.
I DO NOT EXPLICITELY CLOSE my NS3 node socket after opening it. I am using an altered version of bulk-send-application.cc to include capability to also receive data from a server, and then i create a custom mosquitto namespace to add the mosquitto client functions which i will call from the bulk-send-applicaiton.cc.
WHY IS THE BROKER ACCEPTING MY CONNECTION, RECEIVES MY INFORMATION I SEND TO IT, SINCE IT DISPLAYS MY ID ('publisher'), THEN ALMOST IMMEDIATELY DISCONNECTS ME WITH A SOCKET-READ-ERROR WHILE I HAVE NOT EXPLICITELY CLOSED MY NS3 SOCKET ?
| Moderator's Comments: | ||
|
|
|
9 More Discussions You Might Find Interesting
1. IP Networking
Command terminated with signal SIGSEGV. Run it under a debugger to get more information (./waf --run <program> --command-template="gdb --args %s <args>").
while running our own program in ns3 we got the above error...
what does this error mean?? (1 Reply)
Discussion started by: nivedita
1 Replies
2. IP Networking
i need materials regarding ns3(related to WiMAX) (1 Reply)
Discussion started by: nivedita
1 Replies
3. IP Networking
how to add a relay node in wimax network using ns3 simulator.... (0 Replies)
Discussion started by: nivedita
0 Replies
4. IP Networking
Hi,
I am working to implement a basic WiFi infrastructure in NS3. I have placed 16 APs in grid and one client is moving using random walk. Client and AP can communicate through message exchange. However, when I try a message of size more than 30 bytes, it is crashed. Please help me if anyone have... (0 Replies)
Discussion started by: dandapat
0 Replies
5. IP Networking
Dear all,
I want to simulate an Wireless Mobile ad hoc network that uses the
OLSR routing algorithm. ( i know how to do that now after reading the
tutorial)
Now, Instead of sending messages, I want the nodes to be able to send
a c++ code.
consider this scenario:
node A, send a c++... (0 Replies)
Discussion started by: knowledgeSeeker
0 Replies
6. Programming
Hi, I'm doing my thesis on the NS3 environment. I need to integrate it with mqtt. Mqtt provides a (mosquitto) broker / server, and it expects to have clients connect to it. A client could be a publisher (publishes data on the broker) or a subscriber (receives data from the broker it has subscribed... (4 Replies)
Discussion started by: KishIsrael
4 Replies
7. Infrastructure Monitoring
After setting up MQTT and testing some ESP8266 and ESP32 modules, where I noted that testing in Programming ESP32 (ESP-WROOM-32) as an MQTT Client Subscribed to Linux Server Load Average Messages, I was so impressed with MQTT that I installed MQTT on three different computers, instantly and... (2 Replies)
Discussion started by: Neo
2 Replies
8. Programming
Various Node-Red crypto modules do not work with PHP, so to send an encrypted message from a PHP script (in this case from a Ubuntu server) to Node-RED we need our own code.
After a few hours of searching, testing various libs, more testing and debugging, I got this PHP to Node-RED code... (0 Replies)
Discussion started by: Neo
0 Replies
9. Programming
First, I want to thank Neo (LOL) for this post from 2018, Node.js and mysql - ER_ACCESS_DENIED_ERROR
I could not get the Node-RED mysql module to work and searched Google until all my links were purple! I kept getting ER_ACCESS_DENIED_ERROR with the right credentials. Nothing on the web was... (0 Replies)
Discussion started by: Neo
0 Replies
LEARN ABOUT DEBIAN
rabbitmq-server
RABBITMQ-SERVER(1) RabbitMQ Server RABBITMQ-SERVER(1) NAME
rabbitmq-server - start RabbitMQ AMQP server SYNOPSIS
rabbitmq-server [-detached] DESCRIPTION
RabbitMQ is an implementation of AMQP, the emerging standard for high performance enterprise messaging. The RabbitMQ server is a robust and scalable implementation of an AMQP broker. Running rabbitmq-server in the foreground displays a banner message, and reports on progress in the startup sequence, concluding with the message "broker running", indicating that the RabbitMQ broker has been started successfully. To shut down the server, just terminate the process or use rabbitmqctl(1). ENVIRONMENT
RABBITMQ_MNESIA_BASE Defaults to /var/lib/rabbitmq/mnesia. Set this to the directory where Mnesia database files should be placed. RABBITMQ_LOG_BASE Defaults to /var/log/rabbitmq. Log files generated by the server will be placed in this directory. RABBITMQ_NODENAME Defaults to rabbit. This can be useful if you want to run more than one node per machine - RABBITMQ_NODENAME should be unique per erlang-node-and-machine combination. See the clustering on a single machine guide[1] for details. RABBITMQ_NODE_IP_ADDRESS By default RabbitMQ will bind to all interfaces, on IPv4 and IPv6 if available. Set this if you only want to bind to one network interface or address family. RABBITMQ_NODE_PORT Defaults to 5672. OPTIONS
-detached start the server process in the background SEE ALSO
rabbitmq-env.conf(5) rabbitmqctl(1) EXAMPLES
rabbitmq-server -detached Runs RabbitMQ AMQP server in the background. AUTHOR
The RabbitMQ Team <info@rabbitmq.com> NOTES
1. clustering on a single machine guide http://www.rabbitmq.com/clustering.html#single-machine RabbitMQ Server 06/22/2012 RABBITMQ-SERVER(1)