新聞中心
java8中提供的很多新特性可以用來(lái)重構(gòu)傳統(tǒng)設(shè)計(jì)模式中的寫法,下面是一些示例:

1. 策略模式
上圖是策略模式的類圖,假設(shè)我們現(xiàn)在要保存訂單,OrderService接口定義要做什么,而NoSqlSaveOrderStragegy以及MySqlSaveOrderStrategy則提供了二種策略,分別是保存到nosql數(shù)據(jù)庫(kù),以及傳統(tǒng)的mysql關(guān)系型數(shù)據(jù)庫(kù),最后在OrderServiceExecutor中通過(guò)構(gòu)造函數(shù)注入最終要使用的策略。
傳統(tǒng)寫法,這個(gè)場(chǎng)景至少得4個(gè)類,代碼如下:
OrderService接口:
public interface OrderService {
void saveOrder(String orderNo);
}Mysql策略實(shí)現(xiàn):
public class MySqlSaveOrderStrategy implements OrderService {
@Override
public void saveOrder(String orderNo) {
System.out.println("order:" + orderNo + " save to mysql");
}
}Nosql策略實(shí)現(xiàn):
public class NoSqlSaveOrderStrategy implements OrderService {
@Override
public void saveOrder(String orderNo) {
System.out.println("order:" + orderNo + " save to nosql");
}
}使用策略的輔助"容器":
public class OrderServiceExecutor {
private final OrderService service;
public OrderServiceExecutor(OrderService service) {
this.service = service;
}
public void save(String orderNo) {
this.service.saveOrder(orderNo);
}
}運(yùn)行測(cè)試類:
public class OrderServiceTest {
public static void main(String[] args) {
OrderServiceExecutor executor1 = new OrderServiceExecutor(new MySqlSaveOrderStrategy());
executor1.save("001");
OrderServiceExecutor executor2 = new OrderServiceExecutor(new NoSqlSaveOrderStrategy());
executor2.save("002");
}
}重構(gòu)后,可以省去2個(gè)策略實(shí)現(xiàn)類,代碼如下:
public static void main(String[] args) {
OrderServiceExecutor executor1 = new OrderServiceExecutor((String orderNo) -> System.out.println("order:" + orderNo + " save to mysql"));
executor1.save("001");
OrderServiceExecutor executor2 = new OrderServiceExecutor((String orderNo) -> System.out.println("order:" + orderNo + " save to nosql"));
executor2.save("002");
}2. 模板方法
類圖如下,核心思路是把一些通用的標(biāo)準(zhǔn)方法,在抽象父類里僅定義方法簽名,實(shí)現(xiàn)邏輯交給子類。
比如:會(huì)員系統(tǒng)中,每個(gè)商家都會(huì)有一些營(yíng)銷活動(dòng),需要推送某種信息給會(huì)員,但是不同的商家推送的內(nèi)容可能不同,有些需要推送優(yōu)惠券,有些需要積分通知。
抽象模板類:
public abstract class AbstractPushTemplate {
public void push(int customerId, String shopName) {
System.out.println("準(zhǔn)備推送...");
execute(customerId, shopName);
System.out.println("推送完成\n");
}
abstract protected void execute(int customerId, String shopName);
}優(yōu)惠券的具體模板;
public class PushCouponTemplate extends AbstractPushTemplate {
@Override
protected void execute(int customerId, String shopName) {
System.out.println("會(huì)員:" + customerId + ",你好," + shopName + "送您一張優(yōu)惠券");
}
}積分的具體模板;
public class PushScoreTemplate extends AbstractPushTemplate {
@Override
protected void execute(int customerId, String shopName) {
System.out.println("會(huì)員:" + customerId + ",你好," + shopName + "送您10個(gè)積分");
}
}使用示例:
AbstractPushTemplate template1 = new PushCouponTemplate();
template1.push(1, "糖果店");
AbstractPushTemplate template2 = new PushScoreTemplate();
template2.push(1, "服裝店");
顯然如果模板的實(shí)現(xiàn)方式越多,子類就越多。
使用java8重構(gòu)后,可以把上面的3個(gè)模板(包括抽象類模板)減少到1個(gè),參考下面:
public class PushTemplateLambda {
public void push(int customerId, String shopName, Consumer借助Consumer
new PushTemplateLambda().push(1, "糖果店", (Object[] obj) -> {
System.out.println("會(huì)員:" + obj[0] + ",你好," + obj[1] + "送您一張優(yōu)惠券");
});
new PushTemplateLambda().push(1, "服裝店", (Object[] obj) -> {
System.out.println("會(huì)員:" + obj[0] + ",你好," + obj[1] + "送您10個(gè)積分");
});3. 觀察者模式
思路:基于某個(gè)Subject主題,然后一堆觀察者Observer注冊(cè)到主題上,有事件發(fā)生時(shí),subject根據(jù)注冊(cè)列表,去通知所有的observer。
Observer接口:
public interface Observer {
void notify(String orderNo);
}Subject接口:
public interface Subject {
void registerObserver(Observer o);
void notifyAllObserver(String orderNo);
}Subject接口實(shí)現(xiàn):
public class SubjectImpl implements Subject {
private final List list = new ArrayList<>();
@Override
public void registerObserver(Observer o) {
list.add(o);
}
@Override
public void notifyAllObserver(String orderNo) {
list.forEach(c -> c.notify(orderNo));
}
} 觀察者的二個(gè)實(shí)現(xiàn):
OrderObserver:
public class OrderObserver implements Observer {
@Override
public void notify(String orderNo) {
System.out.println("訂單 " + orderNo + " 狀態(tài)更新為【已支付】");
}
}StockObserver;
public class StockObserver implements Observer {
@Override
public void notify(String orderNo) {
System.out.println("訂單 " + orderNo + " 已通知庫(kù)房發(fā)貨!");
}
}測(cè)試一把:
static void test1() {
Subject subject = new SubjectImpl();
subject.registerObserver(new OrderObserver());
subject.registerObserver(new StockObserver());
subject.notifyAllObserver("001");
}用java8重構(gòu)后,接口可以提供默認(rèn)實(shí)現(xiàn)方法,我們弄一個(gè)新的主題接口;
public interface NewSubject {
List list = new ArrayList<>();
default void registerObserver(Observer o) {
list.add(o);
}
default void nofityAllObserver(String orderNo) {
list.forEach(c -> c.notify(orderNo));
}
} 使用:
static void test2() {
NewSubject subject = new NewSubject() {
};
subject.registerObserver((String orderNo) -> System.out.println("訂單 " + orderNo + " 狀態(tài)更新為【已支付】"));
subject.registerObserver((String orderNo) -> System.out.println("訂單 " + orderNo + " 已通知庫(kù)房發(fā)貨!"));
subject.nofityAllObserver("002");
}只用2個(gè)接口實(shí)現(xiàn)了觀察者模式。
4. 責(zé)任鏈/職責(zé)鏈模式
核心思想:每個(gè)處理環(huán)節(jié),都有一個(gè)“指針”指向下一個(gè)處理者,類似鏈表一樣。
Processor接口:
public interface Processor {
Processor getNextProcessor();
void process(String param);
}抽象實(shí)現(xiàn)類:
public abstract class AbstractProcessor implements Processor {
private Processor next;
public AbstractProcessor(Processor processor) {
this.next = processor;
}
@Override
public Processor getNextProcessor() {
return next;
}
@Override
public abstract void process(String param);
}定義2個(gè)具體的實(shí)現(xiàn):
public class ProcessorImpl1 extends AbstractProcessor {
public ProcessorImpl1(Processor processor) {
super(processor);
}
@Override
public void process(String param) {
System.out.println("processor 1 is processing:" + param);
if (getNextProcessor() != null) {
getNextProcessor().process(param);
}
}
}及;
public class ProcessorImpl2 extends AbstractProcessor {
public ProcessorImpl2(Processor next) {
super(next);
}
@Override
public void process(String param) {
System.out.println("processor 2 is processing:" + param);
if (getNextProcessor() != null) {
getNextProcessor().process(param);
}
}
}使用示例:
static void test1() {
Processor p1 = new ProcessorImpl1(null);
Processor p2 = new ProcessorImpl2(p1);
p2.process("something happened");
}用java8重構(gòu)后,只需要一個(gè)新接口;
@FunctionalInterface
public interface NewProcessor {
Consumerprocess(String param);
}
同樣的效果,可以寫得很簡(jiǎn)潔:
static void test2() {
Consumer p1 = param -> System.out.println("processor 1 is processing:" + param);
Consumer p2 = param -> System.out.println("processor 2 is processing:" + param);
p2.andThen(p1).accept("something happened");
} andThen天然就是getNextProcessor的另一種表達(dá)。
重要提示:什么時(shí)候該用lambda,什么時(shí)候不用,這是要看情況的,如果處理邏輯相對(duì)比較簡(jiǎn)單,可以用lamdba來(lái)重構(gòu),以便讓代碼更簡(jiǎn)潔易讀,如果處理邏輯很復(fù)雜,應(yīng)該還是用“類”。
網(wǎng)頁(yè)題目:Java8重構(gòu)傳統(tǒng)設(shè)計(jì)模式,是真的優(yōu)雅!
轉(zhuǎn)載來(lái)源:http://www.dlmjj.cn/article/cdhcedc.html


咨詢
建站咨詢
