网红直播天水人间主播大秀

客官°小女子只卖身不卖艺 2023-06-05 08:18 122阅读 0赞

package happy;
    
    import org.apache.zookeeper.CreateMode;
    import org.apache.zookeeper.WatchedEvent;
    import org.apache.zookeeper.Watcher;
    import org.apache.zookeeper.ZooDefs.Ids;
    import org.apache.zookeeper.ZooKeeper;
    
    public class HappyRoom {
    
        //zookeeper集群地址
        private static String connectServerList = "192.168.220.130:2181,192.168.220.131:2181,192.168.220.132:2181";
    
        //连接超时时间
        private static int sessionTimeout = 20000;
    
        //zookeeper客户端
        public static ZooKeeper zk = null;
    
        //天上人间主播平台
        private static final String anchor = "/anchor";
    
    
    
        /**
         * 美女主播签到
         */
        public void singIn(String BeautyAnchorName) throws Exception{
    
         ZooKeeper  happyOnline = new ZooKeeper(connectServerList, sessionTimeout, null);
    
         //签到
            happyOnline.create(anchor +"/BeautyAnchor", BeautyAnchorName.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
    
            System.out.println("美女主播------>"+BeautyAnchorName +"<-----姗姗来迟，妩媚动人、艳惊四座...开启直播不归路......");
    
        }
    
        /**
         * 直播
         */
        public void liveBroadcast(String BeautyAnchorName) throws InterruptedException{
            System.out.println("美女主播------->"+BeautyAnchorName+"<--------"+"开始直播LOL兔女狼上单5杀....");
            Thread.sleep(Long.MAX_VALUE);
        }
    
        /**
         * 开启直播
         */
        public static void main(String[] args) throws Exception{
            HappyRoom happyRoom = new HappyRoom();
            happyRoom.singIn(args[0]);
            happyRoom.liveBroadcast(args[0]);
    
        }
    }

package happy;
    
    
    import org.apache.zookeeper.WatchedEvent;
    import org.apache.zookeeper.Watcher;
    import org.apache.zookeeper.ZooKeeper;
    
    import java.util.ArrayList;
    import java.util.Collection;
    import java.util.List;
    import java.util.Random;
    
    /**
     * 天上人间直播VIP客户
     */
    public class Player {
    
        /**
         *
         *
         * 采帅哥的小蘑菇
         * ゛男人不狠、江山不稳↘
         * 百厮不得骑姐
         *
         *  爱上 我、你会上瘾
         *  朕要翻你的牌
         *  你姐我Gay你咋的了 ？
         *
         * 尼爸帅得像犀利哥
         *
         * 帅先森
         *
         * 别动姐滴爷△
         *
         * 社会哥 @
         *
         * 韩国技美小璐姐
         *
         * 哼，姐就這樣，誰都管不著
         *
         * 男人千千万姐要不爽天天换
         */
    
        volatile List<String> BeautyAnchor = null;
    
        ArrayList<String> VIP = new ArrayList<String>();
    
        //zookeeper集群地址
        private static String connectServerList = "192.168.220.130:2181,192.168.220.131:2181,192.168.220.132:2181";
    
        //连接超时时间
        private static int sessionTimeout = 20000;
    
        //zookeeper客户端
        public static ZooKeeper zk = null;
    
        //天上人间主播平台
        private static final String anchor = "/anchor";
    
    
        public Player(){
    
            VIP.add("゛男人不狠、江山不稳↘");
            VIP.add("百厮不得骑姐");
            VIP.add("爱上我、你会上瘾");
            VIP.add("朕要翻你的牌");
            VIP.add("你姐我Gay你咋的了？");
            VIP.add("尼爸帅得像犀利哥");
            VIP.add("帅先森");
            VIP.add("别动姐滴爷△");
            VIP.add("社会哥@");
            VIP.add("韩国技美小璐姐");
            VIP.add("哼，姐就這樣，誰都管不著");
            VIP.add("男人千千万姐要不爽天天换");
        }
    
    
        /**
         * 查看在线美女主播
         */
        public void viewBeautyAnchor() throws Exception{
            zk = new ZooKeeper(connectServerList, sessionTimeout, new Watcher() {
                public void process(WatchedEvent watchedEvent) {
                    try {
                        refresh();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            });
            refresh();
        }
    
    
    
        /**
         * VIP客户打赏主播
         */
        public void VIPReward(){
    
            Random random = new Random();
            int n = random.nextInt(VIP.size());
            String VIPName = VIP.get(n);
    
            int m = random.nextInt(BeautyAnchor.size());
            String BeautyAnchorName = BeautyAnchor.get(m);
            System.out.println("VIP客户-->    "+VIPName+" ======> 打赏主播-->  "+BeautyAnchorName+"  --->  一架飞机，一辆跑车，一部游艇");
    
        }
    
        /**
         * 刷新在线美女主播列表
         */
        public void refresh() throws Exception{
            ArrayList<String> onlineBeautyAnchor = new ArrayList<String>();
            List<String> AnchorList = zk.getChildren(anchor, true);
            for (String Anchor: AnchorList ) {
                byte[] BeautyAnchor = zk.getData(anchor + "/" + Anchor, false, null);
                String BeautyAnchorName = new String(BeautyAnchor,"GBK");
                onlineBeautyAnchor.add(BeautyAnchorName);
                System.out.println("<---------------当前在线美女主播有----->"+BeautyAnchorName);
            }
    
            BeautyAnchor = onlineBeautyAnchor;
            System.out.println("=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==");
        }
    
    
        public static void main(String[] args) throws Exception {
            Player player = new Player();
            player.viewBeautyAnchor();
            player.VIPReward();
            Thread.sleep(Long.MAX_VALUE);
        }
    }

启动多台服务器：

D:\\>java -jar BeautyAnchor.jar 甜馨儿  
2019-07-30 00:05:48,760 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT  
2019-07-30 00:05:48,760 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:host.name=DESKTOP-RALNSM7  
2019-07-30 00:05:48,760 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.version=1.8.0\_111  
2019-07-30 00:05:48,761 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.vendor=Oracle Corporation  
2019-07-30 00:05:48,761 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.home=D:\\JAVA\\jre  
2019-07-30 00:05:48,761 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.class.path=BeautyAnchor.jar  
2019-07-30 00:05:48,761 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.library.path=D:\\JAVA\\bin;C:\\Windows\\Sun\\Java\\bin;C:\\Windows\\system32;C:\\Windows;D:\\JAVA\\bin;D:\\JAVA\\jre\\binC:\\ProgramData\\Oracle\\Java\\javapath;D:\\Hadoop\_2.7.2dev\\hadoop-2.7.2\\bin;D:\\Hadoop\_2.7.2dev\\hadoop-2.7.2\\sbin;C:\\Windows\\system32;C:\\Windows;C:\\Windows\\System32\\Wbem;C:\\Windows\\System32\\WindowsPowerShell\\v1.0\\;D:\\devSoftware\\python27;D:\\devSoftware\\python36\\;D:\\devSoftware\\bin;D:\\MAVEN\\apache-maven-3.5.0\\bin;D:\\devSoftware\\Scripts\\;D:\\devSoftware\\;D:\\devSoftware\\python36\\Scripts\\;D:\\osSoftware\\;.  
2019-07-30 00:05:48,761 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.io.tmpdir=C:\\Users\\lsh\\AppData\\Local\\Temp\\  
2019-07-30 00:05:48,761 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.compiler=<NA>  
2019-07-30 00:05:48,762 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.name=Windows 10  
2019-07-30 00:05:48,762 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.arch=amd64  
2019-07-30 00:05:48,762 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.version=10.0  
2019-07-30 00:05:48,762 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.name=lsh  
2019-07-30 00:05:48,762 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.home=C:\\Users\\lsh  
2019-07-30 00:05:48,762 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.dir=D:\\  
2019-07-30 00:05:48,763 INFO \[org.apache.zookeeper.ZooKeeper\] - Initiating client connection, connectString=192.168.220.130:2181,192.168.220.131:2181,192.168.220.132:2181 sessionTimeout=20000 watcher=null  
2019-07-30 00:05:48,865 INFO \[org.apache.zookeeper.ClientCnxn\] - Opening socket connection to server 192.168.220.130/192.168.220.130:2181. Will not attempt to authenticate using SASL (unknown error)  
2019-07-30 00:05:48,868 INFO \[org.apache.zookeeper.ClientCnxn\] - Socket connection established to 192.168.220.130/192.168.220.130:2181, initiating session  
2019-07-30 00:05:48,880 INFO \[org.apache.zookeeper.ClientCnxn\] - Session establishment complete on server 192.168.220.130/192.168.220.130:2181, sessionid = 0x16b29c2ee08000b, negotiated timeout = 20000  
2019-07-30 00:05:48,882 ERROR \[org.apache.zookeeper.ClientCnxn\] - Error while calling watcher  
java.lang.NullPointerException  
at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:530)  
at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:505)  
美女主播------>甜馨儿<-----姗姗来迟，妩媚动人、艳惊四座...开启直播不归路......  
美女主播------->甜馨儿<--------开始直播LOL兔女狼上单5杀....

D:\\>java -jar BeautyAnchor.jar 向未来奋斗的励志人  
2019-07-30 00:08:52,252 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT  
2019-07-30 00:08:52,253 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:host.name=DESKTOP-RALNSM7  
2019-07-30 00:08:52,253 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.version=1.8.0\_111  
2019-07-30 00:08:52,253 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.vendor=Oracle Corporation  
2019-07-30 00:08:52,253 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.home=D:\\JAVA\\jre  
2019-07-30 00:08:52,253 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.class.path=BeautyAnchor.jar  
2019-07-30 00:08:52,253 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.library.path=D:\\JAVA\\bin;C:\\Windows\\Sun\\Java\\bin;C:\\Windows\\system32;C:\\Windows;D:\\JAVA\\bin;D:\\JAVA\\jre\\binC:\\ProgramData\\Oracle\\Java\\javapath;D:\\Hadoop\_2.7.2dev\\hadoop-2.7.2\\bin;D:\\Hadoop\_2.7.2dev\\hadoop-2.7.2\\sbin;C:\\Windows\\system32;C:\\Windows;C:\\Windows\\System32\\Wbem;C:\\Windows\\System32\\WindowsPowerShell\\v1.0\\;D:\\devSoftware\\python27;D:\\devSoftware\\python36\\;D:\\devSoftware\\bin;D:\\MAVEN\\apache-maven-3.5.0\\bin;D:\\devSoftware\\Scripts\\;D:\\devSoftware\\;D:\\devSoftware\\python36\\Scripts\\;D:\\osSoftware\\;.  
2019-07-30 00:08:52,254 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.io.tmpdir=C:\\Users\\lsh\\AppData\\Local\\Temp\\  
2019-07-30 00:08:52,254 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.compiler=<NA>  
2019-07-30 00:08:52,254 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.name=Windows 10  
2019-07-30 00:08:52,254 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.arch=amd64  
2019-07-30 00:08:52,254 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.version=10.0  
2019-07-30 00:08:52,254 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.name=lsh  
2019-07-30 00:08:52,255 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.home=C:\\Users\\lsh  
2019-07-30 00:08:52,255 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.dir=D:\\  
2019-07-30 00:08:52,255 INFO \[org.apache.zookeeper.ZooKeeper\] - Initiating client connection, connectString=192.168.220.130:2181,192.168.220.131:2181,192.168.220.132:2181 sessionTimeout=20000 watcher=null  
2019-07-30 00:08:52,354 INFO \[org.apache.zookeeper.ClientCnxn\] - Opening socket connection to server 192.168.220.130/192.168.220.130:2181. Will not attempt to authenticate using SASL (unknown error)  
2019-07-30 00:08:52,356 INFO \[org.apache.zookeeper.ClientCnxn\] - Socket connection established to 192.168.220.130/192.168.220.130:2181, initiating session  
2019-07-30 00:08:52,364 INFO \[org.apache.zookeeper.ClientCnxn\] - Session establishment complete on server 192.168.220.130/192.168.220.130:2181, sessionid = 0x16b29c2ee08000c, negotiated timeout = 20000  
美女主播------>向未来奋斗的励志人<-----姗姗来迟，妩媚动人、艳惊四座...开启直播不归路......  
美女主播------->向未来奋斗的励志人<--------开始直播LOL兔女狼上单5杀....  
2019-07-30 00:08:52,366 ERROR \[org.apache.zookeeper.ClientCnxn\] - Error while calling watcher  
java.lang.NullPointerException  
at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:530)  
at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:505)

