最代码广告位
首页>分享>javascript websocket实现的简单聊天程序>/reverse_ajax/src/com/cn/test/chapter2/websocket/Endpoints.java
package com.cn.test.chapter2.websocket;

import org.eclipse.jetty.websocket.WebSocket;

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * @author Mathieu Carbou (mathieu.carbou@gmail.com)
 */
final class Endpoints {
	
    private final Queue<Endpoint> endpoints = new ConcurrentLinkedQueue<Endpoint>();

    /**
     * 广播
     * @param fromEndpoint  消息来源
     * @param data
     */
    void broadcast(Endpoint fromEndpoint, String data) {
    	System.out.println("endpoints.size  : " + endpoints.size());
        for (Endpoint endpoint : endpoints) {
        	//不给自己发信息广播,如果是clientId=0为系统广播
        	if(endpoint != fromEndpoint){
        		endpoint.sendMessage(fromEndpoint,data);
        	}
        }
    }
    

    void offer(Endpoint endpoint) {
        endpoints.offer(endpoint);
    }

    void remove(Endpoint endpoint) {
        endpoints.remove(endpoint);
    }

    public WebSocket newEndpoint() {
        return new Endpoint(this);
    }
}
最近下载更多
浙雨扬 LV102019年11月25日
月亮月亮星星星星
Swl_124 LV22019年11月4日
星星星星
kangdi LV102019年10月28日
月亮月亮星星星星
skipple3 LV332019年10月15日
太阳太阳星星
墨玉公子 LV22019年7月28日
星星星星
cm1579489233 LV12019年6月9日
星星
wdxcw199327 LV22019年4月3日
星星星星
ws760823 LV82019年2月27日
月亮月亮
w651465994 LV12019年2月20日
星星
chengbochengbo LV12019年1月3日
星星
最近浏览更多
小B男666 LV73月30日
月亮星星星星星星
小资李 LV123月20日
月亮月亮月亮
暂无贡献等级
Allez可乐3月17日
暂无贡献等级
1633902558 LV13月15日
星星
西门厌 LV23月5日
星星星星
暂无贡献等级
zhangchunjia LV21月17日
星星星星
小王wang LV101月17日
月亮月亮星星星星
暂无贡献等级
顶部客服微信二维码底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友