Boost.asio pour écouter un port UDP

Version imprimable

Salut, je viens de me mettre à boost et je veux réaliser une écoute sur un port UDP. J'ai déja un programme qui me permet de simuler des trames. J'ai fais un petit test pour essayer de les récupérer mais je n'y arrive pas.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 int main() { try { boost::asio::io_service io_service; udp::endpoint endpoint (boost::asio::ip::address::from_string("134.246.151.185"), 10001); udp::socket socket(io_service); socket.open(udp::v4()); socket.connect(endpoint); boost::array<char, 128> recv_buf; size_t len = socket.receive(boost::asio::buffer(recv_buf)); std::cout.write(recv_buf.data(), len); } catch (std::exception& e) { std::cerr << e.what() << std::endl; } return 0; }
Si quelqu'un pouvait m'aider ce serait sympa:cry:

09/04/2009, 15h44
3DArchi

Bonjour,
As-tu jeté un coup d'oeil au tutoriel de Boost.Asio disponible sur le site ?
09/04/2009, 15h53
grutt

Oui, j'ai même commencé par là:D.

Mais je n'ai pas trouvé la réponse à ma question. Je veux juste écouter un port UDP sur lequel il y a des trames en continue tout le temps.

Salut,

Il faut que tu "bind" ta socket et que tu utilises receive_from:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
int main()
{
  try
  {
    boost::asio::io_service io_service;
    udp::endpoint endpoint (boost::asio::ip::address::from_string("134.246.151.185"), 10001);
    udp::endpoint sender;
 
    udp::socket socket(io_service);
    socket.open(udp::v4());
    socket.bind(endpoint); // <------
 
    boost::array<char, 128> recv_buf;
    size_t len = socket.receive_from(boost::asio::buffer(recv_buf), sender);
 
    std::cout.write(recv_buf.data(), len);
 
  }
  catch (std::exception& e)
  {
    std::cerr << e.what() << std::endl;
  }
 
  return 0;
 
}

09/04/2009, 16h17
grutt

J'ai essayé avec le bind, et lorsque je lançe l'application il y a l'erreur suivante :
"une seule utilisation de chaque adresse de socket <protocole/adresse réseau/port> est habituellement autorisée."
09/04/2009, 17h53
Montag

L'adresse sur laquelle tu essaies de binder la socket est sans doute déjà utilisée.
En tout cas le code de mon précédent message fonctionne chez moi.
10/04/2009, 09h43
grutt

Salut Montag,
est ce que tu pourrais me montrer le code avec lequel tu simules stp. Je commence à croire que c'est le simulateur qui pose probleme (bien qu'il fonctionnait avec un programme similaire en java).
Merci d'avance
10/04/2009, 10h13
Montag

Salut,

En fait j'ai peut-être mal compris ce que tu souhaites faire.
Le code que j'ai posté permet de créer un "serveur" en bindant une socket sur une adresse bien définie pour permettre à des clients d'y envoyer des données.
Est-ce ce que tu veux faire ?
10/04/2009, 10h23
grutt

Ah ok, je me suis peut être mal exprimé:D.
Non en faites il existe déja un "serveur" qui envoi des données en continu sur un port UDP. Maintenant ce que je veux c'est faire une application permettant de récupérer ces données.
10/04/2009, 10h29
3DArchi

Citation:

Envoyé par grutt

J'ai essayé avec le bind, et lorsque je lançe l'application il y a l'erreur suivante :
"une seule utilisation de chaque adresse de socket <protocole/adresse réseau/port> est habituellement autorisée."

Comme dit par montag, ce genre d'erreur est typique lorsque tu essaies de lier (bind) 2 sockets UDP sur la même adresse (IP+port). Ca se produit : si ton client et ton serveur tourne sur la même machine ou si tu as 2 clients sur la même machine.
Il faut utiliser l'option SO_REUSEADDR (cf doc boost)

Ok, merci beaucoup les gars:king:
J'arrive à récupérer les données:D

Pour ceux que ça intéresse:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
#include <iostream>
#include <boost/array.hpp>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
 
 
using boost::asio::ip::udp;
using namespace std;
 
 
int main()
{
    try{
    boost::asio::io_service io_service;
    udp::endpoint endpoint (boost::asio::ip::address::from_string("134.246.151.185"), 10001);
    boost::asio::socket_base::reuse_address option(true);
    udp::endpoint sender;
 
    udp::socket socket(io_service);
 
    socket.open(udp::v4());
    socket.set_option(option);
    socket.bind(endpoint);
 
 
    boost::array<char, 1024> recv_buf;
    size_t len = socket.receive_from(boost::asio::buffer(recv_buf), sender);
 
    std::cout.write(recv_buf.data(), len);
 
  }
  catch (std::exception& e)
  {
    std::cerr << e.what() << std::endl;
  }
 
  return 0;
 
}

Voila:yaisse2: