国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

public class AuthPlugin implements BrokerPlugin{    private String mqName;//本MQ服務(wù)器名稱    private JdbcTemplate jdbcTemplate;//數(shù)據(jù)庫操作類        public AuthPlugin(JdbcTemplate jdbcTemplate,String mqName) {        this.jdbcTemplate=jdbcTemplate;        this.mqName=mqName;    }        @Override    public Broker installPlugin(Broker broker) throws Exception {        return new AuthBroker(broker,jdbcTemplate,mqName);    }}

<!--broker節(jié)點(diǎn)下--><plugins>    <bean xmlns="http://www.springframework.org/schema/beans" id="ehlPlugin" class="com.ehl.plugin.AuthPlugin">        <constructor-arg index="0">            <ref bean="jdbcTemplate"/>        </constructor-arg>        <constructor-arg index="1" value="MQName"/><!--本消息隊(duì)列的名稱-->    </bean></plugins>

public class AuthBroker extends AbstractAuthenticationBroker{    private static Log log = LogFactory.getLog(AuthBroker.class);　　　//用戶 對(duì)應(yīng)的權(quán)限　　　private Map<String, Map<String,ViewProjectMqQueuesCom>> powers=new HashMap<String,Map<String,ViewProjectMqQueuesCom>>();//權(quán)限    private static final String ACTIVEMQ_ADVISORY_PRODUCER_QUEUE="ActiveMQ.Advisory.Producer.Queue.";//消息生產(chǎn)者前綴    private static final String ACTIVEMQ_ADVISORY_CONSUMER_QUEUE="ActiveMQ.Advisory.Consumer.Queue.";//消息消費(fèi)者前綴    private JdbcTemplate jdbcTemplate;//數(shù)據(jù)庫操作    private String mqName;//MQ服務(wù)器名稱    public AuthBroker(Broker next,JdbcTemplate jdbcTemplate,String mqName) {        super(next);        this.jdbcTemplate=jdbcTemplate;        this.mqName=mqName;    }        /**     * 連接攔截器     */    @Override    public void addConnection(ConnectionContext context, ConnectionInfo info) throws Exception {        log.info("用戶["+info.getUserName()+"]請(qǐng)求連接["+mqName+"]!");        SecurityContext securityContext = context.getSecurityContext();        if (securityContext == null) {            securityContext = authenticate(info.getUserName(), info.getPassword(), null);            context.setSecurityContext(securityContext);            securityContexts.add(securityContext);        }                try {            super.addConnection(context, info);        } catch (Exception e) {            securityContexts.remove(securityContext);            context.setSecurityContext(null);            throw e;        }    }        /**     * 認(rèn)證     * <p>Title: authenticate</p>     */    @Override    public SecurityContext authenticate(String username, String password, X509Certificate[] peerCertificates) throws SecurityException {        SecurityContext securityContext = null;        Com com=getCom(username,password);        //驗(yàn)證用戶信息        if(com!=null&&com.getId()!=null){             securityContext = new SecurityContext(username) {                    @Override                    public Set<Principal> getPrincipals() {                        Set<Principal> groups = new HashSet<Principal>();                        groups.add(new GroupPrincipal("users"));//默認(rèn)加入了users的組                        return groups;                    }                };//                log.info("用戶："+username+"驗(yàn)證成功!");        }else{            log.error("用戶:"+username+"驗(yàn)證失敗!");            throw new SecurityException("驗(yàn)證失敗");        }        return securityContext;    }        /**     * 添加一個(gè)目標(biāo)     * <p>Title: addDestination</p>     * @see org.apache.activemq.broker.BrokerFilter#addDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, boolean)     */    @Override    public Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) throws Exception {        boolean destStats = destination.getPhysicalName().regionMatches(true, 0, ACTIVEMQ_ADVISORY_PRODUCER_QUEUE, 0,ACTIVEMQ_ADVISORY_PRODUCER_QUEUE.length());        //發(fā)送消息者        if(destStats){            if(context.getSecurityContext()!=null){                //判斷不是默認(rèn)用戶                if(!context.getSecurityContext().getUserName().equals(SecurityContext.BROKER_SECURITY_CONTEXT.getUserName())){                    String queuesName=destination.getPhysicalName().replace(ACTIVEMQ_ADVISORY_PRODUCER_QUEUE, "");//得到消息隊(duì)列名                    if(powers.containsKey(context.getSecurityContext().getUserName())){//判斷該用戶是否有權(quán)限                        Map<String,ViewProjectMqQueuesCom> map=powers.get(context.getSecurityContext().getUserName());                        if(map!=null&&map.containsKey(queuesName)){//判斷是否有發(fā)送的權(quán)限                            if(map.get(queuesName).getBindId()!=null&&map.get(queuesName).getComQueuesType()!=null){                                if(map.get(queuesName).getComQueuesType().intValue()==QueuesComType.BOTH.getValue().intValue()||map.get(queuesName).getComQueuesType().intValue()==QueuesComType.SEND.getValue().intValue()){                                    return super.addDestination(context, destination, createIfTemporary);                                }                            }                        }                        throw new Exception("["+mqName+"-"+context.getUserName()+"]對(duì)消息隊(duì)列["+queuesName+"]沒有發(fā)送消息的權(quán)限");                    }else{                        throw new Exception("請(qǐng)登錄后再操作!");                    }                }            }        }else{            boolean consumerStats = destination.getPhysicalName().regionMatches(true, 0, ACTIVEMQ_ADVISORY_CONSUMER_QUEUE, 0,ACTIVEMQ_ADVISORY_CONSUMER_QUEUE.length());            //消息接收者            if(consumerStats){                if(context.getSecurityContext()!=null){                    //判斷不是默認(rèn)用戶                    if(!context.getSecurityContext().getUserName().equals(SecurityContext.BROKER_SECURITY_CONTEXT.getUserName())){                        String queuesName=destination.getPhysicalName().replace(ACTIVEMQ_ADVISORY_CONSUMER_QUEUE, "");//得到消息隊(duì)列名稱                        if(powers.containsKey(context.getSecurityContext().getUserName())){//判斷用戶是否有對(duì)應(yīng)的權(quán)限                            Map<String,ViewProjectMqQueuesCom> map=powers.get(context.getSecurityContext().getUserName());                            if(map!=null&&map.containsKey(queuesName)){                                if(map.get(queuesName).getBindId()!=null&&map.get(queuesName).getComQueuesType()!=null){                                    if(map.get(queuesName).getComQueuesType().intValue()==QueuesComType.BOTH.getValue().intValue()||map.get(queuesName).getComQueuesType().intValue()==QueuesComType.RECEIVE.getValue().intValue()){                                        return super.addDestination(context, destination, createIfTemporary);                                    }                                }                            }                            throw new Exception("["+mqName+"-"+context.getUserName()+"]對(duì)消息隊(duì)列["+queuesName+"]沒有獲取消息的權(quán)限");                        }else{                            throw new Exception("請(qǐng)登錄后再操作!");                        }                    }                }            }        }        return super.addDestination(context, destination, createIfTemporary);    }        /**     * 監(jiān)控發(fā)送消息     * <p>Title: send</p>     * @see org.apache.activemq.broker.BrokerFilter#send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)     */    @Override    public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {        String userName=producerExchange.getConnectionContext().getUserName();        ActiveMQDestination msgDest = messageSend.getDestination();        String physicalName = msgDest.getPhysicalName();    }/**     * 監(jiān)控消息接收者     * <p>Title: acknowledge</p>     * @see org.apache.activemq.broker.BrokerFilter#acknowledge(org.apache.activemq.broker.ConsumerBrokerExchange, org.apache.activemq.command.MessageAck)     */    @Override    public void acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) throws Exception {        String userName=consumerExchange.getConnectionContext().getUserName();        String queues=ack.getDestination().getPhysicalName();    }}