WebrtcDemo

package com.wangzu.webrtcdemo; import android.Manifest; import android.content.Context; import android.media.AudioManager; import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.view.KeyEvent; import android.view.MotionEvent; import android.view.View; import android.view.WindowManager; import android.widget.LinearLayout; import android.widget.TextView; import android.widget.Toast; import org.json.JSONException; import org.json.JSONObject; import org.webrtc.AudioSource; import org.webrtc.AudioTrack; import org.webrtc.Camera1Enumerator; import org.webrtc.Camera2Enumerator; import org.webrtc.CameraEnumerator; import org.webrtc.CameraVideoCapturer; import org.webrtc.DataChannel; import org.webrtc.EglBase; import org.webrtc.IceCandidate; import org.webrtc.MediaConstraints; import org.webrtc.MediaStream; import org.webrtc.PeerConnection; import org.webrtc.PeerConnectionFactory; import org.webrtc.RendererCommon; import org.webrtc.RtpReceiver; import org.webrtc.SdpObserver; import org.webrtc.SessionDescription; import org.webrtc.SurfaceViewRenderer; import org.webrtc.VideoRenderer; import org.webrtc.VideoSource; import org.webrtc.VideoTrack; import java.net.URISyntaxException; import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import io.socket.client.IO; import io.socket.client.Socket; import io.socket.emitter.Emitter; import me.weyye.hipermission.HiPermission; import me.weyye.hipermission.PermissionCallback; import me.weyye.hipermission.PermissionItem; public class MainActivity extends AppCompatActivity implements View.OnClickListener { private LinearLayout chartTools; private TextView switcCamera; private TextView loundSperaker; private SurfaceViewRenderer localView; private SurfaceViewRenderer remoteView; private PeerConnectionFactory mPeerConnectionFactory; private CameraVideoCapturer mVideoCapturer; private VideoTrack mVideoTrack; private AudioTrack mAudioTrack; private EglBase mEglBase; private MediaStream mMediaStream; private Socket mSocket; private MediaConstraints pcConstraints; private MediaConstraints sdpConstraints; private LinkedList iceServers; private Peer mPeer; private boolean isOffer = false; private AudioManager mAudioManager; private VideoTrack remoteVideoTrack; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN, WindowManager.LayoutParams.FLAG_FULLSCREEN); setContentView(R.layout.activity_main); initview(); AskPermission(); } private void AskPermission() { List permissionItems = new ArrayList(); permissionItems.add(new PermissionItem(Manifest.permission.CAMERA, "相机", R.drawable.permission_ic_camera)); permissionItems.add(new PermissionItem(Manifest.permission.WRITE_EXTERNAL_STORAGE, "存储卡", R.drawable.permission_ic_storage)); permissionItems.add(new PermissionItem(Manifest.permission.RECORD_AUDIO, "录音", R.drawable.permission_ic_micro_phone)); permissionItems.add(new PermissionItem(Manifest.permission.READ_PHONE_STATE, "手机", R.drawable.permission_ic_phone)); HiPermission.create(this).permissions(permissionItems) .checkMutiPermission(new PermissionCallback() { @Override public void onClose() { } @Override public void onFinish() { init(); } @Override public void onDeny(String permission, int position) { } @Override public void onGuarantee(String permission, int position) { } }); } private void init() { //初始化PeerConnectionFactory PeerConnectionFactory.initialize( PeerConnectionFactory.InitializationOptions.builder(getApplicationContext()) .setEnableVideoHwAcceleration(true) .createInitializationOptions()); //创建PeerConnectionFactory PeerConnectionFactory.Options options = new PeerConnectionFactory.Options(); mPeerConnectionFactory = new PeerConnectionFactory(options); //设置视频Hw加速,否则视频播放闪屏 mPeerConnectionFactory.setVideoHwAccelerationOptions(mEglBase.getEglBaseContext(), mEglBase.getEglBaseContext()); initConstraints(); mVideoCapturer = createVideoCapture(this); VideoSource videoSource = mPeerConnectionFactory.createVideoSource(mVideoCapturer); mVideoTrack = mPeerConnectionFactory.createVideoTrack("videtrack", videoSource); //设置视频画质 i:width i1 :height i2:fps mVideoCapturer.startCapture(720, 1280, 30); AudioSource audioSource = mPeerConnectionFactory.createAudioSource(new MediaConstraints()); mAudioTrack = mPeerConnectionFactory.createAudioTrack("audiotrack", audioSource); //播放本地视频 mVideoTrack.addRenderer(new VideoRenderer(localView)); //创建媒体流并加入本地音视频 mMediaStream = mPeerConnectionFactory.createLocalMediaStream("localstream"); mMediaStream.addTrack(mVideoTrack); mMediaStream.addTrack(mAudioTrack); //连接服务器 try { mSocket = IO.socket("http://10.0.0.10:6666/"); } catch (URISyntaxException e) { e.printStackTrace(); } mSocket.on("SomeOneOnline", new Emitter.Listener() { @Override public void call(Object... args) { isOffer = true; if (mPeer == null) { mPeer = new Peer(); } mPeer.peerConnection.createOffer(mPeer, sdpConstraints); } }).on("IceInfo", new Emitter.Listener() { @Override public void call(Object... args) { try { JSONObject jsonObject = new JSONObject(args[0].toString()); IceCandidate candidate = null; candidate = new IceCandidate( jsonObject.getString("id"), jsonObject.getInt("label"), jsonObject.getString("candidate") ); mPeer.peerConnection.addIceCandidate(candidate); } catch (JSONException e) { e.printStackTrace(); } } }).on("SdpInfo", new Emitter.Listener() { @Override public void call(Object... args) { if (mPeer == null) { mPeer = new Peer(); } try { JSONObject jsonObject = new JSONObject(args[0].toString()); SessionDescription description = new SessionDescription (SessionDescription.Type.fromCanonicalForm(jsonObject.getString("type")), jsonObject.getString("description")); mPeer.peerConnection.setRemoteDescription(mPeer, description); if (!isOffer) { mPeer.peerConnection.createAnswer(mPeer, sdpConstraints); } } catch (JSONException e) { e.printStackTrace(); } } }); mSocket.connect(); } private void initConstraints() {