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

  
                 Object reply = process(IPAddress, data);
                 if(reply!=null){
                   sendData = getBytes(reply);
                   DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, port);
                   serverSocket.send(sendPacket);
                 }
               }catch (Exception e) {
                 e.printStackTrace();
               }
      } catch (Exception e) {

View Full Code Here

        MulticastSocket receiver = new MulticastSocket(0);
        receiver.joinGroup(multicastAddress);


        MulticastSocket sender = new MulticastSocket();
        sender.setTimeToLive(1);
        sender.send(new DatagramPacket(new byte[]{1}, 0, 1, multicastAddress, receiver.getLocalPort()));
        sender.close();


        byte[] buffer = new byte[1];
        receiver.setSoTimeout(1000);
        try

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

                        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

                    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

            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

      int retries = mcast.retries+1;
      do {
        try {
          logger.log(Logger.FINER, "MainDetectionManager::multicAsk(): sending msg =\""+request+"\" to "+mcast.address+":"+mcast.port);
          packet = new DatagramPacket(request.getBytes(PROTO_ENCODING), request.length(), mcastGroupAddress, mcast.port);
          socket.send(packet);


          do {
            try {
              // get responses
              byte[] buf = new byte[DGRAM_BUF_LEN];

View Full Code Here

/* 1463 */         data.append(":" + partitionName);
/* 1464 */       byte[] buf = data.toString().getBytes();
/* 1465 */       DatagramPacket packet = new DatagramPacket(buf, buf.length, iaGroup, port);
/* 1466 */       if (trace)
/* 1467 */         log.trace("Sending discovery packet(" + data + ") to: " + iaGroup + ":" + port);
/* 1468 */       s.send(packet);
/*      */ 
/* 1472 */       buf = new byte[50];
/* 1473 */       packet = new DatagramPacket(buf, buf.length);
/* 1474 */       s.receive(packet);
/* 1475 */       String myServer = new String(packet.getData()).trim();

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

    MulticastSocket multicastSocket = new MulticastSocket(3351);
    InetAddress mcastaddr = InetAddress.getByName("233.252.1.32");
    multicastSocket.joinGroup(mcastaddr);
    multicastSocket.setSoTimeout(3000);
    String msg = "SRSIMSRV";
    multicastSocket.send(new DatagramPacket(msg.getBytes(), msg.length(),
        mcastaddr, 3351));
    DatagramPacket p = new DatagramPacket(new byte[23], 23);
    do {
      multicastSocket.receive(p);
      msg = new String(p.getData());

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.