[Java] Proxy Rtsp & application android

Proxy Rtsp & application android [Java] - Java - Programmation

Marsh Posté le 06-05-2010 à 15:21:07    

Bonjour,
je suis entrain de développer une application sous Android qui permet de lire des vidéos depuis un serveur VOD. l'application utilise le procole RTSP. La particularité de l'application est qu'elle est censé adapté le bitrate de la video en fonction du debit du terminal (si on utilise une connexion 3G, wifi, etc).
 
Pour cela, on va utiliser un Proxy Rtsp. Le proxy Rtsp va instancier VLC en mode "transcodage", c'est ce dernier qui va encoder la vidéo a la volé puis l'envoyer vers le terminal mobile, un petit schéma explicatif :  
http://img532.imageshack.us/img532/4993/helpa.jpg
 
le flux brut arrive sur le serveur de transcodage, puis le serveur de transcodage renvoie la video sur le terminal.
Pour l'instant en phase de devéloppement, j'ai qqs petits soucis :  
 
le proxy fonctionne a peu près correctement, j'arrive avec un client vlc et un vod vlc a lire une vidéo via le proxy.
 
J'essaye ensuite de rediriger la vidéo du VOD vers un autre client VLC qui lui demande a lire un flux UDP mais la ca coince...
niveau trame IP (avec wireshark), j'ai du ICMP "destination unreachable"
 
 
Pour rediriger le flux, je demande au client VLC 1 de demander telle video via le proxy, ensuite je modifie les ports dans les requetes RTSP puis j'envoie le flux audio et video vers un ports X et Y. j'essaye ensuite de lire le flux UDP X avec un client VLC 2 mais ca ne fonctionne pas... qqun aurait une idée?
 
merci!
 
PS : les sources ainsi que l'appli android sont dispo sur ce serveur svn : http://code.google.com/p/androidautotranscodeplayer
 
je met le code si des personnes sont inspirées... :  
 

Code :
  1. import java.io.*;
  2. import java.net.*;
  4. public class proxy {
  5. static private int END = 0;
  6. final static String CRLF = "\r\n";
  7. static private int nb_control = 0;
  8. static private int indes = 0;//pour indiquer qu'on est dans un bloc DESCRIBE
  9. static private int transport =0; //nombre de transport
  10. static String SOURCEAUDIOPORT;
  11. static String SOURCEVIDEOPORT;
  12. static public String convertMsg(String str,int portVod,String Ip){
  13.  String msgModifie;
  14.  if (str.equals("" )){
  15.   msgModifie=CRLF;
  16.  }
  17.  else{
  18.   String controlString = str.split(" " )[0];
  20.   if (controlString.equals("OPTIONS" ) || controlString.equals("PLAY" ) || controlString.equals("PAUSE" )){
  21.    String controlField[] = str.split(" " )[1].split("/" );
  22.    String videoName = controlField[controlField.length -1];
  23.    msgModifie=controlString+" rtsp://" + Ip + ":" + portVod + "/" + videoName + " RTSP/1.0"+CRLF;
  25.   }
  26.   else if(controlString.equals("DESCRIBE" )){
  27.    String controlField[] = str.split(" " )[1].split("/" );
  28.    String videoName = controlField[controlField.length -1];
  29.    msgModifie=controlString+" rtsp://" + Ip + ":" + portVod + "/" + videoName + " RTSP/1.0"+CRLF;
  30.    indes=1;
  31.   }
  32.   else if (controlString.equals("SETUP" )) {
  33.    String controlField[] = str.split(" " )[1].split("/" );
  34.    String videoName = controlField[controlField.length -2];
  35.    String content = controlField[controlField.length -1];
  36.    msgModifie=controlString+" rtsp://" + Ip + ":" + portVod + "/" + videoName + "/" + content + " RTSP/1.0" + CRLF;
  39.   }
  40.   else if (controlString.equals("Transport:" )){
  41.    if (transport==0){
  42.    SOURCEAUDIOPORT = str.split("=" )[1];
  43.    msgModifie="Transport: RTP/AVP;unicast;client_port=10000-10001";
  44.    transport++;}
  45.    else if(transport==2){
  46.     SOURCEVIDEOPORT = str.split("=" )[1];
  47.     msgModifie="Transport: RTP/AVP;unicast;client_port=20000-20001";
  48.     transport++;
  49.    }
  50.    else
  51.    {
  52.     msgModifie=str;
  53.    }
  54.    return msgModifie;
  55.   }
  56.   else if (controlString.equals("TEARDOWN" )){
  57.    String controlField[] = str.split(" " )[1].split("/" );
  58.    String videoName = controlField[controlField.length -1];
  59.    msgModifie=controlString+" rtsp://" + Ip + ":" + portVod + "/" + videoName + " RTSP/1.0"+CRLF;
  60.    END = 1;
  62.   }
  63.   else{
  64.    msgModifie = str+CRLF;
  65.   }
  66.  }
  68.  return msgModifie;
  69. }
  70. static public String convertMsgVOD(String str,int portProxy,String IpProxy){
  71.  String msgModifieVOD;
  72.  if (str.equals("" )){
  73.   msgModifieVOD=CRLF;
  74.  }
  76.  else {
  77.   String controlFieldVOD[] = str.split(":" );
  78.   String controlVOD=controlFieldVOD[0];
  79.   if (controlVOD.equals("a=control" )){
  80.    String fields[] = controlFieldVOD[controlFieldVOD.length -1].split("/" );
  81.    String videoName=fields[1];
  82.    String contentTrack=fields[2];
  83.    msgModifieVOD=controlVOD+":rtsp://" + IpProxy + ":" + portProxy + "/" + videoName + "/" + contentTrack + CRLF;
  84.    nb_control=nb_control+1;
  85.   }
  86.   else if (controlVOD.equals("Transport" ))
  87.   {
  88.    if (transport==1){
  89.    msgModifieVOD="Transport: RTP/AVP/UDP;client_port="+SOURCEAUDIOPORT;
  90.    transport++;}
  91.    else if(transport==3){
  92.     msgModifieVOD="Transport: RTP/AVP/UDP;client_port="+SOURCEVIDEOPORT;
  93.     transport++;}
  94.    else
  95.     msgModifieVOD=str;
  96.   }
  98.   else{
  99.    msgModifieVOD=str+CRLF;
  100.   }
  102.  }
  103.  return msgModifieVOD;
  104. }
  106. public static void main(String[] args ) {
  108.  int portProxy = 5578;
  109.  int portVod = 1234;
  110.  String msgClient;
  111.  String msgModifie;
  112.  String msgVod;
  113.  String msgModifieR;
  116.  try {
  117.   ServerSocket serverSocket = new ServerSocket(portProxy);
  118.   System.out.println("Serv Started: " + serverSocket);
  119.   Socket socketClient = serverSocket.accept();
  120.   InetAddress addVod = InetAddress.getByName("127.0.0.1" );
  121.   Socket socketVod = new Socket(addVod, portVod);
  123.   BufferedReader inSClient = new BufferedReader (new InputStreamReader(socketClient.getInputStream()));
  124.   BufferedReader inSVod = new BufferedReader (new InputStreamReader(socketVod.getInputStream()));
  125.   PrintWriter outVod = new PrintWriter(socketVod.getOutputStream());
  126.   PrintWriter outClient = new PrintWriter(socketClient.getOutputStream());
  129.   do{
  130.    //client -> proxy -> vod
  132.    do{
  133.     msgClient = inSClient.readLine();
  134.     System.out.println("msg client: "+msgClient);
  135.     msgModifie = convertMsg(msgClient,portVod,"127.0.0.1" );
  136.     System.out.println("msg client modifie: " + msgModifie);
  137.     outVod.write(msgModifie);
  138.     outVod.flush();
  139.    }while(!msgClient.equals("" ));
  142.    //vod -> proxy -> client
  144.    do{
  145.     msgVod = inSVod.readLine();
  146.     System.out.println("msg vod: "+msgVod);
  147.     msgModifieR = convertMsgVOD(msgVod,portProxy,"127.0.0.1" );
  148.     System.out.println("msg vod modifi√©: "+msgModifieR);
  149.     outClient.write(msgModifieR);
  150.     outClient.flush();
  151.    }while (!msgVod.equals("" ));
  152.    if (indes==1){
  153.     while(nb_control!=2){
  154.      msgVod = inSVod.readLine();
  155.      System.out.println("msg vod: "+msgVod);
  156.      msgModifieR = convertMsgVOD(msgVod,portProxy,"127.0.0.1" );
  157.      System.out.println("msg vod modifi√©: "+msgModifieR);
  158.      outClient.write(msgModifieR);
  159.      outClient.flush();
  160.     }
  161.     indes=0;
  162.     nb_control=0;
  163.    }
  168.   }while (END ==0);
  170.   socketClient.close();
  171.   socketVod.close();
  172.   serverSocket.close();
  173.  }
  174.  catch (UnknownHostException e) {
  176.   e.printStackTrace();
  177.  }catch (IOException e) {
  179.   e.printStackTrace();
  180.  }
  181. }
  183. }


