Multicast UDP

Version imprimable

Multicast UDP

Bonsoir,
Une fois de plus je me tourne vers vous pour un coup de main. J'ai un PC avec une sonde qui envoi des données sur un réseau adIp du PC "10.172.1.49" port d'envoi 8000.

Jusqu'à présent pour réceptionner ces données sur un autre on utiliser un programme en VB.net

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
40
Private Sub StartMulticast()
 //avec adipp = 10.172.1.51
        Try
            mcastSocket = New Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)
            Dim localIPAddr As IPAddress = IPAddress.Parse(adipp)
            //IPAddress localIP = IPAddress.Any;
            Dim localEP As EndPoint = CType(New IPEndPoint(localIPAddr, mcastPort), EndPoint)
            mcastSocket.Bind(localEP)
             mcastOption = New MulticastOption(mcastAddress, localIPAddr)
            mcastSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, mcastOption)
        Catch e As Exception
            MsgBox(e.ToString())
        End Try
    End Sub 
 
Public Sub ReceiveBroadcastMessages()
        Dim done As Boolean = False
        Dim bytes() As Byte = New [Byte](99) {}
        Dim groupEP As New IPEndPoint(mcastAddress, mcastPort)
        Dim remoteEP As EndPoint = CType(New IPEndPoint(IPAddress.Any, 0), EndPoint)
        Try
            mcastSocket.ReceiveTimeout = 1000
            mcastSocket.ReceiveFrom(bytes, remoteEP)
            toto = Encoding.ASCII.GetString(bytes, 0, bytes.Length)
            //Traitement de toto
            mcastSocket.Close()
        Catch e As Exception
            //Ne pas oublier le ".close" qui permet de pouvoir relançer l'acquisition
            mcastSocket.Close()
 
        End Try
    End Sub
	Private Sub Timer1_Tick(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Timer1.Tick
        mcastAddress = IPAddress.Parse("225.0.1.30")
        mcastPort = 8000
        //Start a multicast group.
        StartMulticast()
        // Receive broadcast messages.
        ReceiveBroadcastMessages()
    End Sub

Je rame depuis ce matin pour essayer de faire quelque chose de similaire en java.

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
private static void MulticastListener() throws UnknownHostException, IOException {
 
     final InetAddress group = InetAddress.getByName("225.0.1.30");
     final int port = 8000;
 
     try {
 
       System.out.println("On écoute"); 
       MulticastSocket socket = new MulticastSocket(port);
       socket.setInterface(InetAddress.getLocalHost());
       socket.joinGroup(group);
 
       byte[] buffer = new byte[10*1024];
 
       DatagramPacket data = new DatagramPacket(buffer, buffer.length);
 
       while (true) {
          socket.receive(data);
//Ici traitement
       }
 
 
      } catch (IOException e) {
         System.out.println(e.toString());
      }
 
  }

Mais bon j'ai pas l'impression que cela y ressemble beaucoup.
Si quelqu'un peut m'éclairer un peu.

25/11/2013, 21h16
tchize_

A vue de pifomètre, ça m'a l'air similaire: on s'enregistre sur l'adresse multicast mentionnée et on commence la réception. Je supprimerais juste la ligne

Code:

socket.setInterface(InetAddress.getLocalHost());

Pour laisser java se binder autmatiquement sur l'interface réseau adéquate. Avec ton code, t'as une chance qu'elle se binde sur le loopback, ce qui risque de ne pas réceptionner grand chose :)
26/11/2013, 09h35
hugoclo

Merci pour la réponse,
Au risque de passer pour un idiot je ne comprends pas

Citation:

binde sur le loopback, ce qui risque de ne pas réceptionner grand chose

En fin je comprend que je ne vais rien réceptionner mais je suis plus septique sur

Citation:

binde sur le loopback

.
De plus selon le traitement il risque de ne pas se faire si je n'inclut pas un thread,non?
26/11/2013, 10h04
tchize_

Ton code, avec setInterface, dit à java "je veux binder sur l'interface localhost". Seulement, l'interface localhost est imprévisible. En effet, ton ordinateur a plusieurs interface. Celle qui est reliée à 127.0.0.1, et qu'on appelle loopback, qui correspond à un réseau privé visible uniquement de ta machine et qui ne touche jamais le cable réseau. L'interface ou les interfaces réseau, si la machine en a plusieurs, la / les interfaces wifi, les interfaces éventuelles reliées au téléphone, etc.

Et tu sais pas trop dans ce paquet qu'est-ce que java va considéré comme "localhost" :)

A coté de ça, ton code VB donne un indice. Il se relie sur l'interface "IPAddress.Any", donc toutes les interfaces d'un coup. Si tu veux avoir le même comportement, il faut faire le même en java:

Code:

socket.setInterface(InetAddress.getByName("0.0.0.0")); //Any

Par contre, je ne comprends pas ta question sur le Thread. Non il n'est pas nécessaire d'avoir un thread. Tu dois juste faire un Thread séparé si tu veux que ton programme fasse autre chose que la gestion de cette adresse multicast. La boucle continue suffit à traiter tous les messages reçus.
26/11/2013, 10h21
hugoclo

Merci pour ces précisions.
Mon programme sert à afficher ensuite les info sur 2 graphiques (utilisation de Jfreechart). Donc il faut que les utilisateurs puissent avoir la main sur l'interface graphique.
26/11/2013, 11h01
tchize_

Effectivement, si tu lance ça depuis l'interface graphique, il faut absolument que tu crée un Thread à part qui englobe le tout (et pas seulement la réception).

Voici mon code:

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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
public class Jqvue extends javax.swing.JFrame {
 static Boolean Qled = false;
 private XYSeries series1;
 private TimeSeries essai;
 private NumberAxis range = new NumberAxis("Cel");
 private DateAxis domain = new DateAxis("Time");
 private NumberAxis Cel = new NumberAxis("C");
 private NumberAxis Imm = new NumberAxis("Immersion");
//
    public Jqvue() {
        initComponents();
        colorled(Qled);
        this.series1 = new XYSeries("Bathy");
        this.essai = new TimeSeries("Temps réel", Second.class);
        this.essai.setMaximumItemAge(1800);
        XYSeriesCollection dataset = new XYSeriesCollection();
        dataset.addSeries(this.series1);
        TimeSeriesCollection dataset1 = new TimeSeriesCollection();
        dataset1.addSeries(this.essai);
 
        //Premier graph
 
        Cel.setTickLabelFont(new Font("SansSerif", Font.PLAIN, 12));
        Imm.setTickLabelFont(new Font("SansSerif", Font.PLAIN, 12));
        Cel.setLabelFont(new Font("SansSerif", Font.PLAIN, 14));
        Imm.setLabelFont(new Font("SansSerif", Font.PLAIN, 14));
        XYItemRenderer renderer = new XYLineAndShapeRenderer(true, true);
        renderer.setSeriesPaint(0, Color.red);
        renderer.setSeriesPaint(1, Color.ORANGE);
        renderer.setStroke(new BasicStroke(3f, BasicStroke.CAP_BUTT,
        BasicStroke.JOIN_BEVEL));
        XYPlot plot = new XYPlot(dataset, Cel, Imm, renderer);
        plot.setBackgroundPaint(Color.lightGray);
        plot.setDomainGridlinePaint(Color.white);
        plot.setRangeGridlinePaint(Color.white);
        plot.setOrientation(PlotOrientation.VERTICAL);
        plot.setAxisOffset(new RectangleInsets(0.0, 0.0, 0.0, 0.0));
        Cel.setRange(1470, 1520);
        Cel.setLowerMargin(0.0);
        Cel.setUpperMargin(0.0);
        Cel.setTickLabelsVisible(true);
        Imm.setStandardTickUnits(NumberAxis.createIntegerTickUnits());
        Imm.setRange(-300, 0);
        JFreeChart chart = new JFreeChart("BATHY",
        new Font("SansSerif", Font.BOLD, 24), plot, true);
        chart.setBackgroundPaint(Color.white);
 
        //Deuzieme graph
 
        domain.setTickLabelFont(new Font("SansSerif", Font.PLAIN, 12));
        range.setTickLabelFont(new Font("SansSerif", Font.PLAIN, 12));
        domain.setLabelFont(new Font("SansSerif", Font.PLAIN, 14));
        range.setLabelFont(new Font("SansSerif", Font.PLAIN, 14));
        XYItemRenderer renderer1 = new XYLineAndShapeRenderer(true, true);
        renderer1.setSeriesPaint(0, Color.red);
        renderer1.setSeriesPaint(1, Color.ORANGE);
        renderer1.setStroke(new BasicStroke(3f, BasicStroke.CAP_BUTT,
        BasicStroke.JOIN_BEVEL));
        XYPlot plot1 = new XYPlot(dataset1,domain, range ,  renderer1);
        plot1.setBackgroundPaint(Color.lightGray);
        plot1.setDomainGridlinePaint(Color.white);
        plot1.setRangeGridlinePaint(Color.white);
        plot1.setOrientation(PlotOrientation.VERTICAL);
        plot1.setAxisOffset(new RectangleInsets(0, 0, 0, 0));
        range.setRange(1470, 1520);
        range.setLowerMargin(0.0);
        range.setUpperMargin(0.0);
        range.setTickLabelsVisible(true);
        domain.setAutoRange(true);
        domain.setLowerMargin(0.0);
        domain.setUpperMargin(0.0);
        domain.setTickLabelsVisible(true);
        JFreeChart chart1 = new JFreeChart("Graph Temps/Céléritée",
        new Font("SansSerif", Font.BOLD, 24), plot1, true);
        chart1.setBackgroundPaint(Color.white);
 
        //On rajoute au panel
 
        ChartPanel CP = new ChartPanel(chart);
        ChartPanel Graph = new ChartPanel(chart1);
        jTabbedPane1.addTab("Bathy", CP);
        jTabbedPane1.addTab("Graphique", Graph);
 private void JslEchStateChanged(javax.swing.event.ChangeEvent evt) {                                    
        int ValSlide;
        ValSlide = JslEch.getValue();
        switch(ValSlide){
        case 0 :
            range.setRange(1410, 1460);
            Cel.setRange(1410, 1460);
            break;
        case 1 :
            range.setRange(1430, 1480);
            Cel.setRange(1430, 1480);
            break;
        case 2 :
            range.setRange(1450, 1500);
            Cel.setRange(1450, 1500);
            break;
        case 3 :
            range.setRange(1470, 1520);
            Cel.setRange(1470, 1520);
            break;
        case 4 :
            range.setRange(1490, 1540);
            Cel.setRange(1490, 1540);
            break;
        case 5 :
            range.setRange(1510, 1560);
            Cel.setRange(1510, 1560);
            break;
    }
 
    }                                   
 private void colorled (Boolean tutu){
     if(tutu==true){
         led1.setLedColor(LedColor.GREEN_LED);
         led1.setLedOn(rootPaneCheckingEnabled);
        led1.setLedBlinking(rootPaneCheckingEnabled); 
     }
     else{
          led1.setLedColor(LedColor.RED);
         led1.setLedOn(rootPaneCheckingEnabled);
        led1.setLedBlinking(rootPaneCheckingEnabled);
     }
 }
 
  void MulticastListener() throws UnknownHostException, IOException {
 
     final InetAddress group = InetAddress.getByName("0.0.0.0");
     final int port = 8000;
 
     try {
 
       System.out.println("On écoute"); 
       Qled = true;
       MulticastSocket socket = new MulticastSocket(port);
       socket.setInterface(InetAddress.getLocalHost());
       socket.joinGroup(group);
 
       byte[] buffer = new byte[10*1024];
 
       DatagramPacket data = new DatagramPacket(buffer, buffer.length);
 
       while (true) {
          socket.receive(data);
 
       }
 
 
      } catch (IOException e) {
         System.out.println(e.toString());
      }
 
  }//eof MulticastListener
    /**
     * @param args the command line arguments
     */
    public static void main(String args[]) {
        /* Set the Nimbus look and feel */
        //<editor-fold defaultstate="collapsed" desc=" Look and feel setting code (optional) ">
        /* If Nimbus (introduced in Java SE 6) is not available, stay with the default look and feel.
         * For details see http://download.oracle.com/javase/tutorial/uiswing/lookandfeel/plaf.html 
         */
        try {
            for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) {
                if ("Nimbus".equals(info.getName())) {
                    javax.swing.UIManager.setLookAndFeel(info.getClassName());
                    break;
                }
            }
        } catch (ClassNotFoundException ex) {
            java.util.logging.Logger.getLogger(Jqvue.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (InstantiationException ex) {
            java.util.logging.Logger.getLogger(Jqvue.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (IllegalAccessException ex) {
            java.util.logging.Logger.getLogger(Jqvue.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (javax.swing.UnsupportedLookAndFeelException ex) {
            java.util.logging.Logger.getLogger(Jqvue.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        }
        //</editor-fold>
 
        /* Create and display the form */
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new Jqvue().setVisible(true);
 
            }
        });
    }

Je ne vois pas ou mettre mon thread.:calim2:

26/11/2013, 16h14
tchize_

Ben autour de l'intégralité du code se trouvant dans multicastlistener, tout simplement

Désolé d'insister, mais ou mettre l'appel à ma fonction multicastlistener avec mon thread.
Code:

1 2 3 4 5 6 7 Thread t = new Thread(new Runnable() { public void run() { MulticastListener(); } } t.start();

Ben, basiquement, là où dans ton code précédent, tu avais

Code:

1
2
3
//....
multicastListener();
//....

Tu auras

Code:

1
2
3
4
5
6
7
8
//....
Thread t = new Thread() { 
   public void run() {
         multicastListener();
   }
};
t.start();
//....