From e48db45f137a00da35fd92d07c563a2fdae3b757 Mon Sep 17 00:00:00 2001 From: wangchengcheng Date: Wed, 12 May 2021 11:58:11 +0800 Subject: 5.12 --- src/test/java/TestSendObject.java | 41 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 src/test/java/TestSendObject.java (limited to 'src/test/java/TestSendObject.java') diff --git a/src/test/java/TestSendObject.java b/src/test/java/TestSendObject.java new file mode 100644 index 0000000..f893e6f --- /dev/null +++ b/src/test/java/TestSendObject.java @@ -0,0 +1,41 @@ +import cn.ac.iie.storm.utils.config.StreamAggregateConfig; + +import java.io.IOException; + +import static cn.ac.iie.storm.utils.hos.HosService.httpPostObject; +import static cn.ac.iie.storm.utils.hos.Send2S3.SendObject2S3; +import static cn.ac.iie.storm.utils.http.HttpAsncClient.getConnAnsyHttpPost; + +public class TestSendObject { + public static void main(String[] args) throws IOException { + String s = "http://10.111.143.200:9098/hos/fw_http_plug/http_response_body_36.189.23123123.36.21827-183.201.125.13.80_88136053457070.txt"; + String[] split = s.split("/"); + String BucketName = split[split.length-2]; + String filename = split[split.length-1]; +// byte[] bytes = httpPostObject("http://10.111.143.239:9098/hos/", BucketName, filename); +// getConnAnsyHttpPost("http://10.111.151.218:8888/t-http-rzzb/20210312.txt?method=put",bytes); + + + System.out.println("---------------------------------------------------"); + + + byte[] bytes =null; + + if (bytes!=null){ + System.out.println(bytes); + } + String s3Url = SendObject2S3(s,"t-http-jczb"); + System.out.println(s3Url); + + String s1 = "http_response_body_36.189.23123123.36.21827-183.201.125.13.80_88136053457070.txt"; + String s2 ="http://10.111.151.245:8888/t-http-jczb/"; + System.out.println(s1.length()); + System.out.println(s2.length()); + +// String s = "63.23123e+07"; +// Float a = Float.valueOf(s); +// System.out.println(a); + + } + +} -- cgit v1.2.3