java 发布订阅

你的名字 2024-04-17 20:29 106阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpa3VucGVuZzY2NTYyMDE_size_16_color_FFFFFF_t_70]  
**1.发布者接口**

package com.yy.subpub;
    /** * @Description: 发布者接口 * @author: leijing * @date: 2016年9月29日 下午5:07:20 */
    public interface IPublisher<M> { 
    /** * @Description: 向订阅器发布消息 * @param subscribePublish 订阅器 * @param message 消息 * @param isInstantMsg 是否立即发送 * @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 发布者 * @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:构造方法 * @param name */
    public SubscribePublish(String name) { 
    this.name = name;
    }
    /** * @Description: 接收发布者的消息 * @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: 发送存储队列所有消息 * @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: 发送消息 * @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.发布者实现类**

package com.yy.subpub.imp;
    import com.yy.subpub.IPublisher;
    import com.yy.subpub.SubscribePublish;
    /** * @Description: 发布者实现类 * @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.订阅者实现类**

package com.yy.subpub.imp;
    import com.yy.subpub.ISubcriber;
    import com.yy.subpub.SubscribePublish;
    /** * @Description: 订阅者实现类 * @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+"发来的消息:"+message.toString());
    }
    }

**6.测试类**

package com.yy.subpub;
    import com.yy.subpub.imp.PublisherImpOne;
    import com.yy.subpub.imp.SubcriberImpOne;
    /** * @Description: 发布订阅测试类 * @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>("发布者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);
    }
    }

**测试结果:**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpa3VucGVuZzY2NTYyMDE_size_16_color_FFFFFF_t_70 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpa3VucGVuZzY2NTYyMDE_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/8366ac12c6e04c10b20747e714d52c33.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpa3VucGVuZzY2NTYyMDE_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/fec0524ff1e34ae4ab7d1fc3d51d62ed.png