parent
48d24bc6ac
commit
3dd78b125b
@ -0,0 +1,191 @@
|
||||
package com.soa.microservice.core;
|
||||
|
||||
import com.soa.microservice.registry.InMemoryServiceRegistry;
|
||||
import com.soa.microservice.transaction.TwoPhaseCommitTransactionManager;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
/**
|
||||
* 微服务治理平台演示类
|
||||
* 展示服务注册发现、负载均衡、熔断降级和分布式事务功能
|
||||
*/
|
||||
public class MicroserviceDemo {
|
||||
private static final Logger logger = LoggerFactory.getLogger(MicroserviceDemo.class);
|
||||
|
||||
public static void main(String[] args) throws Exception {
|
||||
logger.info("Starting microservice governance platform demo...");
|
||||
|
||||
// 1. 初始化服务注册中心
|
||||
InMemoryServiceRegistry registry = new InMemoryServiceRegistry();
|
||||
logger.info("Service registry initialized");
|
||||
|
||||
// 2. 初始化服务客户端
|
||||
DefaultServiceClient serviceClient = new DefaultServiceClient(registry);
|
||||
logger.info("Service client initialized");
|
||||
|
||||
// 3. 注册测试服务实例
|
||||
registerTestServices(registry);
|
||||
|
||||
// 4. 测试服务发现和负载均衡
|
||||
testServiceDiscoveryAndLoadBalancing(serviceClient);
|
||||
|
||||
// 5. 测试熔断功能
|
||||
testCircuitBreaker(serviceClient);
|
||||
|
||||
// 6. 测试分布式事务
|
||||
testDistributedTransaction();
|
||||
|
||||
logger.info("Demo completed successfully!");
|
||||
}
|
||||
|
||||
/**
|
||||
* 注册测试服务
|
||||
*/
|
||||
private static void registerTestServices(InMemoryServiceRegistry registry) {
|
||||
// 注册用户服务的3个实例
|
||||
for (int i = 1; i <= 3; i++) {
|
||||
ServiceInstance userService = new ServiceInstance(
|
||||
"user-service-" + i,
|
||||
"user-service",
|
||||
"localhost",
|
||||
8000 + i
|
||||
);
|
||||
userService.addMetadata("version", "v1");
|
||||
registry.register(userService);
|
||||
}
|
||||
|
||||
// 注册订单服务的2个实例
|
||||
for (int i = 1; i <= 2; i++) {
|
||||
ServiceInstance orderService = new ServiceInstance(
|
||||
"order-service-" + i,
|
||||
"order-service",
|
||||
"localhost",
|
||||
9000 + i
|
||||
);
|
||||
orderService.addMetadata("version", "v1");
|
||||
registry.register(orderService);
|
||||
}
|
||||
|
||||
logger.info("Registered test services: {}", registry.getServices());
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试服务发现和负载均衡
|
||||
*/
|
||||
private static void testServiceDiscoveryAndLoadBalancing(DefaultServiceClient client) throws Exception {
|
||||
logger.info("\n--- Testing Service Discovery and Load Balancing ---");
|
||||
|
||||
// 测试轮询负载均衡
|
||||
logger.info("Testing round-robin load balancing...");
|
||||
Map<String, AtomicInteger> instanceCount = new HashMap<>();
|
||||
|
||||
for (int i = 0; i < 10; i++) {
|
||||
Object result = client.invoke("user-service", "getUserInfo", i);
|
||||
logger.info("Invocation result: {}", result);
|
||||
|
||||
// 统计每个实例的调用次数
|
||||
String instanceInfo = result.toString();
|
||||
String instanceId = instanceInfo.split("on ")[1];
|
||||
instanceCount.computeIfAbsent(instanceId, k -> new AtomicInteger(0)).incrementAndGet();
|
||||
}
|
||||
|
||||
// 打印负载均衡结果
|
||||
logger.info("Load balancing distribution:");
|
||||
for (Map.Entry<String, AtomicInteger> entry : instanceCount.entrySet()) {
|
||||
logger.info("Instance {}: {} calls", entry.getKey(), entry.getValue().get());
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试熔断功能
|
||||
*/
|
||||
private static void testCircuitBreaker(DefaultServiceClient client) throws Exception {
|
||||
logger.info("\n--- Testing Circuit Breaker ---");
|
||||
|
||||
// 创建一个会失败的服务客户端
|
||||
ServiceClient failingClient = new DefaultServiceClient(new InMemoryServiceRegistry()) {
|
||||
@Override
|
||||
public Object invoke(String serviceName, String method, Object... params) throws Exception {
|
||||
// 模拟服务调用失败
|
||||
throw new Exception("Service unavailable");
|
||||
}
|
||||
};
|
||||
|
||||
// 测试熔断触发
|
||||
int failureCount = 0;
|
||||
for (int i = 0; i < 10; i++) {
|
||||
try {
|
||||
failingClient.invoke("test-service", "testMethod");
|
||||
} catch (Exception e) {
|
||||
failureCount++;
|
||||
logger.info("Invocation {} failed: {}", i+1, e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
logger.info("Total failures: {}", failureCount);
|
||||
logger.info("Circuit breaker should be open after consecutive failures");
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试分布式事务
|
||||
*/
|
||||
private static void testDistributedTransaction() throws Exception {
|
||||
logger.info("\n--- Testing Distributed Transaction ---");
|
||||
|
||||
TwoPhaseCommitTransactionManager transactionManager = new TwoPhaseCommitTransactionManager();
|
||||
|
||||
// 创建测试事务参与者
|
||||
TestTransactionParticipant participant1 = new TestTransactionParticipant("participant-1");
|
||||
TestTransactionParticipant participant2 = new TestTransactionParticipant("participant-2");
|
||||
|
||||
// 开始事务
|
||||
String txId = transactionManager.beginTransaction();
|
||||
logger.info("Transaction {} began", txId);
|
||||
|
||||
// 添加参与者
|
||||
transactionManager.addParticipant(txId, participant1);
|
||||
transactionManager.addParticipant(txId, participant2);
|
||||
|
||||
// 提交事务
|
||||
boolean committed = transactionManager.commitTransaction(txId);
|
||||
logger.info("Transaction {} committed: {}", txId, committed);
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试用的事务参与者
|
||||
*/
|
||||
static class TestTransactionParticipant implements TransactionParticipant {
|
||||
private final String participantId;
|
||||
private static final Logger logger = LoggerFactory.getLogger(TestTransactionParticipant.class);
|
||||
|
||||
public TestTransactionParticipant(String participantId) {
|
||||
this.participantId = participantId;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean prepare(String transactionId) {
|
||||
logger.info("Participant {} preparing for transaction {}", participantId, transactionId);
|
||||
return true; // 模拟准备成功
|
||||
}
|
||||
|
||||
@Override
|
||||
public void commit(String transactionId) {
|
||||
logger.info("Participant {} committing transaction {}", participantId, transactionId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void rollback(String transactionId) {
|
||||
logger.info("Participant {} rolling back transaction {}", participantId, transactionId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getParticipantId() {
|
||||
return participantId;
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue