Discussion :

[grutt]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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

[3DArchi]

Bonjour,
As-tu jeté un coup d'oeil au tutoriel de Boost.Asio disponible sur le site ?

[grutt]

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

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.

[Montag]

Salut,

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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;
 
}

[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."

[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.

[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

[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 ?

[grutt]

Ah ok, je me suis peut être mal exprimé.
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.

[3DArchi]

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)

[grutt]

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

Pour ceux que ça intéresse:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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