2. 程式人生 > >【java小程式】zookeeper監聽並自動更新

【java小程式】zookeeper監聽並自動更新

阿新 • • 發佈：2019-01-07

開發需求背景，在開發小程式視訊時(springboot後端），需要一個後臺管理系統（ssm後端），並且這兩個系統是部署在不同的伺服器上，當管理人員通過短視訊後臺管理背景音樂的上傳和刪除，需要小程式端的伺服器能通過監聽能自動下載背景音樂。這裡我們就通過zookeeper中介軟體，springboot監聽並且下載。
###內容目錄

文章目錄

什麼是Zookeeper？

1、中介軟體，提供協調服務。
2、作用於分散式系統，發揮其優勢，可以為大資料服務。
3、支援java，提供java和c語言的客戶端api。

什麼是分散式系統？

1、很多臺計算機組成一個整體，一個整體一致對外並且處理同一請求。
2、內部的每臺計算機都可以相互通訊。
3、客戶端到服務端的一次請求到響應結束會經歷多臺計算機。

windows10 單機安裝zookeeper

1、在安裝zookeeper之前，需要先安裝JDK，並進行環境配置。
2、下載zookeeper解壓。在bin目錄下， zkServer.cmd是zookeeper的啟動指令碼。

在你執行啟動指令碼之前，還有幾個基本的配置項需要配置一下，Zookeeper 的配置檔案在 conf 目錄下，這個目錄下有 zoo_sample.cfg 和 log4j.properties，你需要做的就是將 zoo_sample.cfg 改名為 zoo.cfg，因為 Zookeeper 在啟動時會找這個檔案作為預設配置檔案。

常用的zk java客戶端

1、zk原生API

缺點：超時重連，不支援自動，需要手動操作。Watch註冊一次後會失效，不支援遞迴的建立節點。

2、zkClient （很久沒有更新）

3、apache curator

apche的開源專案，解決watcher的註冊一次就失效的問題，api更加簡單方便。

支援程式碼塊，並解決常見的程式碼塊換行不正確,特別是iPone、iPad上不能滾動的問題;
解決把內容貼上到公眾號時，圖片、或樣式丟失的問題;

Curator 建立zk客戶端的步驟

1、建立重試策略 - retryPolicy
2、建立客戶端 - client
3、 初始化客戶端，加入到spring容器，專案啟動載入的時候執行。

zookeeepr程式碼實現

1、zookeeper需要匯入的pom依賴

	<!-- 引入zookeeper -->
		<dependency>
			<groupId>org.apache.curator</groupId>
			<artifactId>curator-framework</artifactId>
			<version>4.0.0</version>
		</dependency>
		<dependency>
			<groupId>org.apache.zookeeper</groupId>
			<artifactId>zookeeper</artifactId>
			<version>3.4.11</version>
		</dependency>
		<dependency>
			<groupId>org.apache.curator</groupId>
			<artifactId>curator-recipes</artifactId>
			<version>4.0.0</version>
		</dependency>

2、後臺管理ssm進行zookeeper的spring容器的配置

<description>zookeeper 放入spring容器，專案啟動載入的時候就建立和zk的連線</description>
	
	<!-- 建立重連策略 -->
	<bean id="retryPolicy" class="org.apache.curator.retry.ExponentialBackoffRetry">
		<!-- 每次重試連線的等待時間 -->
		<constructor-arg index="0" value="1000"></constructor-arg>
		<!-- 設定的重連的次數 -->
		<constructor-arg index="1" value="5"></constructor-arg>
	</bean>
	
	<!-- 建立zookeeper客戶端 -->
	<bean id="client" class="org.apache.curator.framework.CuratorFrameworkFactory" 
		factory-method="newClient" init-method="start">
		<constructor-arg index="0" value="192.168.1.210:2181"></constructor-arg>
		<constructor-arg index="1" value="10000"></constructor-arg>
		<constructor-arg index="2" value="10000"></constructor-arg>
		<constructor-arg index="3" ref="retryPolicy"></constructor-arg>
	</bean>
	
	<!-- 客戶端配置 -->
	<!-- init-method="init" 不使用zk的話，僅僅只是測試,為了方便可以把這個方法暫時拿掉 -->
	<bean id="ZKCurator" class="com.imooc.web.util.ZKCurator" init-method="init">
		<constructor-arg index="0" ref="client"></constructor-arg>
	</bean>

3、後臺管理zookeeper的客戶端工具類

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() {
		//使用admin名稱空間，方便zookeeper節點目錄區分。
		client = client.usingNamespace("admin");
		
		try {
			// 判斷在admin名稱空間下是否有bgm節點  /admin/bmg
			if (client.checkExists().forPath("/bgm") == null) {
				/**
				 * 對於zk來講，有兩種型別的節點:
				 * 持久節點: 當你建立一個節點的時候，這個節點就永遠存在，除非你手動刪除
				 * 臨時節點: 你建立一個節點之後，會話斷開，會自動刪除，當然也可以手動刪除
				 */
				client.create().creatingParentsIfNeeded()
					.withMode(CreateMode.PERSISTENT)		// 節點型別：持久節點
					.withACL(Ids.OPEN_ACL_UNSAFE)			// acl：匿名許可權
					.forPath("/bgm");
				log.info("zookeeper初始化成功...");
				
				log.info("zookeeper伺服器狀態：{}", client.isStarted());
			}
		} catch (Exception e) {
			log.error("zookeeper客戶端連線、初始化錯誤...");
			e.printStackTrace();
		}
	}
	
	/**
	 * @Description: 增加或者刪除bgm，向zk-server建立子節點，供小程式後端監聽
	 *  forPath的兩個引數：第一個：表示建立的目錄節點，第二個表示該節點下要儲存的資料。
	 */
	public void sendBgmOperator(String bgmId, String operObj) {
		try {
			
			client.create().creatingParentsIfNeeded()
				.withMode(CreateMode.PERSISTENT)		// 節點型別：持久節點
				.withACL(Ids.OPEN_ACL_UNSAFE)			// acl：匿名許可權
				.forPath("/bgm/" + bgmId, operObj.getBytes());  //     bgm/bgmId 子節點
		} catch (Exception e) { 
			e.printStackTrace();
		}
	}
	
}

