'commit'

dsSupport/Utils/ConvertUtil/ConvertUtil.go

@@ -112,7 +112,7 @@ func GetAllCutChild(source string) []string {
 func ConvertToH264Mp4(childMovie string) {
 	extension := path.Ext(childMovie)
 	childMovieMp4 := strings.Replace(filepath.Base(childMovie), extension, ".mp4", -1)
-	CommonUtil.Exec(ffmpeg, getWorkingPath(childMovieMp4, WorkingCutPath), `-i`, childMovie, `-c:v`, `libx264`, `-strict`, `-2`,
+	CommonUtil.Exec(ffmpeg, getWorkingPath(childMovieMp4, WorkingCutPath), `-i`, childMovie, `-c:v`, `libx264`,`-threads`, `16`, `-strict`, `-2`,
 		getWorkingPath(childMovieMp4, WorkingMp4Path)+childMovieMp4)
 }
 

dsSupport/思路.txt

@@ -0,0 +1,44 @@
+组长（Master)N名 ，每个任务按 任务ID%N=第几个组长机进行执行下面的任务。
+（1）生成关键帧 （一般速度较快）
+（2）切开视频   （一般速度较快）
+（3）生成待转码视频任务
+
+组员（处理机）M（名）
+（1）
+
+
+创建topic
+/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --partitions 3 --replication-factor 1 --topic test
+
+删除topic
+/usr/local/kafka/bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic test
+
+修改分区个数
+/usr/local/kafka/bin/kafka-topics.sh --alter --zookeeper 127.0.0.1:2181 --topic dsideal_db --partitions 3
+
+发送
+/usr/local/kafka/bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
+
+测试接收
+/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
+
+/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test
+
+查看
+/usr/local/kafka/bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic test
+
+消费者组[这个玩意有用！可以保证只有一个消费者获取到这条数据]
+/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092  --topic test --consumer-property group.id=group_mytest
+
+
+
+#  有用的文章：
+https://blog.csdn.net/u012369535/article/details/93844653
+
+
+#如果处理机有N台宕机了，如何处理异常？
+应该有一个定时检查已发布任务的轮询机制，对于正常执行需要10分钟的任务，现在超过了6*10还没有回写完成标识，需要重新入队列即可解决。
+
+
+# 关于优先级队列的理解和认识
+http://qiankunli.github.io/2019/04/27/kafka_priority.html