frank
7 years ago
parent
39808aca1c
commit
e394737800
@ -0,0 +1,178 @@ |
||||
//
|
||||
// Created by frank on 2018/2/2.
|
||||
//
|
||||
|
||||
#include <jni.h> |
||||
#include <string> |
||||
#include <android/log.h> |
||||
|
||||
#define LOG_TAG "FFmpegLive" |
||||
#define LOGE(...) __android_log_print(ANDROID_LOG_ERROR, LOG_TAG, __VA_ARGS__) |
||||
#define LOGI(...) __android_log_print(ANDROID_LOG_INFO, LOG_TAG, __VA_ARGS__) |
||||
|
||||
#ifdef __cplusplus |
||||
extern "C" { |
||||
#endif |
||||
#include <libavcodec/avcodec.h> |
||||
#include <libavformat/avformat.h> |
||||
#include <libavfilter/avfilter.h> |
||||
#include <libavutil/time.h> |
||||
|
||||
JNIEXPORT jint JNICALL |
||||
Java_com_frank_ffmpeg_Pusher_pushStream(JNIEnv *env, jobject, jstring filePath, jstring liveUrl) { |
||||
|
||||
AVOutputFormat *output_format = NULL; |
||||
AVFormatContext *in_format = NULL, *out_format = NULL; |
||||
AVPacket packet; |
||||
const char *file_path, *live_url; |
||||
int video_index = -1; |
||||
int ret = 0, i; |
||||
int frame_index = 0; |
||||
int64_t start_time = 0; |
||||
|
||||
file_path = env->GetStringUTFChars(filePath, NULL); |
||||
live_url = env->GetStringUTFChars(liveUrl, NULL); |
||||
|
||||
LOGI("file_path=%s", file_path); |
||||
LOGI("live_url=%s", live_url); |
||||
|
||||
//注册所有组件
|
||||
av_register_all(); |
||||
//初始化网络
|
||||
avformat_network_init(); |
||||
//打开输入文件
|
||||
if((ret = avformat_open_input(&in_format, file_path, 0, 0)) < 0){ |
||||
LOGE("could not open input file..."); |
||||
goto end; |
||||
} |
||||
//寻找流信息
|
||||
if((ret = avformat_find_stream_info(in_format, 0)) < 0){ |
||||
LOGE("could not find stream info..."); |
||||
goto end; |
||||
} |
||||
//
|
||||
for(i=0; i<in_format->nb_streams; i++){ |
||||
//找到视频流
|
||||
if(in_format->streams[i]->codec->codec_type == AVMEDIA_TYPE_VIDEO){ |
||||
video_index = i; |
||||
break; |
||||
} |
||||
} |
||||
av_dump_format(in_format, 0, file_path, 0); |
||||
//分配输出封装格式上下文， rtmp协议支持格式为flv
|
||||
avformat_alloc_output_context2(&out_format, NULL, "flv", live_url); |
||||
if(!out_format){ |
||||
LOGE("could not alloc output context..."); |
||||
ret = AVERROR_UNKNOWN; |
||||
goto end; |
||||
} |
||||
//根据输入流来创建输出流
|
||||
for(i=0; i<in_format->nb_streams; i++){ |
||||
AVStream *in_stream = in_format->streams[i]; |
||||
AVStream *out_stream = avformat_new_stream(out_format, in_stream->codec->codec); |
||||
if(!out_stream){ |
||||
LOGE("could not alloc output stream..."); |
||||
ret = AVERROR_UNKNOWN; |
||||
goto end; |
||||
} |
||||
//复制封装格式上下文
|
||||
ret = avcodec_copy_context(out_stream->codec, in_stream->codec); |
||||
if(ret < 0){ |
||||
LOGE("could not copy context..."); |
||||
goto end; |
||||
} |
||||
out_stream->codec->codec_tag = 0; |
||||
if(out_format->oformat->flags & AVFMT_GLOBALHEADER){ |
||||
out_stream->codec->flags |= CODEC_FLAG_GLOBAL_HEADER; |
||||
} |
||||
} |
||||
//封装格式
|
||||
output_format = out_format->oformat; |
||||
//打开输出文件/URL
|
||||
if(!(output_format->flags & AVFMT_NOFILE)){ |
||||
ret = avio_open(&out_format->pb, live_url, AVIO_FLAG_WRITE); |
||||
if(ret < 0){ |
||||
LOGE("could not open output url '%s'", live_url); |
||||
goto end; |
||||
} |
||||
} |
||||
//写文件头
|
||||
ret = avformat_write_header(out_format, NULL); |
||||
if(ret < 0){ |
||||
LOGE("could not write header..."); |
||||
goto end; |
||||
} |
||||
//获取开始时间
|
||||
start_time = av_gettime(); |
||||
//开始循环读一帧数据
|
||||
while (1){ |
||||
AVStream *in_stream, *out_stream; |
||||
ret = av_read_frame(in_format, &packet); |
||||
if(ret < 0){ |
||||
break; |
||||
} |
||||
//计算帧间隔，参考时钟/采样率
|
||||
if(packet.pts == AV_NOPTS_VALUE){ |
||||
AVRational time_base = in_format->streams[video_index]->time_base; |
||||
int64_t cal_duration = (int64_t)(AV_TIME_BASE/av_q2d(in_format->streams[video_index]->r_frame_rate)); |
||||
packet.pts = (int64_t)((frame_index * cal_duration)/(av_q2d(time_base) * AV_TIME_BASE)); |
||||
packet.dts = packet.pts; |
||||
packet.duration = (int64_t)(cal_duration/(av_q2d(time_base) * AV_TIME_BASE)); |
||||
} |
||||
//视频帧之间延时
|
||||
if(packet.stream_index == video_index){ |
||||
AVRational time_base = in_format->streams[video_index]->time_base; |
||||
AVRational time_base_q = {1, AV_TIME_BASE}; |
||||
int64_t pts_time = av_rescale_q(packet.dts, time_base, time_base_q); |
||||
int64_t now_time = av_gettime() - start_time; |
||||
//延时以保持同步
|
||||
if(pts_time > now_time){ |
||||
av_usleep((unsigned int)(pts_time - now_time)); |
||||
} |
||||
} |
||||
in_stream = in_format->streams[packet.stream_index]; |
||||
out_stream = out_format->streams[packet.stream_index]; |
||||
|
||||
//pts/dts转换
|
||||
packet.pts = av_rescale_q_rnd(packet.pts, in_stream->time_base, out_stream->time_base, |
||||
(AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX)); |
||||
packet.dts = av_rescale_q_rnd(packet.dts, in_stream->time_base, out_stream->time_base, |
||||
(AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX)); |
||||
packet.duration = av_rescale_q(packet.duration, in_stream->time_base, out_stream->time_base); |
||||
packet.pos = -1; |
||||
|
||||
//视频帧计数
|
||||
if(packet.stream_index == video_index){ |
||||
frame_index ++; |
||||
LOGI("write frame = %d", frame_index); |
||||
} |
||||
//写一帧数据
|
||||
ret = av_interleaved_write_frame(out_format, &packet); |
||||
if(ret < 0){ |
||||
LOGE("could not write frame..."); |
||||
break; |
||||
} |
||||
//释放包数据内存
|
||||
av_packet_unref(&packet); |
||||
} |
||||
//写文件尾
|
||||
av_write_trailer(out_format); |
||||
|
||||
end: |
||||
avformat_close_input(&in_format); |
||||
if(out_format && !(out_format->flags & AVFMT_NOFILE)){ |
||||
avio_close(out_format->pb); |
||||
} |
||||
avformat_free_context(in_format); |
||||
avformat_free_context(out_format); |
||||
env->ReleaseStringUTFChars(filePath, file_path); |
||||
env->ReleaseStringUTFChars(liveUrl, live_url); |
||||
if(ret < 0 && ret != AVERROR_EOF){ |
||||
return -1; |
||||
} |
||||
return 0; |
||||
} |
||||
|
||||
#ifdef __cplusplus |
||||
} |
||||
#endif |
||||
@ -0,0 +1,16 @@ |
||||
package com.frank.ffmpeg; |
||||
|
||||
/** |
||||
* 使用FFmepg进行推流直播 |
||||
* Created by frank on 2018/2/2. |
||||
*/ |
||||
|
||||
public class Pusher { |
||||
static { |
||||
System.loadLibrary("media-handle"); |
||||
} |
||||
|
||||
//选择本地文件推流到指定平台直播
|
||||
public native int pushStream(String filePath, String liveUrl); |
||||
|
||||
} |
||||
@ -0,0 +1,72 @@ |
||||
package com.frank.ffmpeg.activity; |
||||
|
||||
import android.support.v7.app.AppCompatActivity; |
||||
import android.os.Bundle; |
||||
import android.text.TextUtils; |
||||
import android.util.Log; |
||||
import android.view.View; |
||||
import android.widget.Button; |
||||
import android.widget.EditText; |
||||
import android.widget.Toast; |
||||
|
||||
import com.frank.ffmpeg.Pusher; |
||||
import com.frank.ffmpeg.R; |
||||
|
||||
import java.io.File; |
||||
|
||||
/** |
||||
* 使用ffmpeg推流直播 |
||||
* Created by frank on 2018/2/2. |
||||
*/ |
||||
public class PushActivity extends AppCompatActivity { |
||||
|
||||
private static final String TAG = PushActivity.class.getSimpleName(); |
||||
private static final String FILE_PATH = "storage/emulated/0/hello.flv"; |
||||
private static final String LIVE_URL = "rtmp://192.168.1.104/live/stream"; |
||||
|
||||
@Override |
||||
protected void onCreate(Bundle savedInstanceState) { |
||||
super.onCreate(savedInstanceState); |
||||
setContentView(R.layout.activity_push); |
||||
|
||||
initView(); |
||||
} |
||||
|
||||
private void initView() { |
||||
final EditText edit_file_path = (EditText) findViewById(R.id.edit_file_path); |
||||
final EditText edit_live_url = (EditText) findViewById(R.id.edit_live_url); |
||||
edit_file_path.setText(FILE_PATH); |
||||
edit_live_url.setText(LIVE_URL); |
||||
|
||||
Button btn_push_stream = (Button)findViewById(R.id.btn_push_stream); |
||||
|
||||
btn_push_stream.setOnClickListener(new View.OnClickListener() { |
||||
@Override |
||||
public void onClick(View v) { |
||||
//TODO 视频文件格式为flv
|
||||
final String filePath = edit_file_path.getText().toString(); |
||||
final String liveUrl = edit_live_url.getText().toString(); |
||||
Log.i(TAG, "filePath=" + filePath); |
||||
Log.i(TAG, "liveUrl=" + liveUrl); |
||||
|
||||
if(!TextUtils.isEmpty(filePath) && !TextUtils.isEmpty(filePath)){ |
||||
File file = new File(filePath); |
||||
//判断文件是否存在
|
||||
if(file.exists()){ |
||||
//开启子线程
|
||||
new Thread(new Runnable() { |
||||
@Override |
||||
public void run() { |
||||
//开始推流
|
||||
new Pusher().pushStream(filePath, liveUrl); |
||||
} |
||||
}).start(); |
||||
}else { |
||||
Toast.makeText(PushActivity.this, "文件不存在", Toast.LENGTH_SHORT).show(); |
||||
} |
||||
} |
||||
} |
||||
}); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,35 @@ |
||||
<?xml version="1.0" encoding="utf-8"?> |
||||
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android" |
||||
xmlns:tools="http://schemas.android.com/tools" |
||||
android:layout_width="match_parent" |
||||
android:layout_height="match_parent" |
||||
tools:context="com.frank.ffmpeg.activity.PushActivity"> |
||||
|
||||
<EditText |
||||
android:id="@+id/edit_file_path" |
||||
android:layout_width="match_parent" |
||||
android:layout_height="wrap_content" |
||||
android:maxLines="1" |
||||
android:minWidth="200dp" |
||||
android:layout_centerInParent="true"/> |
||||
|
||||
|
||||
<EditText |
||||
android:id="@+id/edit_live_url" |
||||
android:layout_width="match_parent" |
||||
android:layout_height="wrap_content" |
||||
android:maxLines="1" |
||||
android:minWidth="200dp" |
||||
android:layout_marginTop="10dp" |
||||
android:layout_below="@+id/edit_file_path"/> |
||||
|
||||
<Button |
||||
android:id="@+id/btn_push_stream" |
||||
android:layout_width="wrap_content" |
||||
android:layout_height="wrap_content" |
||||
android:layout_marginTop="10dp" |
||||
android:layout_below="@+id/edit_live_url" |
||||
android:layout_centerHorizontal="true" |
||||
android:text="@string/video_push"/> |
||||
|
||||
</RelativeLayout> |
||||
|
After Width: | Height: | Size: 6.7 MiB |
Binary file not shown.
|
After Width: | Height: | Size: 157 KiB |
Loading…
Reference in new issue