Skip to content

Latest commit

 

History

History
159 lines (105 loc) · 4.01 KB

Java利用listener实现回调，即观察者模式.md

File metadata and controls

159 lines (105 loc) · 4.01 KB
Raw

java中实现观察者模式有很多种方式，上一篇文章介绍到了，利用callback的方式实现了回调，这篇文章准备介绍的是利用listener实现回调。

Java回调机制

根据实时性划分：

实现方式

这两种实现方式本质上是类似的，应用场景略有不同，如果有熟知安卓的朋友应该可以知道，在为一个view添加点击实现的时候是有两种方式的

  1. 利用callback来实现
view.setOnClickListener(new View.OnClickListener() {
            @Override public void onClick(View view) {
                
            }
        });

2.实现View.OnClickListener接口

public class Test extends AppCompatActivity implements View.OnClickListener {
    private Button button;

    @Override protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        button = (Button) findViewById(R.id.ac_video_btn_getValue);
        button.setOnClickListener(this);
    }

    @Override public void onClick(View view) {
        //TODO
    }
}

回调的本质

其实无论哪种方式来实现回调，利用的思想都是观察者模式，即在我们选择订阅之后，当对方做出任何举动的时候会给我们发送一条信息，这样做的好处是省着我们用一个新的线程轮训检测对方的状态，可以节省很多的资源。

应用的场景

  • 如果我们需要将信息一层一层的返回去的时候，正如我下面的例子，那么可能用listener更为适合我们，因为我们可以将这个listener进行传递，在需要查看数据的时候进行回调它。或者当我们有很多事件需要回调的时候，可以实现一个listener然后发送不同的信息，进行区分。这样代码看起来会简洁一些，不会像callback一样，会嵌套很多层，也不会写出很多个callback来。

  • 如果我们只有一处，或者简单的几处需要回调的话，那么我们完全可以不用实现这个接口，而是用callback的方式来进行处理。

还是举一个简单的生活中的例子吧，在公司中有一件事情，老板想要问员工，但是老板只能联系到部门经理，那么便有了，A问B,B问C，C经过思考，回答了B，B又将答案告诉了A，A知道了答案，便高兴的说了出来。

我下面的代码采用了单例模式来写：

Listner.java

public interface Listener {
	void onFinish(String msg);
}

People.java

public class People implements Listener {

	private static People people;

	private People() {

	}

	synchronized public static People getInstance() {
		if (people == null) {
			people = new People();
		}
		return people;
	}

	public void askPeople2() {
		People2.getInstance().askPeople3(this);
	}

	@Override
	public void onFinish(String msg) {
		System.out.println("收到的消息是 ---> " + msg);
	}

}

People2.java

public class People2 {

	private static People2 people2;

	private People2() {

	}

	synchronized public static People2 getInstance() {
		if (people2 == null)
			people2 = new People2();
		return people2;
	}
	
	public void askPeople3(Listener listener){
		People3.getInstance().thinking(listener);
	}

}

People3.java

public class People3 {

	private static People3 people3;

	private People3() {

	}

	synchronized public static People3 getInstance() {
		if (people3 == null)
			people3 = new People3();
		return people3;
	}

	public void thinking(Listener listener3) {
		try {
			Thread.sleep(2000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		listener3.onFinish("我已经思考完毕");
	}

}

result