Skip to content

Commit

Permalink
将项目模块化，便于扩展
Browse files Browse the repository at this point in the history
  • Loading branch information
anduo committed Apr 26, 2015
1 parent 574fd7e commit ae85a31
Show file tree
Hide file tree
Showing 63 changed files with 599 additions and 495 deletions.
168 changes: 89 additions & 79 deletions pom.xml
View file
Original file line number Diff line number Diff line change
@@ -1,89 +1,99 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>xyz.anduo</groupId>
<artifactId>rpc</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>rpc Maven Webapp</name>
<url>http://maven.apache.org</url>
<dependencies>
<!-- JUnit -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>xyz.anduo</groupId>
<artifactId>rpc</artifactId>
<packaging>pom</packaging>
<version>0.0.1-SNAPSHOT</version>
<modules>
<module>rpc_client</module>
<module>rpc_sieve</module>
<module>rpc_common</module>
<module>rpc_simple</module>
</modules>
<name>rpc</name>

<!-- SLF4J -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.7</version>
</dependency>
<dependencyManagement>
<dependencies>
<!-- JUnit -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>

<!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>3.2.12.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>3.2.12.RELEASE</version>
<scope>test</scope>
</dependency>
<!-- SLF4J -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.7</version>
</dependency>

<!-- Netty -->
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.0.24.Final</version>
</dependency>
<!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>3.2.12.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>3.2.12.RELEASE</version>
<scope>test</scope>
</dependency>

<!-- Protostuff -->
<dependency>
<groupId>com.dyuproject.protostuff</groupId>
<artifactId>protostuff-core</artifactId>
<version>1.0.8</version>
</dependency>
<dependency>
<groupId>com.dyuproject.protostuff</groupId>
<artifactId>protostuff-runtime</artifactId>
<version>1.0.8</version>
</dependency>
<!-- Netty -->
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.0.24.Final</version>
</dependency>

<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>
<!-- Protostuff -->
<dependency>
<groupId>com.dyuproject.protostuff</groupId>
<artifactId>protostuff-core</artifactId>
<version>1.0.8</version>
</dependency>
<dependency>
<groupId>com.dyuproject.protostuff</groupId>
<artifactId>protostuff-runtime</artifactId>
<version>1.0.8</version>
</dependency>

<!-- Apache Commons Collections -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-collections4</artifactId>
<version>4.0</version>
</dependency>
<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>

<!-- Objenesis -->
<dependency>
<groupId>org.objenesis</groupId>
<artifactId>objenesis</artifactId>
<version>2.1</version>
</dependency>
<!-- Apache Commons Collections -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-collections4</artifactId>
<version>4.0</version>
</dependency>

<!-- CGLib -->
<dependency>
<groupId>cglib</groupId>
<artifactId>cglib</artifactId>
<version>3.1</version>
</dependency>
</dependencies>
<build>
<finalName>rpc</finalName>
</build>
<!-- Objenesis -->
<dependency>
<groupId>org.objenesis</groupId>
<artifactId>objenesis</artifactId>
<version>2.1</version>
</dependency>

<!-- CGLib -->
<dependency>
<groupId>cglib</groupId>
<artifactId>cglib</artifactId>
<version>3.1</version>
</dependency>
</dependencies>

</dependencyManagement>

<build>
<finalName>rpc</finalName>
</build>
</project>
71 changes: 71 additions & 0 deletions rpc_client/pom.xml
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,71 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>rpc</artifactId>
<groupId>xyz.anduo</groupId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rpc-client</artifactId>

<dependencies>
<dependency>
<groupId>xyz.anduo</groupId>
<artifactId>rpc-common</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- SLF4J -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</dependency>

<!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
</dependency>
<!-- Netty -->
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
</dependency>

<!-- Protostuff -->
<dependency>
<groupId>com.dyuproject.protostuff</groupId>
<artifactId>protostuff-core</artifactId>
</dependency>
<dependency>
<groupId>com.dyuproject.protostuff</groupId>
<artifactId>protostuff-runtime</artifactId>
</dependency>

<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
</dependency>

<!-- Apache Commons Collections -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-collections4</artifactId>
</dependency>

<!-- Objenesis -->
<dependency>
<groupId>org.objenesis</groupId>
<artifactId>objenesis</artifactId>
</dependency>

<!-- CGLib -->
<dependency>
<groupId>cglib</groupId>
<artifactId>cglib</artifactId>
</dependency>
</dependencies>

</project>
14 changes: 4 additions & 10 deletions .../java/xyz/anduo/rpc/client/RpcClient.java → .../java/xyz/anduo/rpc/client/RpcClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,9 @@

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import xyz.anduo.rpc.common.RpcDecoder;
import xyz.anduo.rpc.common.RpcEncoder;

import xyz.anduo.rpc.server.RpcDecoder;
import xyz.anduo.rpc.server.RpcEncoder;
import xyz.anduo.rpc.server.RpcRequest;
import xyz.anduo.rpc.server.RpcResponse;

