TCP协议的视频聊天

package com.obo.chat; import com.obo.camera.get.OBSocketImgGet; import com.obo.camera.get.OBSocketImgGetAgent; import com.obo.camera.send.OBSocketImgSend; import com.obo.camera.surface.OBCameraAgent; import com.obo.camera.surface.OBCameraView; import com.obo.record.get.OBRecord; import com.obo.record.get.OBRecordFlowAgent; import com.obo.socket.flowget.OBSocketFlowGet; import com.obo.socket.flowget.OBSocketFlowGetAgent; import com.obo.socket.flowsend.OBSendFlow; import com.obo.track.play.OBTrack; import android.os.Bundle; import android.os.Handler; import android.graphics.Bitmap; import android.graphics.Matrix; import android.util.Log; import android.widget.ImageView; public class MainActivity extends BaseActivity implements OBSocketImgGetAgent,OBCameraAgent ,OBRecordFlowAgent ,OBSocketFlowGetAgent{ private final static String TAG = "MainActivity"; //图片接收 , 为了保证传输质量，启动了三个传输通道 OBSocketImgGet imgGet[] = new OBSocketImgGet[2]; //图片发送 ， 为了保证传输质量，启动了三个发送通道 OBSocketImgSend imgSend[] = new OBSocketImgSend[2]; //流发送 OBSendFlow sendF = null; //流接收 OBSocketFlowGet getF = null; //图片显示 ImageView imgOther = null; //相机预览界面 OBCameraView oboCamera = null; //录音 OBRecord oboRecord = null; //播放 OBTrack oboTrack = null; //用于异步线程同步到UI线程 Handler handler = new Handler(); @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); initViews(); // initActions(); } private void initViews() { imgOther = (ImageView)findViewById(R.id.img_friend); oboCamera = (OBCameraView)findViewById(R.id.view_camera_test); oboCamera.setImgAgent(this, handler); } private void initActions() { for(int i=0;i<imgGet.length;i++) { if(imgGet[i] == null) imgGet[i] = new OBSocketImgGet(this, handler, 10000+i); if(imgSend[i] == null) imgSend[i] = new OBSocketImgSend(IP, 10000+i); } if(sendF == null) sendF = new OBSendFlow(IP,10009); if(getF == null) getF = new OBSocketFlowGet(this,handler,10009); if(oboRecord == null) oboRecord = new OBRecord(this); if(oboTrack == null) oboTrack = new OBTrack(); } @Override public void getImg(Bitmap arg0) { // TODO Auto-generated method stub Matrix matrix = new Matrix(); matrix.postRotate(-90); arg0 = Bitmap.createBitmap(arg0, 0, 0, arg0.getWidth(), arg0.getHeight(), matrix, true); imgOther.setImageBitmap(arg0); } @Override public void changeIp() { // TODO Auto-generated method stub /*for(int i=0;i<imgSend.length;i++) { imgSend[i].setIp(IP);// = new OBSocketImgSend(IP, 10000+i); } sendF = new OBSendFlow(IP,10000);*/ closeAll(); initActions(); } int currentSend = 0; @Override public void getCameraImg(Bitmap arg0) { // TODO Auto-generated method stub currentSend%=3; if(imgSend[currentSend]!=null) { imgSend[currentSend].sendImg(arg0, 0.2f); currentSend++; } } @Override public void sendFlow(byte[] arg0) { // TODO Auto-generated method stub if(sendF!=null) sendF.sendFlow(arg0); } @Override public void getFlow(byte[] arg0) { // TODO Auto-generated method stub if(oboTrack!=null) oboTrack.record(arg0); } @Override public void onResume() { super.onResume(); Log.i(TAG, "监控 onResume"); initActions(); } //复原 @Override public void onStart() { super.onStart(); Log.i(TAG, "监控 onStart"); initActions(); } @Override public void onPause() { Log.i(TAG, "监控 onPause"); closeAll(); super.onPause(); } private void closeAll() { // if(oboCamera!=null) // { // oboCamera.close(); // oboCamera = null; // } if(oboRecord!=null) { try { oboRecord.close(); }catch(Exception e) { } oboRecord = null; } if(oboTrack!=null) { try { oboTrack.close(); } catch(Exception e) { } oboTrack = null; } if(getF!=null) { try { getF.close(); } catch(Exception e) { } getF = null; } if(sendF !=null) { try { sendF.close(); } catch(Exception e) { } sendF = null; } for(int i=0;i<imgGet.length;i++) { if(imgGet[i]!=null) { try{ imgGet[i].close(); } catch(Exception e) { } imgGet[i] = null; } if(imgSend[i]!=null) { try{ imgSend[i].close(); } catch(Exception e) { } imgSend[i] = null; } } } @Override public void onStop() { Log.i("", "监控 onStop"); closeAll(); super.onStop(); } @Override public void onDestroy() { Log.i("", "监控 onDestroy"); closeAll(); super.onDestroy(); } }