D:\\>java -jar BeautyAnchor.jar 恋爱请排队  
2019-07-30 00:10:21,794 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT  
2019-07-30 00:10:21,794 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:host.name=DESKTOP-RALNSM7  
2019-07-30 00:10:21,794 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.version=1.8.0\_111  
2019-07-30 00:10:21,794 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.vendor=Oracle Corporation  
2019-07-30 00:10:21,794 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.home=D:\\JAVA\\jre  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.class.path=BeautyAnchor.jar  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.library.path=D:\\JAVA\\bin;C:\\Windows\\Sun\\Java\\bin;C:\\Windows\\system32;C:\\Windows;D:\\JAVA\\bin;D:\\JAVA\\jre\\binC:\\ProgramData\\Oracle\\Java\\javapath;D:\\Hadoop\_2.7.2dev\\hadoop-2.7.2\\bin;D:\\Hadoop\_2.7.2dev\\hadoop-2.7.2\\sbin;C:\\Windows\\system32;C:\\Windows;C:\\Windows\\System32\\Wbem;C:\\Windows\\System32\\WindowsPowerShell\\v1.0\\;D:\\devSoftware\\python27;D:\\devSoftware\\python36\\;D:\\devSoftware\\bin;D:\\MAVEN\\apache-maven-3.5.0\\bin;D:\\devSoftware\\Scripts\\;D:\\devSoftware\\;D:\\devSoftware\\python36\\Scripts\\;D:\\osSoftware\\;.  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.io.tmpdir=C:\\Users\\lsh\\AppData\\Local\\Temp\\  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:java.compiler=<NA>  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.name=Windows 10  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.arch=amd64  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:os.version=10.0  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.name=lsh  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.home=C:\\Users\\lsh  
2019-07-30 00:10:21,795 INFO \[org.apache.zookeeper.ZooKeeper\] - Client environment:user.dir=D:\\  
2019-07-30 00:10:21,796 INFO \[org.apache.zookeeper.ZooKeeper\] - Initiating client connection, connectString=192.168.220.130:2181,192.168.220.131:2181,192.168.220.132:2181 sessionTimeout=20000 watcher=null  
2019-07-30 00:10:21,894 INFO \[org.apache.zookeeper.ClientCnxn\] - Opening socket connection to server 192.168.220.132/192.168.220.132:2181. Will not attempt to authenticate using SASL (unknown error)  
2019-07-30 00:10:21,895 INFO \[org.apache.zookeeper.ClientCnxn\] - Socket connection established to 192.168.220.132/192.168.220.132:2181, initiating session  
2019-07-30 00:10:21,903 INFO \[org.apache.zookeeper.ClientCnxn\] - Session establishment complete on server 192.168.220.132/192.168.220.132:2181, sessionid = 0x36b28a6cb09000b, negotiated timeout = 20000  
2019-07-30 00:10:21,905 ERROR \[org.apache.zookeeper.ClientCnxn\] - Error while calling watcher  
java.lang.NullPointerException  
at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:530)  
at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:505)  
美女主播------>恋爱请排队<-----姗姗来迟，妩媚动人、艳惊四座...开启直播不归路......  
美女主播------->恋爱请排队<--------开始直播LOL兔女狼上单5杀....

