SpringBoot 仿抖音短視頻小程序開發(fā)（三）

SpringBoot 仿抖音短視頻小程序開發(fā)（一）：項(xiàng)目的簡(jiǎn)介(https://segmentfault.com/a/11...
SpringBoot 仿抖音短視頻小程序開發(fā)（二）：項(xiàng)目功能分析與具體實(shí)現(xiàn)(https://segmentfault.com/a/11...
源代碼： SpringBoot 仿抖音短視頻小程序開發(fā) 全棧式實(shí)戰(zhàn)項(xiàng)目（https://gitee.com/scau_zns/sh...）
短視頻后臺(tái)管理系統(tǒng)：(https://gitee.com/scau_zns/sh...

// 用戶列表
        var handleList = function() {
            
            // 上下文對(duì)象路徑
            var hdnContextPath = $("#hdnContextPath").val();
            var apiServer = $("#apiServer").val();
            
            var jqGrid = $("#usersList");  
            jqGrid.jqGrid({  
                caption: "短視頻用戶列表",  
                url: hdnContextPath + "/users/list.action",  
                mtype: "post",  
                styleUI: "Bootstrap",//設(shè)置jqgrid的全局樣式為bootstrap樣式  
                datatype: "json",  
                colNames: ["ID", "頭像", "用戶名", "昵稱", "粉絲數(shù)", "關(guān)注數(shù)", "獲贊數(shù)"],  
                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發(fā)送請(qǐng)求給后臺(tái)

        // 條件查詢所有用戶列表
        $("#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("長(zhǎng)傳失敗...");
            } else {
                var bgmServer = $("#bgmServer").val();
                var url = bgmServer + data.result.data;
                $("#bgmContent").html("點(diǎn)我播放");
                $("#path").attr("value", data.result.data);
            }
            
        }
    });

后臺(tái)接口保存BGM的方法參考上傳頭像的方法

參考用戶列表信息的分頁查詢多少

    var deleteBgm = function(bgmId) {
    var flag = window.confirm("是否確認(rèn)刪除？？？");
    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節(jié)點(diǎn) /admin/bgm
            if( client.checkExists().forPath("/bgm") == null ) {
                //對(duì)于zk來講，有兩種類型的節(jié)點(diǎn)，一種是持久節(jié)點(diǎn)（永久存在，除非手動(dòng)刪除），另一種是臨時(shí)節(jié)點(diǎn)（會(huì)話斷開，自動(dòng)刪除）
                client.create().creatingParentContainersIfNeeded()
                .withMode(CreateMode.PERSISTENT) //持久節(jié)點(diǎn)
                .withACL(Ids.OPEN_ACL_UNSAFE)  //匿名權(quán)限
                .forPath("/bgm"); 
                log.info("zookeeper客戶端連接初始化成功");
                log.info("zookeeper服務(wù)端狀態(tài)：{}",client.isStarted());
            }
        } catch (Exception e) {
            log.error("zookeeper客戶端連接初始化失敗");
            e.printStackTrace();
        }
    }
    
    /**
     * 增加或者刪除Bgm，向zk-server創(chuàng)建子節(jié)點(diǎn)，供小程序后端監(jiān)聽
     * @param bgmId
     * @param operType
     */
    public void sendBgmOperator(String bgmId, String operObject) {
        try {
            client.create().creatingParentContainersIfNeeded()
            .withMode(CreateMode.PERSISTENT) //持久節(jié)點(diǎn)
            .withACL(Ids.OPEN_ACL_UNSAFE)  //匿名權(quán)限
            .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);
        //創(chuàng)建zk客戶端  120.79.18.36:2181
        client = CuratorFrameworkFactory.builder().connectString(resourceConfig.getZookeeperServer()).sessionTimeoutMs(10000)
                .retryPolicy(retryPolicy).namespace("admin").build();
        //啟動(dòng)客戶端
        client.start();
        try {
            addChildWatch("/bgm");
        } catch (Exception e) {
            e.printStackTrace();
        }
    } 

監(jiān)聽zk-server的節(jié)點(diǎn)，當(dāng)短視頻后臺(tái)管理系統(tǒng)上傳或者刪除某個(gè)BGM的時(shí)候，小程序后臺(tái)服務(wù)器通過Zookeeper監(jiān)聽自動(dòng)下載背景音樂

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("監(jiān)聽到事件CHILD_ADDED");
                    //1. 從數(shù)據(jù)庫查詢bgm對(duì)象，獲取路徑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所在的相對(duì)路徑
//                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