1.發(fā)布者接口

package com.yy.subpub; /** * @Description: 發(fā)布者接口 * @author: leijing * @date: 2016年9月29日 下午5:07:20 */ public interface IPublisher<M> { /** * @Description: 向訂閱器發(fā)布消息 * @param subscribePublish 訂閱器 * @param message 消息 * @param isInstantMsg 是否立即發(fā)送 * @author: leijing * @date: 2016年9月29日 下午5:08:52 */ public void publish(SubscribePublish subscribePublish,M message,boolean isInstantMsg); }

2.訂閱者接口

package com.yy.subpub; /** * @Description: 訂閱者接口 * @author: leijing * @date: 2016年9月29日 下午5:07:20 */ public interface ISubcriber<M> { /** * @Description: 訂閱 * @param: subscribePublish 訂閱器 * @author: leijing * @date: 2016年9月29日 下午5:08:04 */ public void subcribe(SubscribePublish subscribePublish); /** * @Description: 退訂 * @param: subscribePublish 訂閱器 * @author: leijing * @date: 2016年9月29日 下午5:09:00 */ public void unSubcribe(SubscribePublish subscribePublish); /** * @Description: 接收消息 * @param: publisher 發(fā)布者 * @param: message 消息 * @author: leijing * @date: 2016年9月29日 下午5:09:44 */ public void update(String publisher,M message); }

3.訂閱器類

package com.yy.subpub; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; /** * @Description: 訂閱器類 * @author: leijing * @date: 2016年9月29日 下午5:07:20 */ public class SubscribePublish<M> { //訂閱器名稱 private String name; //訂閱器隊列容量 final int QUEUE_CAPACITY = 20; //訂閱器存儲隊列 private BlockingQueue<Msg> queue = new ArrayBlockingQueue<Msg>(QUEUE_CAPACITY); //訂閱者 private List<ISubcriber> subcribers = new ArrayList<ISubcriber>(); /** * @Description:構(gòu)造方法 * @param name */ public SubscribePublish(String name) { this.name = name; } /** * @Description: 接收發(fā)布者的消息 * @param publisher * @param Msg * @param isInstantMsg * @author: leijing * @date: 2016年9月29日 下午5:17:03 */ public void publish(String publisher,M message,boolean isInstantMsg) { if(isInstantMsg){ update(publisher,message); return; } Msg<m> m = new Msg<m>(publisher,message); if(!queue.offer(m)){ update(); } } /** * @Description: 訂閱 * @param subcriber * @return: void * @author: leijing * @date: 2016年9月29日 下午5:18:43 */ public void subcribe(ISubcriber subcriber) { subcribers.add(subcriber); } /** * @Description: 退訂 * @param subcriber * @return: void * @author: leijing * @date: 2016年9月29日 下午5:18:43 */ public void unSubcribe(ISubcriber subcriber) { subcribers.remove(subcriber); } /** * @Description: 發(fā)送存儲隊列所有消息 * @return: void * @author: leijing * @date: 2016年9月29日 下午5:20:33 */ public void update(){ Msg m = null; while((m = queue.peek())!= null){ this.update(m.getPublisher(),(M)m.getMsg()); } } /** * @Description: 發(fā)送消息 * @param publisher * @param Msg * @return: void * @author: leijing * @date: 2016年9月29日 下午5:14:29 */ public void update(String publisher,M Msg) { for(ISubcriber subcriber:subcribers){ subcriber.update(publisher,Msg); } } } /** * @Description: 消息類 * @author: leijing * @date: 2016年9月29日 下午5:25:21 */ class Msg<M>{ private String publisher; private M m; public Msg(String publisher, M m) { this.publisher = publisher; this.m = m; } public String getPublisher() { return publisher; } public void setPublisher(String publisher) { this.publisher = publisher; } public M getMsg() { return m; } public void setMsg(M m) { this.m = m; } }

4.發(fā)布者實現(xiàn)類

package com.yy.subpub.imp; import com.yy.subpub.IPublisher; import com.yy.subpub.SubscribePublish; /** * @Description: 發(fā)布者實現(xiàn)類 * @author: leijing * @date: 2016年9月29日 下午5:10:00 */ public class PublisherImpOne<M> implements IPublisher<M>{ private String name; public PublisherImpOne(String name) { super(); this.name = name; } public void publish(SubscribePublish subscribePublish, M message,boolean isInstantMsg) { subscribePublish.publish(this.name, message, isInstantMsg); } }

5.訂閱者實現(xiàn)類

package com.yy.subpub.imp; import com.yy.subpub.ISubcriber; import com.yy.subpub.SubscribePublish; /** * @Description: 訂閱者實現(xiàn)類 * @author: leijing * @date: 2016年9月29日 下午5:10:00 */ public class SubcriberImpOne<M> implements ISubcriber<M>{ public String name; public SubcriberImpOne(String name) { super(); this.name = name; } public void subcribe(SubscribePublish subscribePublish) { subscribePublish.subcribe(this); } public void unSubcribe(SubscribePublish subscribePublish) { subscribePublish.unSubcribe(this); } public void update(String publisher,M message) { System.out.println(this.name+"收到"+publisher+"發(fā)來的消息:"+message.toString()); } }

6.測試類

package com.yy.subpub; import com.yy.subpub.imp.PublisherImpOne; import com.yy.subpub.imp.SubcriberImpOne; /** * @Description: 發(fā)布訂閱測試類 * @author: leijing * @date: 2016年9月29日 下午5:28:53 */ public class SubPubTest { public static void main(String[] args) { SubscribePublish<string> subscribePublish = new SubscribePublish<string>("訂閱器"); IPublisher<string> publisher1 = new PublisherImpOne<string>("發(fā)布者1"); ISubcriber<string> subcriber1 = new SubcriberImpOne<string>("訂閱者1"); ISubcriber<string> subcriber2 = new SubcriberImpOne<string>("訂閱者2"); subcriber1.subcribe(subscribePublish); subcriber2.subcribe(subscribePublish); publisher1.publish(subscribePublish, "welcome",true); publisher1.publish(subscribePublish, "to",true); publisher1.publish(subscribePublish, "yy",false); } }

測試結(jié)果:

總結(jié)

以上是生活随笔為你收集整理的java 发布订阅的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。