question on JMF

[S Thanigaivel]

My aim is to transmit encrypted audio and video data across network (for developing secured video conferencing system). I 'm using RTPConnector and able to transmit media across network, but i'm not able to transmit the encrypted data. Previously, i was trying with EncryptionInfo class but it is of no use so i switched to RTPConnector and using RTPSocketAdapter.

Actually, when i encrypt and transmit data, receiver(ReceiveStreamListener methods are not invoked) couldn't recognize it.
but when i transmit the same data without encryption the receiver is able to recognize. - why is it so?

How to encrypt audio and video data properly?
How to transmit the encrypted audio and video over n/w as streams?
How to receive the encrypted data, decrypt, and play the same data using JMF as streams?

Help me out plz...
--------------------
Thanks in Advance

Thanigaivel S.

[Michael Lloyd Lee]

How are you encrypting/decrypting the data? (which encryption method are you using?)
Does said method support streaming?

[S Thanigaivel]

Originally posted by Michael Lloyd Lee:
How are you encrypting/decrypting the data? (which encryption method are you using?)
Does said method support streaming?

// for encryption
public byte[] encode(byte[] bArray,SecretKey secretKey)
{
        byte[] retArray= new byte[bArray.length];
        try {
cipher = Cipher.getInstance( "DES" );
cipher.init(Cipher.ENCRYPT_MODE, secretKey);
retArray = cipher.doFinal(bArray);
         } catch (Exception e) 
           {
e.printStackTrace();
           }
          return retArray;
}

  
// for decryption
public byte[] decode(byte[] bArray,SecretKey secretKey)
{
        byte[] retArray= new byte[bArray.length];
        try {
cipher = Cipher.getInstance( "DES" );
cipher.init( Cipher.DECRYPT_MODE, secretKey);
retArray = cipher.doFinal(bArray);
        } catch (Exception e) 
        {
e.printStackTrace();
        }
        return retArray;
}
 

  
// receiver side code
 
public int read(byte buffer[], int offset, int length) 
{
   try {
     DatagramPacket p = new DatagramPacket(buffer, offset, length, addr, port);
     synchronized (this) 
     {
         byte[] buffer1 = new byte[2048];
         sock.receive(p);
         
         if (enc==1)
         { 
            ByteArrayInputStream bi = new ByteArrayInputStream(buffer);
            byte[] bylen = new byte[4];
            bi.read(bylen,0,4);
            String sblen = new String(bylen);
            sblen = sblen.trim();
            int blen = Integer.parseInt(sblen);
            byte[] buffer2 = new byte[blen];
            bi.read(buffer2,0,blen);
            byte[] buffer3 = new byte[2048];
[B]
            buffer3 = AVTransmit3.des.decode(buffer2,AVTransmit3.skey);                     // decryption using des algo
 
[/B]
 
            ByteArrayInputStream bi1 = new ByteArrayInputStream(buffer3);
            byte[] buffer4 = new byte[2048];
            bi1.read(buffer4,0,buffer3.length);
            buffer = buffer4;
          }
          System.out.println("Read2: " + offset+ " Len(buffer): " + length + " Port: " + port+" Addr: "+addr);
                                          //}
          dataRead = true;
          notify();
       }
       return p.getLength();
    } catch (Exception e) 
       { 
          System.out.println(e);
          return -1;
       }
 
}
 

 
// Transmitter side
 
public int write(byte data[], int offset, int length) 
{
     try {
            if (enc ==1)
            {
[B]byte [] buffer1 = AVTransmit3.des.encode(data,AVTransmit3.skey);                 // encryption using des algo
[/B]
 
// ** Start Concat**
String sblen;
int blen = buffer1.length;
//System.out.println("Send1: " + " Len: " + blen+ " datalen: " + data.length);
if (blen <10)
sblen = "   "+blen;
else if(blen <100)
sblen = "  "+blen;
else if(blen <1000)
sblen = " "+blen;
else 
sblen = ""+blen;
byte[] bylen = sblen.getBytes();

ByteArrayOutputStream ba = new ByteArrayOutputStream(blen+4);
ba.write(bylen,0,bylen.length);
ba.write(buffer1,0,blen);

// **End Concat**

byte[] buffer2 = ba.toByteArray();

//byte[] b = (Integer(buffer1.length)).getBytes();
sock.send(new DatagramPacket(buffer2, offset, buffer2.length, addr, port));
                 //sock.send(new DatagramPacket(data, offset, length, addr, port));
System.out.println("Offset1: " + buffer2.length + " addr" + addr + " port" + port);
            }
            else
            {
sock.send(new DatagramPacket(data, offset, length, addr, port));
System.out.println("Offset2: " + data.length + " addr" + addr + " port" + port);
             }
         } catch (Exception e) 
           { 
              System.out.println(e);
              return -1;
            }
           return length;
}
 

This is how i encrypt/decrypt