check

张宗朋
1 parent 08199d34
Showing 2 changed files with 75 additions and 41 deletions
src/main/java/com/cnlive/mz/live/action/CheckAction.java
src/main/java/com/cnlive/mz/live/rest/BaseUtil.java
@@ -50,15 +50,17 @@ public class CheckAction {
 	public Result coseLive(int id,Params params) throws UnsupportedEncodingException{
 		String userId = params.getString("user_id");
 		String streamName = userId+"_"+id;
-		//String streamName = "498122_57";
-		String accesskey = "I3TC8a4xboPUMe5xlp22";
-		//accesskey = java.net.URLEncoder.encode(accesskey,"utf-8");
+		String accesskey = BaseUtil.getAccessKey();
+		accesskey = java.net.URLEncoder.encode(accesskey,"utf-8");
 		String signature = BaseUtil.signature(streamName);
+		String del = "del";
+		String delsignature = BaseUtil.signature(del,streamName);
 		String expire = BaseUtil.getTimestamp();
 		System.out.println(expire+"---expire---");
 		//添加到黑名单。。
 		try {
 			addBlackList(signature,accesskey,expire,streamName);
+			delBlackList(delsignature,accesskey,expire,streamName);
 		} catch (UnsupportedEncodingException e) {
 			e.printStackTrace();
 		}
@@ -75,7 +77,7 @@ public class CheckAction {
 	 * @throws UnsupportedEncodingException
 	 */
 	public String addBlackList(String signature, String accesskey, String expire,String streamName) throws UnsupportedEncodingException {
-		String url = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature="+signature+"&accesskey="+accesskey+"&expire="+expire+"&method=add&app=live&name="+streamName; 
+		String url = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature="+signature+"&accesskey="+accesskey+"&expire="+expire+"&app=live&method=add&name=" + streamName; 
 		System.out.println(url);
 		String jsonArrStr = HttpReq.getRequestWidthResult(url);
 		int status = HttpReq.getRequest(url);
@@ -94,9 +96,10 @@ public class CheckAction {
 	 * @throws UnsupportedEncodingException
 	 */
 	public Object delBlackList(String signature, String accesskey, String expire,String streamName) throws UnsupportedEncodingException {
-		String url = "http://cnlive.uplive.ks-cdn.com/blacklist?signature="+signature+"&accesskey="+accesskey+"&expire="+expire+"&method=del&app=live&name="+streamName; 
+		String url = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature="+signature+"&accesskey="+accesskey+"&expire="+expire+"&app=live&method=del&name=" + streamName;
+		System.out.println("..url.."+url);
 		String jsonArrStr = HttpReq.getRequestWidthResult(url);
-		System.out.println();
+		System.out.println("..jsonArrStr.."+jsonArrStr);
 		/*Map map = JsonUtil.getMapFromJsonObjStr(jsonArrStr);
 		String chatRoomid = (String) map.get("Content-Length");*/
 		return jsonArrStr;
@@ -21,14 +21,16 @@ import javax.crypto.spec.SecretKeySpec;
 import org.apache.commons.codec.binary.Base64;
+import com.cnlive.mz.commons.net.HttpReq;
+
 import sun.misc.BASE64Encoder;
 public class BaseUtil {
 	private static final String ENCODING = "UTF-8";
 	// AccessKey、SecretKey
-	private static final String SECRET_KEY = "7SxVU5lFpqCEQIqxLprQat9BWoyZNKlKfSScTuIk";
-	private static final String ACCESS_KEY = "I3TC8a4xboPUMe5xlp22";
+	private static final String SECRET_KEY = "iqljE4WxQaSMeSd1QP+PPYSpvtK0uWyH0/r6tgi7";
+	private static final String ACCESS_KEY = "I3TC8a4xboN9kSJnUIQh";
 	/*
 	 * 计算MD5+BASE64
@@ -88,7 +90,9 @@ public class BaseUtil {
 		Calendar cal = Calendar.getInstance();
 		cal.setTime(date);
 		long timestamp = cal.getTimeInMillis();
-		return String.valueOf(timestamp).substring(0, 10);
+		System.out.println("------timestamp-----"+timestamp);
+		//return String.valueOf(timestamp).substring(0, 10);
+		return "1483200000";
 	}
 	/**
@@ -101,24 +105,54 @@ public class BaseUtil {
 	public static String signature(String streamName) throws UnsupportedEncodingException {
 		String method = "GET";
-		String Expire = BaseUtil.getTimestamp();
-		String nonce = getUUid();
-		System.out.println(Expire + "---expire----");
-		String Resource = "app=live&method=add&nonce=" + nonce + "&public=0&vdoid=12345&stream=" + streamName;
-		Resource = java.net.URLEncoder.encode(Resource, "utf-8");
-		String stringToSign = method + "\n" + Expire + "\n" + Resource;
+		String expire = BaseUtil.getTimestamp();
+		String app = "live";
+		String methodadd = "add";
+		String name = streamName;
+		app = java.net.URLEncoder.encode(app, "utf-8");
+		methodadd = java.net.URLEncoder.encode(methodadd, "utf-8");
+		name = java.net.URLEncoder.encode(name, "utf-8");
+		System.out.println(expire + "---expire----");
+		String Resource = "app="+app+"&method="+methodadd+"&name=" + name;
+		//Resource = java.net.URLEncoder.encode(Resource, "utf-8");
+		String stringToSign = method + "\n" + expire + "\n" + Resource;
+		System.out.println("--stringToSign--"+stringToSign);
 		// 2.计算 HMAC-SHA1
 		String signature = HMACSha1(stringToSign, SECRET_KEY);
-		System.out.println(signature + "---signature---");
+		System.out.println( "---signature---"+signature );
 		signature = java.net.URLEncoder.encode(signature, "utf-8");
 		return signature;
 	}
+	public static String signature(String methodNname,String streamName) throws UnsupportedEncodingException {
+		String method = "GET";
+		String expire = BaseUtil.getTimestamp();
+		String app = "live";
+		//String methodadd = methodNname;
+		//String name = streamName;
+		app = java.net.URLEncoder.encode(app, "utf-8");
+		methodNname = java.net.URLEncoder.encode(methodNname, "utf-8");
+		streamName = java.net.URLEncoder.encode(streamName, "utf-8");
+		System.out.println(expire + "---expire----");
+		String Resource = "app="+app+"&method="+methodNname+"&name=" + streamName;
+		//Resource = java.net.URLEncoder.encode(Resource, "utf-8");
+		String stringToSign = method + "\n" + expire + "\n" + Resource;
+		System.out.println("--stringToSign--"+stringToSign);
+		// 2.计算 HMAC-SHA1
+		String signature = HMACSha1(stringToSign, SECRET_KEY);
+		System.out.println( "---signature---"+signature );
+		signature = java.net.URLEncoder.encode(signature, "utf-8");
+		return signature;
+	}
+	 
 	public static String getUUid() {
 		String uuid = UUID.randomUUID().toString();
 		uuid = uuid.replaceAll("-", "");
 		return uuid;
 	}
+	public static String getAccessKey() {
+		return ACCESS_KEY;
+	}
 	public static int random_7(int number) {
 		int x = (int) (Math.random() * 10);
@@ -218,26 +252,26 @@ public class BaseUtil {
 			/*
 			 * http header 参数
 			 */
-			String method = "GET";
-			String Expire = "1436976000";
-			String Resource = "nonce=4e1f2519c626cbfbab1520c255830c26&public=0&vdoid=12345";
-			String content_type = "application/json";
-			String path = realUrl.getFile();
-			String date = toGMTString(new Date());
-			// 1.对body做MD5+BASE64加密
-			// String bodyMd5 = MD5Base64(body);
-			String stringToSign = method + "\n" + Expire + "\n" + Resource;
-			// 2.计算 HMAC-SHA1
-			String signature = HMACSha1(stringToSign, ak_secret);
-			// 3.得到 authorization header
-			String authHeader = "Dataplus " + ak_id + ":" + signature;
+//			String method = "GET";
+//			String Expire = "1436976000";
+//			String Resource = "nonce=4e1f2519c626cbfbab1520c255830c26&public=0&vdoid=12345";
+//			String content_type = "application/json";
+//			String path = realUrl.getFile();
+//			String date = toGMTString(new Date());
+//			// 1.对body做MD5+BASE64加密
+//			// String bodyMd5 = MD5Base64(body);
+//			String stringToSign = method + "\n" + Expire + "\n" + Resource;
+//			// 2.计算 HMAC-SHA1
+//			String signature = HMACSha1(stringToSign, ak_secret);
+//			// 3.得到 authorization header
+//			String authHeader = "Dataplus " + ak_id + ":" + signature;
 			// 打开和URL之间的连接
 			URLConnection connection = realUrl.openConnection();
 			// 设置通用的请求属性
-			connection.setRequestProperty("accept", "json");
-			connection.setRequestProperty("content-type", content_type);
-			connection.setRequestProperty("date", date);
-			connection.setRequestProperty("Authorization", authHeader);
+//			connection.setRequestProperty("accept", "json");
+//			connection.setRequestProperty("content-type", content_type);
+//			connection.setRequestProperty("date", date);
+//			connection.setRequestProperty("Authorization", authHeader);
 			// 建立实际的连接
 			connection.connect();
 			// 定义 BufferedReader输入流来读取URL的响应
@@ -283,14 +317,11 @@ public class BaseUtil {
 		System.out.println("..............");
 		// String str = signature();
 		// System.out.println(str);//L2muBoImPzyvwyzfBtGXEu+wRNE=
-		/*
-		 * // 发送GET请求 String ak_id1 = "fWUN8KDtJZJGo0ArQ4qo"; //用户ak String
-		 * ak_secret1 = "UIWPYVeaV8kq2vWImDkLBvWs/pwmTJVF9MCNHDsC"; //
-		 * 用户ak_secret String url1 =
-		 * "http://cnlive.uplive.ks-cdn.com?signature=L2muBoImPzyvwyzfBtGXEu+wRNE=&accesskey=fWUN8KDtJZJGo0ArQ4qo&expire=1436976000&method=add&app=live&name=498122_57";
-		 * System.out.println("response body:" +sendGet(url1, ak_id1,
-		 * ak_secret1));
-		 */
+		
+		 // 发送GET请求
+		 String url1 = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature=iDPKaesXXW3A26CScNyjpNkzxZs%3D&accesskey=I3TC8a4xboPUMe5xlp22&expire=1483200000&app=live&method=add&stream=310166_863";
+		 System.out.println("response body:" +sendGet(url1, ACCESS_KEY, SECRET_KEY));
+		
 		// long d = getTimestamp();
 		// System.out.println(d);
 	}