package proxy
import "fmt"
type House interface {
Sail()
}
type SmailHouse struct {
}
func (SmailHouse) Sail() {
fmt.Println("100 万")
}
type Proxy struct {
house SmailHouse
}
func NewProxy() *Proxy {
return &Proxy{}
}
func (p Proxy) Sail() {
var result string = "签订成功"
p.Before()
p.house.Sail()
p.After()
fmt.Println(result)
}
func (Proxy) Before() {
fmt.Println("代理之前的一些检查")
}
func (Proxy) After() {
fmt.Println("代理之后的一些检查")
}
package proxy
import "testing"
func Test(t *testing.T) {
var house House = NewProxy()
house.Sail()
}
package tech.selinux.design.pattern.structural.proxy;
public class Order {
private Object orderInfo;
private Integer userId;
public Object getOrderInfo() {
return orderInfo;
}
public void setOrderInfo(Object orderInfo) {
this.orderInfo = orderInfo;
}
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
}
package tech.selinux.design.pattern.structural.proxy;
public interface IOrderDao {
int insert(Order order);
}
package tech.selinux.design.pattern.structural.proxy;
public interface IOrderService {
int saveOrder(Order order);
}
package tech.selinux.design.pattern.structural.proxy;
public class OrderDaoImpl implements IOrderDao {
@Override
public int insert(Order order) {
System.out.println("Dao层添加Order成功");
return 1;
}
}
package tech.selinux.design.pattern.structural.proxy;
public class OrderServiceImpl implements IOrderService {
private IOrderDao iOrderDao;
@Override
public int saveOrder(Order order) {
iOrderDao = new OrderDaoImpl();
System.out.println("Service层调用Dao层添加Order");
return iOrderDao.insert(order);
}
}
package tech.selinux.design.pattern.structural.proxy.staticproxy;
import tech.selinux.design.pattern.structural.proxy.IOrderService;
import tech.selinux.design.pattern.structural.proxy.Order;
import tech.selinux.design.pattern.structural.proxy.OrderServiceImpl;
public class OrderServiceStaticProxy {
private IOrderService iOrderService;
public int saveOrder(Order order) {
beforeMethod(order);
iOrderService = new OrderServiceImpl();
int result = iOrderService.saveOrder(order);
afterMethod();
return result;
}
private void beforeMethod(Order order) {
int userId = order.getUserId();
int dbRouter = userId % 2;
System.out.println("静态代理分配到【db" + dbRouter + "】处理数据");
// todo 设置dataSource;
System.out.println("db" + String.valueOf(dbRouter));
System.out.println("静态代理 before code");
}
private void afterMethod() {
System.out.println("静态代理 after code");
}
}
package tech.selinux.design.pattern.structural.proxy;
public class StaticTest {
public static void main(String[] args) {
Order order = new Order();
order.setUserId(2);
OrderServiceStaticProxy orderServiceStaticProxy = new OrderServiceStaticProxy();
orderServiceStaticProxy.saveOrder(order);
}
}
package tech.selinux.design.pattern.structural.proxy.dynamicproxy;
import tech.selinux.design.pattern.structural.proxy.Order;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
public class OrderServiceDynamicProxy implements InvocationHandler {
private Object target;
public OrderServiceDynamicProxy(Object target) {
this.target = target;
}
public Object bind() {
Class cls = target.getClass();
return Proxy.newProxyInstance(cls.getClassLoader(), cls.getInterfaces(), this);
}
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
Object argObject = args[0];
beforeMethod(argObject);
Object object = method.invoke(target, args);
afterMethod();
return object;
}
private void beforeMethod(Object obj) {
int userId = 0;
System.out.println("动态代理 before code");
if (obj instanceof Order) {
Order order = (Order) obj;
userId = order.getUserId();
}
int dbRouter = userId % 2;
System.out.println("动态代理分配到【db" + dbRouter + "】处理数据");
// todo 设置dataSource;
System.out.println("db" + String.valueOf(dbRouter));
}
private void afterMethod() {
System.out.println("动态代理 after code");
}
}
package tech.selinux.design.pattern.structural.proxy;
public class DynamicTest {
public static void main(String[] args) {
Order order = new Order();
order.setUserId(1);
IOrderService orderServiceDynamicProxy =
(IOrderService) new OrderServiceDynamicProxy(new OrderServiceImpl()).bind();
orderServiceDynamicProxy.saveOrder(order);
}
}
