`
m635674608
  • 浏览: 4922454 次
  • 性别: Icon_minigender_1
  • 来自: 南京
社区版块
存档分类
最新评论

es 乐观锁问题重现

    博客分类:
  • java
 
阅读更多
package es;

import java.util.UUID;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import jodd.http.HttpRequest;
import jodd.http.HttpResponse;

public class Test {
	static ExecutorService pool = Executors.newFixedThreadPool(16);

	public static void main(String[] args) {

		for (int i = 0; i < 200; i++) {

			pool.submit(new Thread() {
				public void run() {
					for (int i = 0; i < 1; i++) {
						update();
					}

				};
			});

		}
	}
	
	public static void update() {
		HttpRequest httpRequest = HttpRequest
		// .post("http://127.0.0.1:9200/zzm/zzm/1");
		// .put("http://192.168.1.29:9200/zzm/zzm/1");
				.post("http://192.168.1.29:9200/zzm/zzm/1/_update");
		httpRequest.header("Content-Type",
				"application/x-www-form-urlencoded; charset=UTF-8");
		String str = "{\"script\": \"ctx._source.title = 'new conten"+UUID.randomUUID().toString()+"'\"}";
		httpRequest.bodyText(str);
		System.out.println("str=========="+str);
		HttpResponse response = httpRequest.send();
		System.out.println(response.bodyText());

	}

	public static void move() {
		HttpRequest httpRequest = HttpRequest
		// .post("http://127.0.0.1:9200/zzm/zzm/1");
		// .put("http://192.168.1.29:9200/zzm/zzm/1");
				.post("http://192.168.1.29:9200/zzm/zzm/1");
		httpRequest.header("Content-Type",
				"application/x-www-form-urlencoded; charset=UTF-8");
		httpRequest.bodyText("{\"title\":\"zzm" + UUID.randomUUID().toString()
				+ "\"}");
		HttpResponse response = httpRequest.send();
		System.out.println(response.bodyText());

	}

}

 

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics