小程序端检测到zookeeper curator实现增加和删除

第一步：后台上传

package com.lpy.service.impl;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.n3r.idworker.Sid;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.lpy.enums.BGMOperatorTypeEnum;
import com.lpy.mapper.BgmMapper;
import com.lpy.pojo.Bgm;
import com.lpy.pojo.BgmExample;
import com.lpy.service.VideoService;
import com.lpy.web.util.ZookeeperCurator;
import com.lpy.utils.JsonUtils;
import com.lpy.utils.PagedResult;
@Service
public class VideoServiceImpl implements VideoService {
	
	@Autowired
	private BgmMapper bgmMapper;
	
	@Autowired
	private Sid sid;
	
	@Autowired
	private ZookeeperCurator zookeeperCurator;
	

	@Override
	public void addBgm(Bgm bgm) {  //和配置里面有切面行为  事务的配置
		String bgmId=sid.nextShort();
		bgm.setId(bgmId);
		bgmMapper.insert(bgm);
		
		Map<String, String> map=new HashMap<>();
		map.put("operType", BGMOperatorTypeEnum.ADD.type);
		map.put("path", bgm.getPath());
		zookeeperCurator.sendBgmOperator(bgmId,JsonUtils.objectToJson(map));
	}

	@Override
	public PagedResult queryBgmList(Integer page, Integer pageSize) {
		//第一步：开始分页
		PageHelper.startPage(page,pageSize);
		//第二步：查询的条件
		BgmExample example=new BgmExample();
		//第三步：查询数据库的数据list
		List<Bgm> list = bgmMapper.selectByExample(example);
		//第四步：将查询出来的数据进行封装
		PageInfo<Bgm> pageList=new PageInfo<>(list);
		//第五步：将封装好的数据给我们自己写的帮助类里面，并返回
		PagedResult result=new PagedResult();
		result.setTotal(pageList.getPages());//总的页数
		result.setRows(list);//每一列
		result.setPage(page);//当前的页数
		result.setRecords(pageList.getTotal());//总的数量
		return result;
	}

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

}
package com.lpy.service.impl;