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

                        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

                logger.finest("send() JmDNS out:" + msg.print(true));
            } catch (final IOException e) {
                logger.throwing(getClass().toString(), "send(DNSOutgoing) - JmDNS can not parse what it sends!!!", e);
            }
            final MulticastSocket ms = socket;
            if (ms != null && !ms.isClosed()) ms.send(packet);
        }
    }


    public void startAnnouncer() {
        new Announcer(this).start(timer);

View Full Code Here

                    logger.throwing(getClass().toString(), "send(" + this.getName() + ") - JmDNS can not parse what it sends!!!", e);
                }
            }
            final MulticastSocket ms = _socket;
            if (ms != null && !ms.isClosed()) {
                ms.send(packet);
            }
        }
    }


    /*

View Full Code Here

            out = new DatagramPacket(secondMessage.getBytes("UTF-8"), secondMessage.length(), someInet, MPORT);
            inFirst = new DatagramPacket(secondMessage.getBytes("UTF-8"), secondMessage.length(), someInet, MPORT);
            receiveFirst = new Receive(firstSocket, inSecond);
            receiveFirst.start();


            secondSocket.send(out);
            if (receiveFirst.waitForReceive()) {
                Assert.fail("We did not receive the data in the first socket");
            }
            String fromSecond = new String(inFirst.getData(), "UTF-8");
            assertEquals("Expected the first socket to recieve the same message the second socket sent", secondMessage, fromSecond);

View Full Code Here

                                   // socket.receive()
        // send & recieve packet
        byte[] sendData = message.getBytes();
        DatagramPacket sendDatagram = new DatagramPacket(sendData, 0,
                sendData.length, group, PORT);
        socket.send(sendDatagram);
        socket.receive(recvDatagram);
        String recvMessage = new String(recvData, 0, recvDatagram.getLength());
        assertEquals(message, recvMessage);
        
        // send & receive longer packet

View Full Code Here

        
        // send & receive longer packet
        sendData = longerMessage.getBytes();
        sendDatagram = new DatagramPacket(sendData, 0, sendData.length,
                group, PORT);
        socket.send(sendDatagram);
        socket.receive(recvDatagram);
        recvMessage = new String(recvData, 0, recvDatagram.getLength());
        assertEquals(longerMessage, recvMessage);


        // tricky case, added to test compatibility with RI;

View Full Code Here

        // tricky case, added to test compatibility with RI;
        // depends on the previous test case
        sendData = veryLongMessage.getBytes();
        sendDatagram = new DatagramPacket(sendData, 0, sendData.length, group,
                PORT);
        socket.send(sendDatagram);
        recvDatagram.setLength(recvDatagram.getLength()); // !!!
        socket.receive(recvDatagram);
        recvMessage = new String(recvData, 0, recvDatagram.getLength());
        assertEquals(longerMessage, recvMessage);

View Full Code Here


        // 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_sock.setTrafficClass(8);
            for(int i=0; i < 10; i++) {
                start=System.currentTimeMillis();
                send_buf=Util.objectToByteBuffer(start);
                send_packet=new DatagramPacket(send_buf, 0, send_buf.length, GROUP, PORT);
                send_sock.send(send_packet);
                Util.sleep(1000);
            }
        }
        else {
            MulticastSocket recv_sock=new MulticastSocket(PORT);

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.