3、後臺管理–列舉類

package com.imooc.enums;

public enum BGMOperatorTypeEnum {
	
	ADD("1", "新增bgm"),				
	DELETE("2", "刪除bgm");		
	
	public final String type;
	public final String value;
	
	BGMOperatorTypeEnum(String type, String value){
		this.type = type;
		this.value = value;
	}
	
	public String getUserType() {
		return type;
	}  
	
	public String getValue() {
		return value;
	} 
	
	public static String getValueByKey(String key) {
		for (BGMOperatorTypeEnum type : BGMOperatorTypeEnum.values()) {
			if (type.getUserType().equals(key)) {
				return type.value;
			}
		}
		return null;
	}
	
}

4、後臺管理對bgm進行新增和刪除時候，將資料儲存在zookeeper節點上。

@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());
		
		zkCurator.sendBgmOperator(bgmId, JsonUtils.objectToJson(map));
	}
	

@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());
		
		zkCurator.sendBgmOperator(id, JsonUtils.objectToJson(map));
		
	}

5、小程式端後臺監聽，並進行刪除或新增操作。

package com.imooc;

import java.io.File;
import java.net.URL;
import java.net.URLEncoder;
import java.util.Map;

import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.PathChildrenCache;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.imooc.cofig.ResourceConfig;
import com.imooc.enums.BGMOperatorTypeEnum;
import com.imooc.utils.JsonUtils;

@Component
public class ZKCuratorClient {

	// zk客戶端
	private CuratorFramework client = null;	
	final static Logger log = LoggerFactory.getLogger(ZKCuratorClient.class);

//	@Autowired
//	private BgmService bgmService;
	
//	public static final String ZOOKEEPER_SERVER = "192.168.1.210:2181";
	
	@Autowired
	private ResourceConfig resourceConfig;
	