public class RpcClient extends SimpleChannelInboundHandler<RpcResponse> {

Expand All @@ -38,7 +36,6 @@ public RpcClient(String host, int port) {
@Override
public void channelRead0(ChannelHandlerContext ctx, RpcResponse response) throws Exception {
this.response = response;

synchronized (obj) {
obj.notifyAll(); // 收到响应，唤醒线程
}
Expand All @@ -57,11 +54,8 @@ public RpcResponse send(RpcRequest request) throws Exception {
bootstrap.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel channel) throws Exception {
channel.pipeline().addLast(new RpcEncoder(RpcRequest.class)) // 将
// RPC
// 请求进行编码（为了发送请求）
.addLast(new RpcDecoder(RpcResponse.class)) // 将 RPC
// 响应进行解码（为了处理响应）
channel.pipeline().addLast(new RpcEncoder(RpcRequest.class)) // 将 RPC 请求进行编码（为了发送请求）
.addLast(new RpcDecoder(RpcResponse.class)) // 将 RPC 响应进行解码（为了处理响应）
.addLast(RpcClient.this); // 使用 RpcClient 发送 RPC 请求
}
}).option(ChannelOption.SO_KEEPALIVE, true);
Expand Down
51 changes: 51 additions & 0 deletions rpc_client/src/main/java/xyz/anduo/rpc/client/RpcProxy.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,51 @@
package xyz.anduo.rpc.client;

import java.lang.reflect.Method;
import java.util.UUID;

import net.sf.cglib.proxy.InvocationHandler;
import net.sf.cglib.proxy.Proxy;

public class RpcProxy {
private String serverAddress;
private ServiceDiscovery serviceDiscovery;

public RpcProxy(String serverAddress) {
this.serverAddress = serverAddress;
}

public RpcProxy(ServiceDiscovery serviceDiscovery) {
this.serviceDiscovery = serviceDiscovery;
}

@SuppressWarnings("unchecked")
public <T> T create(Class<?> interfaceClass) {
return (T) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class<?>[]{interfaceClass},
new InvocationHandler() {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
RpcRequest request = new RpcRequest(); // 创建并初始化 RPC 请求
request.setRequestId(UUID.randomUUID().toString());
request.setClassName(method.getDeclaringClass().getName());
request.setMethodName(method.getName());
request.setParameterTypes(method.getParameterTypes());
request.setParameters(args);

if (serviceDiscovery != null) {
serverAddress = serviceDiscovery.discover(); // 发现服务
}
String[] array = serverAddress.split(":");
String host = array[0];
int port = Integer.parseInt(array[1]);

RpcClient client = new RpcClient(host, port); // 初始化 RPC 客户端
RpcResponse response = client.send(request); // 通过 RPC客户端发送RPC请求并获取RPC响应
if (response.isError()) {
throw response.getError();
} else {
return response.getResult();
}
}
});
}
}
2 changes: 1 addition & 1 deletion ...java/xyz/anduo/rpc/server/RpcRequest.java → ...java/xyz/anduo/rpc/client/RpcRequest.java
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package xyz.anduo.rpc.server;
package xyz.anduo.rpc.client;

public class RpcRequest {
private String requestId;
Expand Down
2 changes: 1 addition & 1 deletion ...ava/xyz/anduo/rpc/server/RpcResponse.java → ...ava/xyz/anduo/rpc/client/RpcResponse.java
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package xyz.anduo.rpc.server;
package xyz.anduo.rpc.client;

public class RpcResponse {
private String requestId;
Expand Down
4 changes: 2 additions & 2 deletions ...yz/anduo/rpc/client/ServiceDiscovery.java → ...yz/anduo/rpc/client/ServiceDiscovery.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,15 +13,15 @@
import org.apache.zookeeper.ZooKeeper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import xyz.anduo.rpc.common.Constant;

import xyz.anduo.rpc.server.Constant;

public class ServiceDiscovery {
private static final Logger LOGGER = LoggerFactory.getLogger(ServiceDiscovery.class);

private CountDownLatch latch = new CountDownLatch(1);

private volatile List<String> dataList = new ArrayList<>();
private volatile List<String> dataList = new ArrayList<String>();

private String registryAddress;

Expand Down
0 src/main/resources/client-config.properties → ...c/main/resources/client-config.properties
View file
File renamed without changes.
18 changes: 18 additions & 0 deletions rpc_client/src/main/resources/spring-client.xml
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd">

<context:property-placeholder location="classpath:client-config.properties"/>

<!-- 配置服务发现组件 -->
<bean id="serviceDiscovery" class="xyz.anduo.rpc.client.ServiceDiscovery">
<constructor-arg name="registryAddress" value="${registry.address}"/>
</bean>

<!-- 配置 RPC 代理 -->
<bean id="rpcProxy" class="xyz.anduo.rpc.client.RpcProxy">
<constructor-arg name="serviceDiscovery" ref="serviceDiscovery"/>
</bean>
</beans>
Loading

0 comments on commit ae85a31

Please sign in to comment.