glaciall / Jtt1078 Video Server

目录

1. 简介说明
2. 分支说明
3. 项目说明
4. 准备工具
5. 测试步骤
6. 测试环境
7. TODO
8. 致谢
9. 推荐群友项目
10. 交流讨论

jtt1078-video-server

基于JT/T 1078协议实现的视频转播服务器，当车机服务器端主动下发音视频实时传输控制消息（0x9101）后，车载终端连接到此服务器后，发送指定摄像头所采集的视频流，此项目服务器完成音视频数据接收并转码，完成转播的流程，提供各平台的播放支撑。

同时，本项目在配置 ffmpeg路径 及 rtmp url 后，将同时输出一路到 RTMP 服务器上去，为移动端播放提供音视频支持（注意，由于旁路的RTMP流是通过ffmpeg子进程实现，并且有音频转码的过程，所以性能将有很大的下降）。

非常感谢 孤峰赏月/hx（github/jelycom） 提供的mp3音频支持。

分支说明

原项目有4个分支不同的实现方式，现将其它分支全部删除，已经用不上了。 配置了ffmpeg和rtmp，可以想办法同时输出到比如HLS等。

有其它语言的开发者，可以参考我的“JTT/1078音视频传输协议开发指南”，我所知道的官方文档里的错误或是缺陷以及坑，我全部写了下来，希望对你有帮助。

项目说明

本项目接收来自于车载终端发过来的音视频数据，视频直接封装为FLV TAG，音频完成G.711A、G.711U、ADPCMA、G726到PCM的转码，并使用MP3压缩后再封装为FLV TAG。

视频编码支持

目前几乎所有的终端视频，默认的视频编码都是h264，打包成flv也是非常简单的，有个别厂家使用avs，但是我没有碰到过。本项目目前也只支持h264编码的视频。

音频编码支持

音频编码太多，也没那么多设备可以测试的，比较常见的就G.711A和ADPCMA这两种，本程序对于不支持的音频，将作 静音处理 。

音频编码转码扩展实现

继承并实现AudioCodec类的抽象方法，完成任意音频到PCM编码的转码过程，并且补充AudioCodec.getCodec()工厂方法即可。AudioCodec抽象类原型如下：

public abstract class AudioCodec
{
	// 转换至PCM
    public abstract byte[] toPCM(byte[] data);
    // 由PCM转为当前编码，可以留空，反正又没有调用
    public abstract byte[] fromPCM(byte[] data);
}

准备工具

项目里准备了一个测试程序（src/main/java/cn.org.hentai.jtt1078.test.VideoPushTest.java），以及一个数据文件（src/main/resources/tcpdump.bin），数据文件是通过工具采集的一段几分钟时长的车载终端发送上来的原始消息包，测试程序可以持续不断的、慢慢的发送数据文件里的内容，用来模拟车载终端发送视频流的过程。

另外，新增了 cn.org.hentai.jtt1078.test.RTPGenerate 类，用于读取bin文件，并且修改SIM卡号和通道号，创建大量数据文件以便于压力测试。

测试步骤

1. 配置好服务器端，修改app.properties里的配置项。
2. 直接在IDE里运行cn.org.hentai.jtt1078.app.VideoServerApp，或对项目进行打包，执行mvn package，执行java -jar jtt1078-video-server-1.0-SNAPSHOT.jar来启动服务器端。
3. 运行VideoPushTest.java，开始模拟车载终端的视频推送。
4. 开始后，控制台里会输出显示start publishing: 013800138999-2的字样
5. 打开浏览器，输入 http://localhost:3333/test/multimedia#013800138999-2 后回车
6. 点击网页上的play video，开始播放视频

测试环境

我在我自己的VPS上搭建了一个1078音视频环境，完全使用了flv分支上的代码来创建，各位可以让终端将音视频发送到此服务器或是使用netcat等网络工具发送模拟数据来仿真终端，来体验音视频的效果。下面我们说一下通过netcat来模拟终端的方法：

1. 首先，本项目的 /src/main/resources/ 下的 tcpdump.bin 即为我抓包存下来的终端音视频数据文件，通过cat tcpdump.bin | pv -L 40k -q | nc 103.143.81.233 10780即可以每秒40kBPS的速度，向服务器端持续的发送数据。
2. 在浏览器里打开http://1078.hentai.org.cn/test/multimedia#SIM-CHANNEL （注意替换掉后面的SIM和CHANNEL，即终端的SIM卡号，不足12位前面补0，CHANNEL即为通道号），然后点击网页上的play video即可。

项目文件说明