	public void init() {
		
		if (client != null) {
			return;
		}
		
		// 重試策略
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		// 建立zk客戶端
		client = CuratorFrameworkFactory.builder().connectString(resourceConfig.getZookeeperServer())
				.sessionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("admin").build();
		// 啟動客戶端
		client.start();
		
		try {
			//測試 從這個（admin/bgm/18052674D26HH3X4）節點下獲取資料
//		    String testNodeData = new String(client.getData().forPath("/bgm/18052674D26HH3X4"));
//			log.info("測試的節點資料為： {}", testNodeData);
			addChildWatch("/bgm");  //監聽bgm下的子節點
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}
	//事件監聽
	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<String, String> 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 bgm = bgmService.queryBgmById(bgmId);
//					if (bgm == null) {
//						return;
//					}
					
					// 1.1 bgm所在的相對路徑
//					String songPath = bgm.getPath();
					
					// 2. 定義儲存到本地的bgm路徑
//					String filePath = "C:\\imooc_videos_dev" + songPath;
					String filePath = resourceConfig.getFileSpace() + songPath;
					
					// 3. 定義下載的路徑（播放url）
					String arrPath[] = songPath.split("\\\\");
					String finalPath = "";
					// 3.1 處理url的斜槓以及編碼
					for(int i = 0; i < arrPath.length ; i ++) {
						if (StringUtils.isNotBlank(arrPath[i])) {
							finalPath += "/";
							finalPath += URLEncoder.encode(arrPath[i], "UTF-8") ;
						}
					}
//					String bgmUrl = "http://192.168.1.2:8080/mvc" + finalPath;
					String bgmUrl = resourceConfig.getBgmServer() + finalPath;
					
					if (operatorType.equals(BGMOperatorTypeEnum.ADD.type)) {
						// 下載bgm到spingboot伺服器
						URL url = new URL(bgmUrl);
						File file = new File(filePath);
						FileUtils.copyURLToFile(url, file);
						client.delete().forPath(path);
					} else if (operatorType.equals(BGMOperatorTypeEnum.DELETE.type)) {
						File file = new File(filePath);
						FileUtils.forceDelete(file);
						client.delete().forPath(path);
					}
				}
			}
		});
	}
	
}

6、小程式後端，springboot對ZKCuratorClient進行bean的配置。

@Configuration
public class WebMvcConfig extends WebMvcConfigurerAdapter {

    @Bean(initMethod="init")
	public ZKCuratorClient zkCuratorClient() {
		return new ZKCuratorClient();
	}
}

7、小程式後端，springboot進行自定義資原始檔配置。

@ConfigurationProperties(prefix=“com.imooc”)中的com.imooc是對resource.properties檔案中com.imooc.zookeeperServer的com.imooc的統一定義。

@Configuration //定義配置檔案
@ConfigurationProperties(prefix="com.imooc") // 定義字首。
@PropertySource("classpath:resource.properties")  //指定資原始檔目錄
public class ResourceConfig {

	private String zookeeperServer;
	private String bgmServer;
	private String fileSpace;

	public String getZookeeperServer() {
		return zookeeperServer;
	}
	public void setZookeeperServer(String zookeeperServer) {
		this.zookeeperServer = zookeeperServer;
	}
	public String getBgmServer() {
		return bgmServer;
	}
	public void setBgmServer(String bgmServer) {
		this.bgmServer = bgmServer;
	}
	public String getFileSpace() {
		return fileSpace;
	}
	public void setFileSpace(String fileSpace) {
		this.fileSpace = fileSpace;
	}
}

資原始檔：resource.properties

com.imooc.zookeeperServer=192.168.1.210:2181
com.imooc.bgmServer=http://192.168.1.2:8080/mvc
com.imooc.fileSpace=C:\\imooc_videos_dev

相關推薦

【java小程式】zookeeper監聽並自動更新

開發需求背景，在開發小程式視訊時(springboot後端），需要一個後臺管理系統（ssm後端），並且這兩個系統是部署在不同的伺服器上，當管理人員通過短視訊後臺管理背景音樂的上傳和刪除，需要小程式端的伺服器能通過監聽能自動下載背景音樂。這裡我們就通過zookeeper中介軟體，springb

【java小程式】分頁顯示視訊列表

###內容目錄（由[TOC]自動生成） 文章目錄 分頁查詢的後端程式碼 小程式端程式碼 index.wxml index.wxss index.js

【java小程式】利用ffmpeg對視訊進行截圖操作

ffmpeg程式對視訊進行的截圖的命令如下語法如下： ffmpeg.exe -ss 00:00:01 -i spring.mp4 -vframes 1 bb.jpg 00:00:01 擷取視訊圖片的時間。 spring.map4 需要擷取的視訊名稱。 1

【java小程式】使用ffmpeg進行視訊與背景音樂的整合

文章目錄 ffmpeg簡介 利用ffmpeg進行程式碼開發 ffmpeg處理工具類的呼叫 在小視訊開發中，上傳視訊時需要選擇背景音樂進行視訊與背景音樂的整合。這裡我們就藉助ffmpeg這個工具來完

【java小程式】小程式視訊上傳檔案的前後端程式碼

文章目錄 小程式端程式碼 1、上傳視訊選中事件 2、背景音樂的頁面載入 上傳檔案的後端程式碼 上傳小視訊功能，我們是通過我的主頁點選上傳按鈕進行上傳，選中視訊後會

【java小程式】背景頁面到小程式的展示

文章目錄 背景音樂查詢後端程式碼 1、BgmService的程式碼 2、背景音樂service介面的實現類BgmServiceImpl 3、背景音樂的Controller類BgmController

【java小程式】上傳頭像的功能實現。

上傳頭像小程式端的頁面程式碼和前面的登出程式碼一樣，可以去【java小程式實戰】小程式登出功能實現檢視 文章目錄 小程式端的js實現（mine.js) java後臺程式碼： 1、UserService介面

