SpringCobar分库分表

package com.kelvin.test; import net.sf.json.JSONObject; import org.apache.commons.io.FileUtils; import org.apache.http.HttpEntity; import org.apache.http.HttpHost; import org.apache.http.HttpResponse; import org.apache.http.client.HttpClient; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.util.EntityUtils; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.http.HttpMethod; import org.springframework.http.client.ClientHttpRequest; import org.springframework.http.client.ClientHttpResponse; import org.springframework.http.client.SimpleClientHttpRequestFactory; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.io.*; import java.net.URI; import java.net.URISyntaxException; import java.util.Iterator; import java.util.Random; import java.util.concurrent.TimeUnit; /** * 测试Redis的使用，主要是用的是Spring Data Redis（SDR） */ @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration({ /*"classpath:conf-spring/spring-dao.xml",*/ "classpath:springRedis.xml" }) public class TestJedis { @Autowired private RedisTemplate<String, Object> template; @Test public void sample() { template.opsForZSet().add("test_liukun3", 1,1); template.opsForZSet().add("test_liukun3", 3,2); template.opsForZSet().add("test_liukun3", 2,3); template.opsForZSet().add("test_liukun3", -1,4); Iterator it = template.opsForZSet().range("test_liukun3", 0,5).iterator(); /*template.opsForSet().add("test1", 1); template.opsForSet().add("test1", 2); template.opsForSet().add("test1", 3); template.opsForSet().remove("test1",2); Set set = template.opsForSet().members("test1"); System.out.println(set);*/ /** * opsForValue */ //this.testOpsForValue(); /** * 测试使用redis发送和接送消息 */ //this.testPublishAndReceiveMessage(); /** * 就不需要为redisTemplate再写一个工具类了，已经做了封装 */ /*template.opsForValue().set("test-key1", "test-key1-value"); System.out.println(template.opsForValue().get("test-key1"));*/ } public void testOpsForValue() { /** * 测试使用opsForValue */ RedisObject redisObject = new RedisObject(); redisObject.setObjectType(Integer.class); template.opsForValue().set("redisObject", redisObject, 10, TimeUnit.SECONDS); try { Thread.sleep(15000); } catch (InterruptedException e) { e.printStackTrace(); } redisObject = (RedisObject) template.opsForValue().get("redisObject"); System.out.println(redisObject.getObjectType().toString()); } public void testPublishAndReceiveMessage() { template.convertAndSend("hello-channel2", "我是中文"); } @Test public void testHttpClient() throws Exception{ CloseableHttpClient httpClient = HttpClients.createDefault(); HttpHost proxy = new HttpHost("yourproxy", 8080, "http"); RequestConfig requestConfig = RequestConfig.custom().setProxy(proxy).build(); HttpGet httpGet = new HttpGet(); httpGet.setConfig(requestConfig); // 创建HttpClient对象 HttpClient client = HttpClients.createDefault(); // 创建GET请求（在构造器中传入URL字符串即可） HttpGet get = new HttpGet("http://127.0.0.1/http/demo.do?name=admin&age=40"); // 调用HttpClient对象的execute方法获得响应 HttpResponse response = client.execute(get); // 调用HttpResponse对象的getEntity方法得到响应实体 HttpEntity httpEntity = response.getEntity(); // 使用EntityUtils工具类得到响应的字符串表示 String result = EntityUtils.toString(httpEntity,"utf-8"); System.out.println(result); } @Test public void testGetIP() { String ip = ""; int count = 0; while (true) { try { Random r = new Random(); ip = ""; ip += String.valueOf(r.nextInt(256)) + "."; ip += String.valueOf(r.nextInt(256)) + "."; ip += String.valueOf(r.nextInt(256)) + "."; ip += String.valueOf(r.nextInt(256)); System.out.println(ip); URI uri = new URI("http://ip.taobao.com/service/getIpInfo.php?ip=" + ip); SimpleClientHttpRequestFactory schr = new SimpleClientHttpRequestFactory(); ClientHttpRequest chr = schr.createRequest(uri, HttpMethod.POST); //chr.getBody().write(param.getBytes());//body中设置请求参数 ClientHttpResponse res = chr.execute(); InputStream is = res.getBody(); //获得返回数据,注意这里是个流 InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); String str = ""; String finalStr = ""; while ((str = br.readLine()) != null) { System.out.println(str);//获得页面内容或返回内容 finalStr += str; } JSONObject dataJson = JSONObject.fromObject(finalStr).getJSONObject("data"); String country = dataJson.getString("country"); String area = dataJson.getString("area"); String region = dataJson.getString("region"); String city = dataJson.getString("city"); String isp = dataJson.getString("isp"); FileUtils.writeStringToFile(new File("c:\\ip.txt"), ip + "\t" + country + "\t" + area + "\t" + region + "\t" + city + "\t" + isp + "\r\n", true); count ++; Thread.sleep(r.nextInt(200)); /*if (count % 100 == 0){ Thread.sleep(r.nextInt(1000)); count = 0; }*/ } catch (URISyntaxException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } /** * 该类需要可序列化 */ class RedisObject implements Serializable { private Class objectType; public Class getObjectType() { return objectType; } public void setObjectType(Class objectType) { this.objectType = objectType; } }