message_bus / message_bus_sdk · 提交

转到一个项目

作者 王勇
提交 646fa895bad024a2fdda664e51a638874e9b3338 1 个父辈 d8169bcc

sdk，初步完善，备份

内嵌 并排对比
正在显示 17 个修改的文件 包含 34 行增加 和 23 行删除
URL_CONSUMER_ONE=http://192.168.1.33:9032/bus/rabbit/consumer_one
URL_CONSUMER_MORE=http://192.168.1.33:9032/bus/rabbit/consumer_more
\ No newline at end of file
... ... @@ -27,6 +27,7 @@
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
... ... @@ -38,12 +39,6 @@
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-log4j</artifactId>
<version>1.3.8.RELEASE</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>4.8.1</version>
... ... @@ -70,6 +65,7 @@
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>
... ...
... ... @@ -14,7 +14,7 @@ public class MyTestMethods {
private static final String url_product_new = "http://192.168.1.53:12343/message-bus-send/bus/rabbit/product_new";
private static final String url_product_old = "http://192.168.1.53:12343/message-bus-send/bus/rabbit/product_old";
private static final String url_consumer_one = "http://192.168.1.53:12343/message-bus-receive/bus/rabbit/consumer_one";
private static final String url_consumer_more = "http://192.168.1.53:12343/message-bus-receive/bus/rabbit/consumer_more2";
private static final String url_consumer_more = "http://192.168.1.53:12343/message-bus-receive/bus/rabbit/consumer_more";
private static final String token =
"Bearer eyJhbGciOiJSUzI1NiJ9.eyJzdWIiOiJ6aWNoZW5nIiwiZXhwIjoxNTk5NDk3MzU1fQ.YI69vs8pV99v7hnt6xGX5c4wvMPBj6tgsjiI4JJbW2Irj-sUW1stskQ25-G5cDRI-qoZFQTlvRvGVFR97arFD9gwAIB8Gfz4Sog-QC1wLDS3xStvygsCDabQmaF8JaE_zWbtJ7Izs7Jd45VOiI4CS_uZY5dsgODB5IqW1hwj-JY";
... ... @@ -27,7 +27,9 @@ public class MyTestMethods {
public BusResult product_old()
{
long start = System.currentTimeMillis();
String content = "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <MSG> <META> <SNDR>zicheng</SNDR> \t\t<RCVR></RCVR> \t\t<DDTM>20200902164413</DDTM> \t\t<TYPE>E_zicheng</TYPE> \t\t<STYP>R_zicheng</STYP> \t\t<SEQN>本性难移</SEQN> \t\t<TOKN>江山易老</TOKN> \t\t<VSHT>V_zicheng</VSHT> \t\t<SERV>S_zicheng</SERV> \t</META> \t<BODY>中元节，即是鬼节</BODY> </MSG>";
String content = "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <MSG> <META> <SNDR>zicheng</SNDR> \t\t<RCVR></RCVR> " +
"\t\t<DDTM>20200902164413</DDTM> \t\t<TYPE>E_zicheng</TYPE> \t\t<STYP>R_zicheng</STYP> \t\t<SEQN>本性难移</SEQN> \t\t<TOKN>江山易老</TOKN> " +
"\t\t<VSHT>V_zicheng</VSHT> \t\t<SERV>S_zicheng</SERV> \t</META> \t<BODY>你好啊，我的老BoBy</BODY> </MSG>";
MessageRequest messageRequest = new MessageRequest();
BusResult busResult = messageRequest.sendMessage(url_product_old, token, content);
... ... @@ -40,8 +42,8 @@ public class MyTestMethods {
{
long start = System.currentTimeMillis();
MessageRequest messageRequest = new MessageRequest();
BusResult busResult = messageRequest.sendMessage(url_product_new, "S_zicheng", "V_zicheng", "E_zicheng", "R_zicheng", "江山易老，本性难移", "zicheng"
, "20200907164413", token, "序列号");
BusResult busResult = messageRequest.sendMessage(url_product_new, "S_zicheng", "V_zicheng", "E_zicheng", "R_zicheng", "待到重阳日，还来就菊花", "zicheng"
, "20200909164413", token, "序列号");
long end = System.currentTimeMillis();
System.out.println("发送一条参数消息，耗时：" + (end - start) + "毫秒");
return busResult;
... ... @@ -59,7 +61,7 @@ public class MyTestMethods {
public BusResult consumerMore()
{
int num = 100;
int num = 10000;
long start = System.currentTimeMillis();
MessageRequest messageRequest = new MessageRequest();
BusResult busResult = messageRequest.getMessageMore(url_consumer_more, token, "zicheng", "S_zicheng",
... ...
... ... @@ -19,16 +19,15 @@ import java.util.concurrent.locks.ReentrantLock;
public class Test2 {
public static void main(String[] args) throws IOException
{
// 1031 15:45:58 15:48:57
Test2 t2 = new Test2();
t2.moreThread();
}
void moreThread()
{
Tickets thread = new Tickets();
long start = System.currentTimeMillis();
Tickets thread = new Tickets();
ExecutorService executorService = new ThreadPoolExecutor(
32, 64,
0L,
... ... @@ -36,20 +35,29 @@ public class Test2 {
new LinkedBlockingQueue<>(10),
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.AbortPolicy());
for (int i = 0; i < 32; i++) {
for (int i = 0; i < 20; i++) {
executorService.submit(thread);
}
executorService.shutdown();
while (!executorService.isTerminated()) {
}
long end = System.currentTimeMillis();
System.out.println("耗时：" + (end - start));
}
}
class Tickets implements Runnable {
private int ticket = 1000;
private int ticket = 100;
Lock lock = new ReentrantLock();
@Override
public void run()
{
while (true) {
lock.lock();
try {
if (ticket <= 0) {
break;
... ... @@ -58,9 +66,10 @@ class Tickets implements Runnable {
// 发送一条报文消息
BusResult busResult = myTestMethods.product_old();
System.out.println(Thread.currentThread().getName() + "发送了第" + ticket + "条消息");
System.out.println(busResult);
ticket--;
} finally {
lock.unlock();
}
}
}
... ...
... ... @@ -171,6 +171,4 @@ public class MessageRequest {
BusResult result = new BusResult(true, code, msg, dataList);
return result;
}
}
... ...
... ... @@ -88,9 +88,9 @@ public class OkHttpUtils {
private Boolean isBlankUrl(String url)
{
if (StringUtils.isBlank(url)) {
log.info("url is blank-->" + url);
return true;
} else {
log.info("url is blank-->" + url);
return false;
}
}
... ... @@ -108,7 +108,6 @@ public class OkHttpUtils {
}
} catch (Exception e) {
log.error("request execute failure", e);
System.out.println("失败");
}
return re;
}
... ...
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\App.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\utils\GsonUtil.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\request\MessageRequest.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\domain\ExitThreadPoolFactory.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\response\BusResult.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\utils\OkHttpUtils.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\domain\ExitThreadFactory.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\response\ResultJson.java
F:\郑州商友\mywork\消息总线服务\message_bus_sdk\src\main\java\com\sunyo\wlpt\message\bus\sdk\request\BusMessage.java
... ...