Examples of java.net.MulticastSocket.send()

java.net.MulticastSocket.send()
Sends a datagram packet to the destination, with a TTL (time- to-live) other than the default for the socket. This method need only be used in instances where a particular TTL is desired; otherwise it is preferable to set a TTL once on the socket, and use that default TTL for all packets. This method does not alter the default TTL for the socket. Its behavior may be affected by setInterface.
If there is a security manager, this method first performs some security checks. First, if p.getAddress().isMulticastAddress() is true, this method calls the security manager's checkMulticast method with p.getAddress() and ttl as its arguments. If the evaluation of that expression is false, this method instead calls the security manager's checkConnect method with arguments p.getAddress().getHostAddress() and p.getPort(). Each call to a security manager method could result in a SecurityException if the operation is not allowed. @param p is the packet to be sent. The packet should containthe destination multicast ip address and the data to be sent. One does not need to be the member of the group to send packets to a destination multicast address. @param ttl optional time to live for multicast packet.default ttl is 1. @exception IOException is raised if an error occurs i.eerror while setting ttl. @exception SecurityException if a security manager exists and its checkMulticast or checkConnect method doesn't allow the send. @deprecated Use the following code or its equivalent instead:...... int ttl = mcastSocket.getTimeToLive(); mcastSocket.setTimeToLive(newttl); mcastSocket.send(p); mcastSocket.setTimeToLive(ttl); ...... @see DatagramSocket#send @see DatagramSocket#receive @see SecurityManager#checkMulticast(java.net.InetAddress,byte) @see SecurityManager#checkConnect


        // tests if received packet is truncated after length was set to 1
        sendData = message.getBytes();
        sendDatagram = new DatagramPacket(sendData, 0, sendData.length,
                group, PORT);
        socket.send(sendDatagram);
        recvDatagram.setLength(1);
        socket.receive(recvDatagram);
        assertEquals("Received message was not truncated", 1,
                recvDatagram.getLength());
        assertSame("Received message is invalid", sendData[0], recvData[0]);

View Full Code Here

            // send the datagram
            byte[] sendData = message.getBytes();
            DatagramPacket sendDatagram = new DatagramPacket(sendData, 0,
                    sendData.length, new InetSocketAddress(InetAddress
                            .getByName(ADDRESS), PORT));
            socket.send(sendDatagram);


            // receive the datagram
            byte[] recvData = new byte[100];
            DatagramPacket recvDatagram = new DatagramPacket(recvData,
                    recvData.length);

View Full Code Here

            // send the datagram
            byte[] sendData = message.getBytes();
            DatagramPacket sendDatagram = new DatagramPacket(sendData, 0,
                    sendData.length, new InetSocketAddress(InetAddress
                            .getByName(ADDRESS), PORT));
            socket.send(sendDatagram);


            // receive the datagram
            byte[] recvData = new byte[100];
            DatagramPacket recvDatagram = new DatagramPacket(recvData,
                    recvData.length);

View Full Code Here

                        buf[i] = (byte) i;
                    }
                    DatagramPacket pack = new DatagramPacket(buf, buf.length,
                                                             InetAddress.getByName(group), port);
                    s.setTimeToLive(2);
                    s.send(pack);
                    System.out.println("Sent test data");
                    s.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    canRunTests = false;

View Full Code Here

                        String msg = IOUtils.readStringFromStream(ins);
                        msg = msg.replace("urn:uuid:883d0d53-92aa-4066-9b6f-9eadb1832366",
                                          incoming);
                        byte out[] = msg.getBytes("UTF-8");
                        DatagramPacket outp = new DatagramPacket(out, 0, out.length, sa);
                        s.send(outp);
                    }
                    
                    s.close();
                } catch (Throwable t) {
                    t.printStackTrace();

View Full Code Here

            data.append(":" + partitionName);
         byte[] buf = data.toString().getBytes();
         packet = new DatagramPacket(buf, buf.length, iaGroup, port);
         if (trace)
            log.trace("Sending discovery packet(" + data + ") to: " + iaGroup + ":" + port);
         s.send(packet);
         // Look for a reply
         // IP address + port number = 128.128.128.128:65535 => (12+3) + 1 + (5) = 21


         buf = new byte[50];
         packet = new DatagramPacket(buf, buf.length);

View Full Code Here

            } else {
                sendDP = new DatagramPacket(buf2, buf2.length, address, port);
                multicastStateManager.rebindToPort(port);
                MulticastSocket ms = this.multicastStateManager.getMulticastSocket();


                ms.send(sendDP);
                written = sendDP.getLength();
            }


            return runtime.newFixnum(written);

View Full Code Here

                        buf[i] = (byte) i;
                    }
                    DatagramPacket pack = new DatagramPacket(buf, buf.length,
                                                             InetAddress.getByName(group), port);
                    s.setTimeToLive(2);
                    s.send(pack);
                    System.out.println("Sent test data");
                    s.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    canRunTests = false;

View Full Code Here

      
      // Create Multicast Socket
      MulticastSocket resSock = new MulticastSocket();
      
      // Send response
      resSock.send(response);
      
      log.debug("[MulticastDiscovery] Responded Discovery Request");
    } catch (Exception e) {
      log.error("[MulticastDiscovery] Service Failed to Reply",e);
    }

View Full Code Here

    
    // Send Request
    byte[] greet = GREET_MSG.getBytes("UTF-8");
    DatagramPacket request = new DatagramPacket(greet, greet.length, SERVICE_REQUEST_IP, SERVICE_PORT);
    MulticastSocket reqSock = new MulticastSocket();
    reqSock.send(request);
    
    // Wait for Response
    MulticastSocket resSock = new MulticastSocket(SERVICE_PORT);
    resSock.joinGroup(SERVICE_RESPONSE_IP);

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.