【java小程式實戰】swagger2構建restful介面測試

在開發過程中使用swagger2介面進行測試有以下幾個好處： 1、可以生成文件形式的api並提供個不同的安卓、IOS、前端開發團隊。 2、方便後端開發人員進行功能的自測，也方便領導查閱任務量。 3、無需過多冗餘的word文件。 下面直接開始配置： 一、pom依賴包 <

【java小程式實戰】小程式短視訊後臺專案之MD5加密工具類

對字串進行簡單加密，直接上程式碼： package com.imooc.utils; import org.apache.commons.codec.binary.Base64; import java.security.MessageDigest; import java.secu

【java小程式實戰】小程式短視訊後端專案之返回結果包裝工具類

在開發過程中，我們在controller 中把需要返回的結果封裝成一個IMoocJSONResult類，再把資料轉換為json格式，傳送到前端頁面。 IMoocJSONResult類程式碼： package com.imooc.utils; /** * @Description: 自

【java小程式實戰】小程式短視訊專案之逆向工程程式碼生成

在子工程中mybatis-generatorconfig中專案結構如下 1、 pom依賴 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.

【java小程式實戰】小程式短視訊專案之springBoot後臺搭建

在以往的專案中我們使用的是單結構工程 在小程式這個專案中我們會使用maven搭建分層的聚合工程 一個imooc-video工程下，有很多子工程common、mapper、api、pojo等子工程。 一般分為common層其他工程都可以呼叫，pojo層資料庫的實體類，mapper層資料庫的對

【java小程式實戰】小程式短視訊專案之資料庫建表

 最近自己在練習一個java小程式短視訊的專案，希望每天通過文章的形式把開發內容和學習到的東西記錄下來。  一個專案的開始就是資料庫建表，首先我們要有一個使用者表，記錄使用者的一些資訊   使用者表-user 欄位

【oracle常見錯誤】oracle監聽程式配置/“ORA-12541: TNS: 無監聽程式”

一、問題描述 在用PL/SQL Developer連線Oracle 11g時報錯“ORA-12541: TNS: 無監聽程式”，如下圖所示。可以按照如下的步驟進行解決。 二、解決方案 1、監聽程式配置  從開始選單中開啟“Oracle Net Configu

【java小程式實戰】小程式登出功能實現

小程式實戰中，如何實現程式的登出功能呢？後端程式碼只要刪除使用者的redi快取即可。小程式端在成功返回訊息後，進行登陸頁面的跳轉。 文章目錄 小程式的mine.wxml程式碼 mine.wxss程式碼 登出事件

【java小程式實戰】redis快取session的實現

###內容目錄（由[TOC]自動生成） 文章目錄 一、有狀態session 二、無狀態session 三、redis-session 四、redis應用 1、pom依賴 2、ap

【java小程式實戰】小程式註冊功能的前後端程式碼

文章目錄 小程式註冊程式碼 1 、小程式和後端互動，對app.js進行全域性配置 2、小程式的wxml程式碼 3、小程式的wxss程式碼 4、小程式js程式碼

【Android學習日記】(七) 監聽簡訊接收例項

/* 自定義繼承自BroadcastReceiver類,監聽系統服務廣播的資訊 */ public class EX06_01_SMSreceiver extends BroadcastReceiver  {     /*宣告靜態字串,並使用android.provider

【微信小程式】封裝網路請求並在wxml呼叫

正文： // url:網路請求的url method:網路請求方式 data:請求引數 message:提示資訊 success:成功的回撥函式 fail：失敗的回撥 //pages/utils/

【Java小專案】一個Socket連續傳輸多個檔案

      想給前短時間做的那個山寨QQ加一個傳輸檔案的功能，因為那個山寨QQ每個客戶端和伺服器端就一個Socket連線用ObjectOutputStream進行通訊，現在要加一個DataOutputStream來傳輸檔案，所以先了寫這個試驗下。      思路：