背景：代码的原理是opencv连接摄像头，捕获到帧数据mat（矩阵），将其转成byte数组然后进行base64编码，把数据与帧的其他信息（宽、高、通道数、时间戳）写入到json对象中，Kafka把json对象以字符串是方式发送出去；消费者（接收方）是ceph集群，拿到json对象后从中提取出帧的编码数据，作为对象内容存进去。要播放视频，就要把数据读出来，然后还原。1.遇到的问题及解决思路从ceph

从csv格式的数据集中读取数据，创建我自定义的GeoMessage对象，把对象放在集合里，通过flink的fromCollection()方法把集合作为数据源，然后通过实现map接口转换数据。需要注意的是GeoMessage类必须继承实现序列化接口，即public class GeoMessage implements Serializableimport org.apache.flink.api

Ubuntu防火墙与端口1、关闭防火墙：#sudo ufw disable关闭了防火墙，并取消了开机自启动。2、查看防火墙状态：#sudo ufw status3、开启防火墙：#sudo ufw enable4、开放端口，添加规则，在终端输入，中间的80为所需要开放的端口$ iptables -I INPUT -p tcp --dport 80 -j A...

devmem源码很短，网上可以下载到，有devmem和devmem2两个版本devmem源码地址：https://www.cnblogs.com/sky-heaven/p/13597581.htmldevmem2源码地址：http://sources.buildroot.net/devmem2.cbusybox中的devmembusybox是Linux一个调试工具箱，里面包含了devmem及其他工