├── doc
│   ├── 1078.png（图标）
│   └── ffmpeg.png
├── LICENSE（开源协议）
├── pom.xml
├── README.md（项目说明）
├── src
│   └── main
│       ├── java
│       │   └── cn
│       │       └── org
│       │           └── hentai
│       │               └── jtt1078
│       │                   ├── app
│       │                   │   └── VideoServerApp.java（主入口程序）
│       │                   ├── codec
│       │                   │   ├── ADPCMCodec.java（ADPCM编解码器）
│       │                   │   ├── AudioCodec.java（音频编解码抽象父类）
│       │                   │   ├── G711Codec.java（G711A/alaw编解码器）
│       │                   │   ├── G711UCodec.java（G711U/ulaw编解码器）
│       │                   │   ├── g726（G726编解码实现）
│       │                   │   │   ├── G726_16.java
│       │                   │   │   ├── G726_24.java
│       │                   │   │   ├── G726_32.java
│       │                   │   │   ├── G726_40.java
│       │                   │   │   ├── G726.java
│       │                   │   │   └── G726State.java
│       │                   │   ├── G726Codec.java（G726编解码器）
│       │                   │   ├── MP3Encoder.java（PCM到MP3压缩编码器）
│       │                   │   └── SilenceCodec.java（静音化解码器）
│       │                   ├── entity
│       │                   │   ├── Audio.java
│       │                   │   ├── MediaEncoding.java
│       │                   │   ├── Media.java
│       │                   │   └── Video.java
│       │                   ├── flv
│       │                   │   ├── AudioTag.java
│       │                   │   ├── FlvAudioTagEncoder.java
│       │                   │   ├── FlvEncoder.java（H264到FLV封装编码器）
│       │                   │   └── FlvTag.java
│       │                   ├── http（内置HTTP服务，提供HTTP-CHUNKED传输支持）
│       │                   │   ├── GeneralResponseWriter.java
│       │                   │   └── NettyHttpServerHandler.java
│       │                   ├── publisher
│       │                   │   ├── Channel.java（一个通道一个Channel实例，Subscriber订阅Channel上的音频与视频）
│       │                   │   └── PublishManager.java（管理Channel和Subscriber）
│       │                   ├── server（负责完成1078 RTP消息包的接收和解码）
│       │                   │   ├── Jtt1078Decoder.java
│       │                   │   ├── Jtt1078Handler.java
│       │                   │   ├── Jtt1078MessageDecoder.java
│       │                   │   └── Session.java
│       │                   ├── subscriber
│       │                   │   ├── RTMPPublisher.java（通过ffmpeg子进程将http-flv另外传输一份到RTMP服务器的实现）
│       │                   │   ├── Subscriber.java（订阅者抽象类定义）
│       │                   │   └── VideoSubscriber.java（视频订阅者）
│       │                   ├── test（测试代码）
│       │                   │   ├── AudioTest.java
│       │                   │   ├── ChannelTest.java
│       │                   │   ├── FuckTest.java
│       │                   │   ├── G711ATest.java
│       │                   │   ├── MP3Test.java
│       │                   │   ├── RTPGenerate.java（通过读取原始消息数据文件，创建N个修改了sim卡号的新数据文件，可用于压力测试）
│       │                   │   ├── VideoPushTest.java
│       │                   │   ├── VideoServer.java
│       │                   │   └── WAVTest.java
│       │                   └── util
│       │                       ├── ByteBufUtils.java
│       │                       ├── ByteHolder.java
│       │                       ├── ByteUtils.java
│       │                       ├── Configs.java
│       │                       ├── FileUtils.java
│       │                       ├── FLVUtils.java
│       │                       ├── Packet.java
│       │                       └── WAVUtils.java
│       └── resources
│           ├── app.properties（主配置文件）
│           ├── audio.html
│           ├── g726
│           │   ├── in_16.g726
│           │   ├── in_24.g726
│           │   ├── in_32.g726
│           │   └── in_40.g726
│           ├── log4j.properties
│           ├── multimedia.html（测试用音视频播放页面）
│           ├── tcpdump.bin（测试用数据文件，音频ADPCM含海思头，视频H264）
│           ├── nginx_sample.conf（NGINX反向代理样例，解决6路并发问题）
│           ├── test.html
│           └── video.html

项目打包说明

通过mvn package直接打包成jar包，通过java -jar jtt1078-video-server-1.0-SNAPSHOT.jar即可运行，最好把app.properties和multimedia.html一并放在同一个目录下，因为项目会优先读取文件系统中的配置文件信息。而如果没有本地测试的需求，multimedia.html可以不要。

注意事项

1. 本项目为JT 1078协议的流媒体服务器部分的实现，不包括1078协议的控制消息交互部分，就是在0x9101指令下发后，终端连接到的音视频服务器的实现。
2. 在一般的浏览器里，比如Chrome下，浏览器限制了对于同一个域名的连接最多只能够有6个并发，所以如果要同时播放多路视频，需要准备多个域名或是端口，通过轮循分配的方式，把视频的传输连接，分配到不同的URL上去。

致谢

本项目一开始只是个简单的示例项目，在开源、建立QQ交流群后，得到了大批的同道中人的帮助和支持，在此表示谢意。本项目尚未完全完善，非常高兴能够有更多的朋友一起加入进来，一起提出更加闪亮的想法，建设更加强大的视频监控平台！

致谢名单

非常感谢以下网友的帮助和支持，以及其他默默支持的朋友们！

• 不岸不名
• 故事~
• 小黄瓜要吃饭
• yedajiang44.com（github.com/yedajiang44）
• 幸福一定强
• minigps-基站定位服务
• 慢慢
• power LXC
• 奎杜
• 孤峰赏月/hx（github/jelycom）
• 洛奇（cuiyaonan）
• tmyam

推荐群友项目

交流讨论

QQ群：808432702，加入我们，群里有热心的同道中人、相关资料、测试数据、代码以及各种方案的先行者等着你。