客户端：

<---------------当前在线美女主播有----->閲囧竻鍝ョ殑灏忚槕鑿�  
<---------------当前在线美女主播有----->閲囧竻鍝ョ殑灏忚槕鑿�  
<---------------当前在线美女主播有----->甜馨儿  
=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==

<---------------当前在线美女主播有----->甜馨儿  
=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==

VIP客户--> 社会哥@ ======> 打赏主播--> 甜馨儿 ---> 一架飞机，一辆跑车，一部游艇  
<---------------当前在线美女主播有----->向未来奋斗的励志人  
<---------------当前在线美女主播有----->閲囧竻鍝ョ殑灏忚槕鑿�  
<---------------当前在线美女主播有----->甜馨儿  
=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==

<---------------当前在线美女主播有----->向未来奋斗的励志人  
<---------------当前在线美女主播有----->无辜的黄瓜  
<---------------当前在线美女主播有----->閲囧竻鍝ョ殑灏忚槕鑿�  
<---------------当前在线美女主播有----->甜馨儿  
=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==

<---------------当前在线美女主播有----->向未来奋斗的励志人  
<---------------当前在线美女主播有----->无辜的黄瓜  
<---------------当前在线美女主播有----->恋爱请排队  
<---------------当前在线美女主播有----->閲囧竻鍝ョ殑灏忚槕鑿�  
<---------------当前在线美女主播有----->甜馨儿  
=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==

\#\#\#\#\#\#\#\#\#\#\#\#无辜的黄瓜     退出后客户端马上获取到最新的主播列表    \#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#\#

<---------------当前在线美女主播有----->向未来奋斗的励志人  
<---------------当前在线美女主播有----->恋爱请排队  
<---------------当前在线美女主播有----->閲囧竻鍝ョ殑灏忚槕鑿�  
<---------------当前在线美女主播有----->甜馨儿  
=嗨翻世界！i===嗨翻世界！i======嗨翻世界！i==========嗨翻世界！i====嗨翻世界！i==

转载于:https://www.cnblogs.com/itBulls/articles/11267391.html