Message édité par minibox le 06-05-2010 à 15:22:41
Reply

Marsh Posté le 06-05-2010 à 15:21:07   

Reply

Marsh Posté le 08-05-2010 à 19:27:18    

salut,  
il faudrait que tu précises ton environnement réseau: LAN, internet et les connexions des clients:3G, Wifi, etc... pq là ça peut être tout à la fois.
 
Sinon merci pr le partage du code, je début sur android et je dois dire qu'ayant lu bcp de comments comme quoi android c génial, je trouve le sdk assez pourri...


---------------
Voir les RAW sous Android: https://market.android.com/details? [...] .RawVision Blog Photo: http://photouch.me Applications mobiles: http://caketuzz.com Wapcam Project: http://wapcam.mobi
Reply

Marsh Posté le 09-05-2010 à 20:13:45    

oui exacte!
je tourne sous MacOs, pour l'instant, tous les tests sont en localhost!
 
Je pense savoir d'ou ca vient, apparament, le flux UDP est mal redirigé (le "proxy" doit mal réecrire les requetes) , du coup les paquets ne peuvent pas etre "transmis" sur ce port la, ca provoque les messages ICMP! (port unreachable)
 
faut que je compare les requetes RTSP entre le client/proxy et entre le serveur/proxy pour voir si elles sont bien modifiées comme on le souhaite
 
merci en tout cas !
 
Sinon pour le SDK, je trouve que ca va, ca fonctionne bien avec eclipse mais faut juste s'y habituer je pense :)
Après, c'est vrai que android c'est a la mode :P, surtout avec les nouveaux htc qui sont aussi bien que les iphones maintenant!

Message cité 1 fois
Message édité par minibox le 09-05-2010 à 23:47:00
Reply

Marsh Posté le 10-05-2010 à 01:06:20    

minibox a écrit :


Sinon pour le SDK, je trouve que ca va, ca fonctionne bien avec eclipse mais faut juste s'y habituer je pense :)
Après, c'est vrai que android c'est a la mode :P, surtout avec les nouveaux htc qui sont aussi bien que les iphones maintenant!


 
tu as raison, j'ai fini ma première appli et c'est vrai qu'en 2 jours, c'est pas mal. Mais je trouve que pour démarrer c'est assez compliqué. Une fois lancé, ca va mieux ;)
 
Sinon, pour ton projet, débugger RTSP et RTP c'est chaud déjà en normal (j'ai fait un serveur RTSP/RTP pour WapcamServer) alors quand tu rajoutes un proxy, pfiou bonjour l'analyse des trames :(
Je ne peux que te conseiller d'essayer d'utiliser des vrais serveurs, tu y verras qd m plus clair.
 
 


---------------
Voir les RAW sous Android: https://market.android.com/details? [...] .RawVision Blog Photo: http://photouch.me Applications mobiles: http://caketuzz.com Wapcam Project: http://wapcam.mobi
Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed