package com.cloud.device;
|
|
import ch.qos.logback.core.net.SyslogOutputStream;
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.common.utils.RestTemplateUtil;
|
import com.cloud.device.model.Cluster;
|
import com.cloud.device.model.Database;
|
import com.cloud.device.model.Node;
|
import com.cloud.device.service.ClusterService;
|
import com.cloud.device.vo.ClusterNodeVo;
|
import com.cloud.device.vo.NodeVo;
|
import org.junit.Test;
|
import org.junit.runner.RunWith;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.test.context.SpringBootTest;
|
import org.springframework.http.MediaType;
|
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
|
import org.springframework.test.context.junit4.SpringRunner;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.locks.Lock;
|
import java.util.concurrent.locks.ReentrantLock;
|
|
//@SpringBootTest
|
//@RunWith(SpringRunner.class)
|
//public class Test11 {
|
|
// @Autowired
|
// ClusterService clusterService;
|
// @Test
|
// public void test() {
|
/*String url ="http://192.168.1.171:11111/searchNode";
|
|
JSONObject a = new JSONObject();
|
|
String all= RestTemplateUtil.post(url, a, MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
|
List<Node> list = JSONObject.parseArray(all, Node.class);
|
//TokenInfo t = RestTemplateUtil.post(httpUrl,jsonObject ,MediaType.APPLICATION_FORM_URLENCODED ,TokenInfo.class , false);
|
|
String port =url.substring(url.indexOf(":")+1, url.lastIndexOf("/"));
|
|
list.stream().forEach(e ->
|
e.setLocalDates(findByNode(getUrl(e.getNodeId(),getPort(url))))
|
);
|
|
|
List<Database> syncDatabase = getSyncDatabase(url);
|
|
System.out.println("syncDatabase :" + syncDatabase.toString());
|
|
System.out.println(list.toString());*/
|
// }
|
|
/*public List<Database> findByNode(String url){
|
JSONObject a = new JSONObject();
|
String all= RestTemplateUtil.post(url, a, MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
List<Database> list = JSONObject.parseArray(all, Database.class);
|
|
System.out.println("NODE-----------" + url);
|
System.out.println(list);
|
return list;
|
}
|
|
public String getUrl(String nodeId,String port){
|
return "http://"+nodeId.substring(nodeId.indexOf("@")+1,nodeId.length())+":"+port+"/findLocalDatabase";
|
}
|
|
public String getPort(String url){
|
return url.substring(url.lastIndexOf(":")+1, url.lastIndexOf("/"));
|
}
|
|
|
public List<Database> getSyncDatabase(String url){
|
String all= RestTemplateUtil.post(url, new JSONObject(), MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
List<Database> list = JSONObject.parseArray(all, Database.class);
|
return list;
|
}
|
|
|
@Test
|
public void test2222(){
|
Map<String,Object> a = new HashMap<>();
|
List<Cluster> list = clusterService.findAllNode(a);
|
|
list.stream().forEach(e-> System.out.println(e.toString()));
|
}
|
|
|
@Test
|
public void testFindNodesByIds(){
|
String ids = "ea5f694d-4c9d-58ca-98a4-0ed033a1398d";
|
|
|
List<ClusterNodeVo> list = clusterService.findNodesByIds(ids);
|
|
list.stream().forEach(e-> System.out.println(e.toString()));
|
|
}*/
|
|
//}
|
