事件驅動程式設計
看完公司的基于Netty的遊戲架構,架構中用到了多态,函數式程式設計和事件驅動程式設計,第一次看到事件驅動的時候,就想到跟觀察者模式很像.
事件驅動初上手感覺還很好用,在我自己寫的項目裡,要寫很多爬蟲,比如下面爬蟲的例子,我隻是想關心拼接URL位址,和關心不同的網站怎麼解析DOM元素,寫一個回調就好
多态,函數式程式設計和事件驅動程式設計,這三個還是然讓我學到很多,可以用一個架構的基礎,比如在Netty中,繼承
SimpleChannelInboundHandler<TextWebSocketFrame>
,實作這裡裡面的方法,就能接收到請求,很友善.
![](https://img.laitimes.com/img/9ZDMuAjOiMmIsIjOiQnIsISM9AnYldnJwAzN9c3Pn5GcuQ0MlMWbidXNp1kenRlT6VEVOhXWE1UNFRUT5hTeaZHetlldwIjYqVTejpWNXRWNsdkYoVTaixGatVWdWdUY6FTaipWM5Nme50GTqp0MjZHaYp1b5kHT20ESjBjUIF2Lc12bj5SYphXa5VWen5WY35iclN3Ztl2Lc9CX6MHc0RHaiojIsJye.png)
1.JAVA回調的例子
/**
* @Description java回調
* @Author Anthony
* @Date 2019/6/15
*/
interface Callback {
Map<String,String> parse(String html);
}
public class CallbackDemo {
// 爬蟲工具類
static Map<String,String> send(String URL, Callback callback) {
// 模拟爬蟲傳回的資料
String spiderResponse = "";
if ("http://www.baidu.com".equals(URL)) {
spiderResponse = "name=baidu&age=23";
}else if("http://www.qq.com".equals(URL)){
spiderResponse = "name=mahuateng&age=24";
}
// 回調方法
return callback.parse(spiderResponse);
}
public static void main(String[] args) {
String URL = "http://www.baidu.com";
Map<String, String> send = send(URL, gbk -> {
Map<String, String> map = new HashMap<>();
// 切分&
String[] split = gbk.split("&");
// name
map.put(split[0].split("=")[0], split[0].split("=")[1]);
// age
map.put(split[1].split("=")[0], split[0].split("=")[1]);
return map;
});
System.out.println(send.get("name"));
}
}
這樣寫各種簡單的java爬蟲的時候,隻需要關心URL,和怎麼分析爬蟲傳回的資料
2.觀察者模式中的多态的例子
/**
* @Description JAVA多态
* @Author Anthony
* @Date 2019/6/15
*/
abstract class MyCallback {
void method(){
System.out.println("method");
}
void method2(){
System.out.println("method2");
}
}
class MyImpl extends MyCallback {
@Override
void method() {
System.out.println("Myimpl method");
}
}
public class Demo {
public static void main(String[] args) {
MyCallback impl = new MyImpl();
impl.method();
impl.method2();
}
}
3.觀察者模式的例子
參考的是菜鳥教程中設計模式的例子
import java.util.ArrayList;
import java.util.List;
/**
* @Description 觀察者模式
* @Author Anthony
* @Date 2019/6/15
*/
/**
* 建立 Observer 類。
*/
abstract class Observer {
Subject subject;
public abstract void update();
}
/**
* 建立 Subject 類。
*/
class Subject {
// 最重要的地方
private List<Observer> observers = new ArrayList<>();
private int state;
int getState() {
return state;
}
void setState(int state) {
this.state = state;
notifyAllObservers();
}
void attach(Observer observer){
observers.add(observer);
}
// 最重要的地方
private void notifyAllObservers(){
for (Observer observer : observers) {
observer.update();
}
}
}
/**
* 建立實體觀察者類。1
*/
class BinaryObserver extends Observer{
BinaryObserver(Subject subject){
this.subject = subject;
this.subject.attach(this);
}
@Override
public void update() {
System.out.println( "BinaryObserver: "+ Integer.toBinaryString( subject.getState() ) );
}
}
/**
* 建立實體觀察者類。2
*/
class OctalObserver extends Observer{
OctalObserver(Subject subject){
this.subject = subject;
this.subject.attach(this);
}
@Override
public void update() {
System.out.println( "OctalObserver: " + Integer.toOctalString( subject.getState() ) );
}
}
public class Demo{
public static void main(String[] args) {
Subject subject = new Subject();
new OctalObserver(subject);
new BinaryObserver(subject);
System.out.println("第一次狀态改變: 15");
subject.setState(15);
System.out.println("第二次狀态改變: 10");
subject.setState(10);
}
}
列印結果:
第一次狀态改變: 15
OctalObserver: 17
BinaryObserver: 1111
第二次狀态改變: 10
OctalObserver: 12
BinaryObserver: 1010
事件驅動程式設計
雖然看了事件驅動的定義,雖然知道是什麼意思,但是不知道該怎麼說出來,大概就是,寫個while循環周遊隊列,或者集合的中資料
/**
* @Description 事件驅動程式設計
* @Author Anthony
* @Date 2019/6/15
*/
interface ClickCall{
String click(String msg);
}
class MyTask{
protected String msg;
protected ClickCall clickCall;
public MyTask(String msg,ClickCall clickCall) {
this.msg = msg;
this.clickCall = clickCall;
}
}
public class Demo {
// java 棧,也可以當做是隊列之類
public static Stack<MyTask> list = new Stack<>();
public static void main(String[] args) throws InterruptedException {
// 模拟滑鼠點選
list.push(new MyTask("右鍵",msg->{
return "右手點選滑鼠"+msg;
}));
list.push(new MyTask("左鍵",msg->{
return "左手點選滑鼠"+msg;
}));
// 啟動一個線程循環List
new Thread(() -> {
while (true && !list.empty()) {
// pop 方法,從棧頂移除一個,并列印出來
MyTask pop = list.pop();
System.out.println(pop.clickCall.click(pop.msg));
}
}).start();
}
}
參考
我的部落格:http://yanganlin.com