五月婷婷丁香性爱|j久久一级免费片|久久美女福利视频|中文观看在线观看|加勒比四区三区二|亚洲裸女视频网站|超碰97AV在线69网站免费观看|有码在线免费视频|久久青青日本视频|亚洲国产AAAA

實(shí)施步驟

1. 在服務(wù)器上運(yùn)行Eclipse，單擊“File>New Project”創(chuàng)建一個(gè)java工程，并將jedis客戶端作為library引用到工程中。
2. 單擊“New>Class”創(chuàng)建一個(gè)VideoBulletScreenDemo.java文件。
3. 將以下示例代碼復(fù)制到VideoBulletScreenDemo.java文件中。

    

   • 視頻直播 彈幕代碼示例

     package org.example.task;
      
     import java.util.ArrayList;
     import java.util.List;
     import java.util.Set;
     import java.util.UUID;
      
     import redis.clients.jedis.Jedis;
     import redis.clients.jedis.Tuple;
      
     public class VideoBulletScreenDemo {
      
         static final int MESSAGE_NUM = 30;
      
         public static void main(String[] args) {
      
             // Redis實(shí)例連接地址和端口，需替換為實(shí)際獲取的值
             String host = "127.0.0.1";
             int port = 6379;
      
             Jedis jedisClient = new Jedis(host,port);
      
             try {
                 // Redis實(shí)例連接密碼，需替換為實(shí)際獲取的值
                 String authMsg = jedisClient.auth("******");
      
                 if (!authMsg.equals("OK")){
                     System.out.println("AUTH FAILED: " + authMsg);
                 }
      
                 String key = "直播彈幕列表";
      
                 jedisClient.del(key);
      
                 // 隨機(jī)生成彈幕消息
                 List<String> messageList = new ArrayList<>();
                 for (int i = 0; i < MESSAGE_NUM; i++){
                     messageList.add("message-" + UUID.randomUUID().toString());
                 }
      
                 // 隨機(jī)生成消息的時(shí)間戳
                 for (int i = 0; i < messageList.size(); i++){
                     String message = messageList.get(i);
                     int sales = (int)(Math.random()*1000);
                     long time = System.currentTimeMillis() + sales;
                     // 插入redis的sortedSet中
                     jedisClient.zadd(key,time,message);
                 }
      
                 System.out.println("    " + key);
      
                 // 獲取所有列表并按時(shí)間先后順序輸出
                 Set<Tuple> sortedMessageList  = jedisClient.zrangeWithScores(key, 0, -1);
                 for (Tuple message : sortedMessageList){
                     System.out.println("彈幕內(nèi)容: " + message.getElement() + ", 發(fā)送時(shí)間: " + Double.valueOf(message.getScore()).longValue());
                 }
      
      
                 System.out.println();
                 System.out.println("    最新的5條彈幕信息");
      
                 Set<Tuple> sortedTopList = jedisClient.zrevrangeWithScores(key,0,4);
                 for (Tuple product : sortedTopList){
                     System.out.println("彈幕內(nèi)容: " + product.getElement() + ", 發(fā)送時(shí)間: " + Double.valueOf(product.getScore()).longValue());
                 }
             } catch (Exception e) {
                 e.printStackTrace();
             } finally {
                 jedisClient.quit();
                 jedisClient.close();
             }
      
         }
      
     }

      
   • 社交網(wǎng)站評論回復(fù)代碼示例

     package org.example.task;
     import java.util.ArrayList;
     import java.util.HashMap;
     import java.util.List;
     import java.util.Set;
     import java.util.UUID;
     import redis.clients.jedis.Jedis;
     import redis.clients.jedis.Tuple;
     public class SiteCommentsDemo {
         // 評論 + 回復(fù) 總數(shù)
         static final  int COMMENT_NUM = 20;
         public static void main(String[] args) {
             // Redis實(shí)例連接地址和端口，需替換為實(shí)際獲取的值
             String host = "127.0.0.1";
             int port = 6379;
     
             Jedis jedisClient = new Jedis(host,port);
             try {
                 // Redis實(shí)例連接密碼，需替換為實(shí)際獲取的值
                 String authMsg = jedisClient.auth("******");
                 if (!authMsg.equals("OK")){
                     System.out.println("AUTH FAILED: " + authMsg);
                 }
                 String key = "社交網(wǎng)站評論回復(fù)列表";
                 jedisClient.del(key);
                 HashMap<Integer, Comment> map = new HashMap<>();
                 // 隨機(jī)生成評論回復(fù)數(shù)據(jù)對象
                 List<Comment> commentList = new ArrayList<>();
                 for (int i = 0; i < COMMENT_NUM; i++){
                     Comment comment = new Comment();
                     comment.setId(i+1);
                     comment.setContent(UUID.randomUUID().toString().substring(0,8));
                     long time = System.currentTimeMillis();
                     Thread.sleep(50);
                     comment.setTime(time);
                     // 隨機(jī)生成回復(fù)
                     if (i > 0 && Math.random() < 0.5){
                         comment.setParentId((int)(Math.random()*i) + 1);
                     }
                     commentList.add(comment);
                     map.put(comment.getId(),comment);
                     // 插入redis的sortedSet中
                     jedisClient.zadd(key,time,String.valueOf(comment.getId()));
                 }
                 System.out.println("    " + key);
                 // 獲取所有列表并按時(shí)間先后順序輸出
                 Set<Tuple> sortedCommentList  = jedisClient.zrangeWithScores(key, 0, -1);
                 for (Tuple comment : sortedCommentList){
                     Integer commentId = Integer.valueOf(comment.getElement());
                     Comment tmpComment = map.get(commentId);
                     System.out.println("評論id: " + comment.getElement() + " 評論父id：" + tmpComment.getParentId() + ", 評論時(shí)間: " + Double.valueOf(comment.getScore()).longValue());
                 }
                 System.out.println();
                 System.out.println("    最新的5條評論回復(fù)信息");
                 Set<Tuple> sortedTopList = jedisClient.zrevrangeWithScores(key,0,4);
                 for (Tuple comment : sortedTopList){
                     Integer commentId = Integer.valueOf(comment.getElement());
                     Comment tmpComment = map.get(commentId);
                     if (tmpComment.getParentId() != null){
                         System.out.println("評論id: " + comment.getElement() + " 回復(fù):" + tmpComment.getParentId()  + " 評論內(nèi)容:" + tmpComment.getContent() + ", 評論時(shí)間: " + Double.valueOf(comment.getScore()).longValue());
                     }else {
                         System.out.println("評論id: " + comment.getElement() + ", 評論時(shí)間: " + Double.valueOf(comment.getScore()).longValue());
                     }
                 }
             } catch (Exception e) {
                 e.printStackTrace();
             } finally {
                 jedisClient.quit();
                 jedisClient.close();
             }
         }
         /**
          * 評論數(shù)據(jù)對象
          */
         static class Comment{
             // 評論id
             private Integer id;
             // 評論內(nèi)容
             private String content;
             // 評論時(shí)間
             private Long time;
             // 父評論id,針對回復(fù)評論
             private Integer parentId;
             public Integer getId() {
                 return id;
             }
             public void setId(Integer id) {
                 this.id = id;
             }
             public String getContent() {
                 return content;
             }
             public void setContent(String content) {
                 this.content = content;
             }
             public Long getTime() {
                 return time;
             }
             public void setTime(Long time) {
                 this.time = time;
             }
             public Integer getParentId() {
                 return parentId;
             }
             public void setParentId(Integer parentId) {
                 this.parentId = parentId;
             }
         }
     }

      

    

4. 將DCS緩存實(shí)例的連接地址、端口以及連接密碼配置到代碼示例中。
5. 編譯并運(yùn)行得到結(jié)果。