SpringBoot 仿抖音短视频小程序开发（三）

SpringBoot 仿抖音短视频小程序开发（一）：项目的简介(https://segmentfault.com/a/11...
SpringBoot 仿抖音短视频小程序开发（二）：项目功能分析与具体实现(https://segmentfault.com/a/11...
源代码： SpringBoot 仿抖音短视频小程序开发 全栈式实战项目（https://gitee.com/scau_zns/sh...）
短视频后台管理系统：(https://gitee.com/scau_zns/sh...

// 用户列表
        var handleList = function() {
            
            // 上下文对象路径
            var hdnContextPath = $("#hdnContextPath").val();
            var apiServer = $("#apiServer").val();
            
            var jqGrid = $("#usersList");  
            jqGrid.jqGrid({  
                caption: "短视频用户列表",  
                url: hdnContextPath + "/users/list.action",  
                mtype: "post",  
                styleUI: "Bootstrap",//设置jqgrid的全局样式为bootstrap样式  
                datatype: "json",  
                colNames: ["ID", "头像", "用户名", "昵称", "粉丝数", "关注数", "获赞数"],  
                colModel: [  
                    { name: "id", index: "id", width: 30, sortable: false, hidden: false },  
                    { name: "faceImage", index: "username", width: 50, sortable: false,
                        formatter:function(cellvalue, options, rowObject) {
                            
                            var src = apiServer + cellvalue;
                            var img = "
                

                    

                        用户名:
                        
                    
                    

                        昵称:
                        
                    
                    搜    索
                
            

使用jGrid发送请求给后台

        // 条件查询所有用户列表
        $("#searchUserListButton").click(function(){
            var searchUsersListForm = $("#searchUserListForm");
            jqGrid.jqGrid().setGridParam({ 
                page: 1,
                url: hdnContextPath + "/users/list.action?" + searchUsersListForm.serialize(),
            }).trigger("reloadGrid");
        });

    $("#file").fileupload({
        pasteZone: "#bgmContent",
        dataType: "json",
        done: function(e, data) {
            console.log(data);
            
            if (data.result.status != "200") {
                alert("长传失败...");
            } else {
                var bgmServer = $("#bgmServer").val();
                var url = bgmServer + data.result.data;
                $("#bgmContent").html("点我播放");
                $("#path").attr("value", data.result.data);
            }
            
        }
    });

后台接口保存BGM的方法参考上传头像的方法

参考用户列表信息的分页查询多少

    var deleteBgm = function(bgmId) {
    var flag = window.confirm("是否确认删除？？？");
    if (!flag) {
        return;
    }
    $.ajax({
        url: $("#hdnContextPath").val() + "/video/delBgm.action?bgmId=" + bgmId,
        type: "POST",
        success: function(data) {
            if (data.status == 200 && data.msg == "OK") {
                alert("删除成功~~");
                var jqGrid = $("#bgmList");  
                jqGrid.jqGrid().trigger("reloadGrid");
            }
        }
    })
}

var forbidVideo = function(videoId) {
    var flag = window.confirm("是否禁播");
    if (!flag) {
        return;
    }
    $.ajax({
        url: $("#hdnContextPath").val() + "/video/forbidVideo.action?videoId=" + videoId,
        type: "POST",
        async: false,
        success: function(data) {
            if(data.status == 200 && data.msg == "OK") {
                alert("操作成功");
                var jqGrid = $("#usersReportsList");  
                //reloadGrid是重新加载表格
                jqGrid.jqGrid().trigger("reloadGrid");
            } else {
                console.log(JSON.stringify(data));
            }
        }
    })
}

import org.apache.curator.framework.CuratorFramework;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs.Ids;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ZKCurator {
    //zk客户端
    private CuratorFramework client = null;
    
    final static Logger log = LoggerFactory.getLogger(ZKCurator.class);
 
    public ZKCurator(CuratorFramework client) {
        this.client = client;
    }
    
    public void init() {
        client = client.usingNamespace("admin");
        try {
            //判断在admin命名空间下是否有bgm节点 /admin/bgm
            if( client.checkExists().forPath("/bgm") == null ) {
                //对于zk来讲，有两种类型的节点，一种是持久节点（永久存在，除非手动删除），另一种是临时节点（会话断开，自动删除）
                client.create().creatingParentContainersIfNeeded()
                .withMode(CreateMode.PERSISTENT) //持久节点
                .withACL(Ids.OPEN_ACL_UNSAFE)  //匿名权限
                .forPath("/bgm"); 
                log.info("zookeeper客户端连接初始化成功");
                log.info("zookeeper服务端状态：{}",client.isStarted());
            }
        } catch (Exception e) {
            log.error("zookeeper客户端连接初始化失败");
            e.printStackTrace();
        }
    }
    
    /**
     * 增加或者删除Bgm，向zk-server创建子节点，供小程序后端监听
     * @param bgmId
     * @param operType
     */
    public void sendBgmOperator(String bgmId, String operObject) {
        try {
            client.create().creatingParentContainersIfNeeded()
            .withMode(CreateMode.PERSISTENT) //持久节点
            .withACL(Ids.OPEN_ACL_UNSAFE)  //匿名权限
            .forPath("/bgm/" + bgmId, operObject.getBytes());

        } catch (Exception e) {
            e.printStackTrace();
        } 
    }
}

    @Autowired
    private ZKCurator zKCurator;
    @Override
    public void addBgm(Bgm bgm) {
        String id = sid.nextShort();
        bgm.setId(id);
        bgmMapper.insert(bgm);
        Map map = new HashMap<>();
        map.put("operType", BGMOperatorTypeEnum.ADD.type);
        map.put("path", bgm.getPath());
        zKCurator.sendBgmOperator(id, JSONUtils.toJSONString(map));
    }

    @Override
    public void deleteBgm(String id) {
        Bgm bgm = bgmMapper.selectByPrimaryKey(id);
        
        bgmMapper.deleteByPrimaryKey(id);
        Map map = new HashMap<>();
        map.put("operType", BGMOperatorTypeEnum.DELETE.type);
        map.put("path", bgm.getPath());
        zKCurator.sendBgmOperator(id, JSONUtils.toJSONString(map));
    }

初始化zookeeper客户端

   private CuratorFramework client = null;

    final static Logger log = LoggerFactory.getLogger(ZKCuratorClient.class);

//    public static final String ZOOKEEPER_SERVER = "120.79.18.36:2181";

    public void init() {
        if(client != null) {
            return;
        }
        //重试策略
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
        //创建zk客户端  120.79.18.36:2181
        client = CuratorFrameworkFactory.builder().connectString(resourceConfig.getZookeeperServer()).sessionTimeoutMs(10000)
                .retryPolicy(retryPolicy).namespace("admin").build();
        //启动客户端
        client.start();
        try {
            addChildWatch("/bgm");
        } catch (Exception e) {
            e.printStackTrace();
        }
    } 

监听zk-server的节点，当短视频后台管理系统上传或者删除某个BGM的时候，小程序后台服务器通过Zookeeper监听自动下载背景音乐

public void addChildWatch(String nodePath) throws Exception {
        final PathChildrenCache cache = new PathChildrenCache(client, nodePath, true);
        cache.start();
        cache.getListenable().addListener(new PathChildrenCacheListener() {
            @Override
            public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
                if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_ADDED)){
                    log.info("监听到事件CHILD_ADDED");
                    //1. 从数据库查询bgm对象，获取路径Path
                    String path = event.getData().getPath();
                    String operatorObjStr = new String(event.getData().getData());
                    Map map = JsonUtils.jsonToPojo(operatorObjStr, Map.class);
                    String operatorType = map.get("operType");
                    String songPath = map.get("path");

//                    String[] arr = path.split("/");
//                    String bgmId = arr[arr.length-1];
//                    Bgm bgm =  bgmService.queryBgmById(bgmId);
//                    if(bgm == null){
//                        return;
//                    }
                    //1.1 bgm所在的相对路径
//                String songPath = bgm.getPath();

                    //2. 定义保存到本地的bgm路径
//                String filePath = "E:imooc_videos_dev" + songPath;
                    String filePath = resourceConfig.getFileSpace() + songPath;

                    //3. 定义下载的路径（播放url）
                    String[] arrPath = songPath.split(""); //windows
//                    String[] arrPath = songPath.split("/"); //linux
                    String finalPath = "";
                    //3.1 处理url的斜杠以及编码
                    for(int i=0; i