java xcap_java实现发布订阅
1.發(fā)布者接口
package com.yy.subpub;
/**
* @Description: 發(fā)布者接口
* @author: leijing
* @date: 2016年9月29日 下午5:07:20
*/
public interface IPublisher {
/**
* @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 {
/**
* @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 {
//訂閱器名稱
private String name;
//訂閱器隊(duì)列容量
final int QUEUE_CAPACITY = 20;
//訂閱器存儲(chǔ)隊(duì)列
private BlockingQueue queue = new ArrayBlockingQueue(QUEUE_CAPACITY);
//訂閱者
private List subcribers = new ArrayList();
/**
* @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 = new Msg(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ā)送存儲(chǔ)隊(duì)列所有消息
* @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{
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ā)布者實(shí)現(xiàn)類
package com.yy.subpub.imp;
import com.yy.subpub.IPublisher;
import com.yy.subpub.SubscribePublish;
/**
* @Description: 發(fā)布者實(shí)現(xiàn)類
* @author: leijing
* @date: 2016年9月29日 下午5:10:00
*/
public class PublisherImpOne implements IPublisher{
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.訂閱者實(shí)現(xiàn)類
package com.yy.subpub.imp;
import com.yy.subpub.ISubcriber;
import com.yy.subpub.SubscribePublish;
/**
* @Description: 訂閱者實(shí)現(xiàn)類
* @author: leijing
* @date: 2016年9月29日 下午5:10:00
*/
public class SubcriberImpOne implements ISubcriber{
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ā)來(lái)的消息:"+message.toString());
}
}6.測(cè)試類
package com.yy.subpub;
import com.yy.subpub.imp.PublisherImpOne;
import com.yy.subpub.imp.SubcriberImpOne;
/**
* @Description: 發(fā)布訂閱測(cè)試類
* @author: leijing
* @date: 2016年9月29日 下午5:28:53
*/
public class SubPubTest {
public static void main(String[] args) {
SubscribePublish subscribePublish = new SubscribePublish("訂閱器");
IPublisher publisher1 = new PublisherImpOne("發(fā)布者1");
ISubcriber subcriber1 = new SubcriberImpOne("訂閱者1");
ISubcriber subcriber2 = new SubcriberImpOne("訂閱者2");
subcriber1.subcribe(subscribePublish);
subcriber2.subcribe(subscribePublish);
publisher1.publish(subscribePublish, "welcome",true);
publisher1.publish(subscribePublish, "to",true);
publisher1.publish(subscribePublish, "yy",false);
}
}
測(cè)試結(jié)果:
總結(jié)
以上是生活随笔為你收集整理的java xcap_java实现发布订阅的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 依赖注入之针对不同类型变量的几种注入方式
- 下一篇： ArcGIS应用