直播功能

Author: danbai225

.idea/workspace.xml

@@ -17,7 +17,8 @@
 + 观看看影视的同时能发送弹幕
 + 跨平台同步观看历史记录
 + 跨平台同步观看进度
-+ 电视直播(开发中)
++ 电视直播
+
 ## 项目所用到的
 
 + Spring Boot
@@ -27,15 +28,22 @@
 + Docker
 ## 版本内容更新
 ### 2019-10-20
+
 + 弹幕获取功能,不用担心一个人看没弹幕啦,在一些人气较高的影视会自动获取弹幕
 + 修复注册邮箱发送问题
+
 ### 2019-11-4
+
 + 更新搜索功能支持演员、导演搜索影视
 + 弹幕tagid获取将不在服务器而是py采集
 + 影视信息补全
 + 配置功能
-## 计划开发功能
+### 2019-11-6
+
 + 电视直播功能
+
+## 计划开发功能
+
 + 影视增加评论、评分功能
 + 弹幕管理
 + 淡白影视APP(开发中)

README.md

@@ -83,6 +83,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-mongodb</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-websocket</artifactId>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

pom.xml

@@ -0,0 +1,52 @@
+package com.danbai.ys.async;
+
+import com.danbai.ys.websocket.TvDmSocket;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+
+/**
+ * @author danbai
+ * @date 2019-11-04 21:36
+ */
+@Component
+public class AsyncDmAllSend {
+    /**
+     * 群发自定义消息
+     * */
+    @Async
+    public void sendInfo(String message) throws IOException {
+        for (TvDmSocket item : TvDmSocket.webSocketSet) {
+            try {
+                item.sendMessage(message);
+            } catch (IOException e) {
+                continue;
+            }
+        }
+    }
+    @Async
+    public void sendInfo(String message,String dmid) throws IOException {
+        for (TvDmSocket item : TvDmSocket.webSocketSet) {
+            if(item.getDmid().equals(dmid)){
+                try {
+                    item.sendMessage(message);
+                } catch (IOException e) {
+                    continue;
+                }
+            }
+        }
+    }
+    @Async
+    public void sendInfoNothis(String message,String dmid,TvDmSocket t) throws IOException {
+        for (TvDmSocket item : TvDmSocket.webSocketSet) {
+            if(item.getDmid().equals(dmid)&item!=t){
+                try {
+                    item.sendMessage(message);
+                } catch (IOException e) {
+                    continue;
+                }
+            }
+        }
+    }
+}

src/main/java/com/danbai/ys/async/AsyncDmAllSend.java

@@ -23,7 +23,7 @@ public void addInterceptors(InterceptorRegistry registry) {
     @Override
     public void addCorsMappings(CorsRegistry registry) {
         registry.addMapping("/**")
-                .allowedOrigins("http://m.dbys.vip", "https://dbys.vip")
+                .allowedOrigins("http://m.dbys.vip", "https://dbys.vip","null")
                 .allowedMethods("POST", "GET", "PUT", "OPTIONS", "DELETE")
                 .maxAge(3600)
                 .allowCredentials(true);

src/main/java/com/danbai/ys/config/MyWebAppConfigurer.java

@@ -0,0 +1,21 @@
+package com.danbai.ys.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.TaskScheduler;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+
+/**
+ * @author danbai
+ * @date 2019-11-04 20:41
+ */
+@Configuration
+public class ScheduledConfig {
+    @Bean
+    public TaskScheduler taskScheduler(){
+        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
+        taskScheduler.setPoolSize(20);
+        taskScheduler.initialize();
+        return taskScheduler;
+    }
+}

src/main/java/com/danbai/ys/config/ScheduledConfig.java

@@ -0,0 +1,17 @@
+package com.danbai.ys.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.socket.server.standard.ServerEndpointExporter;
+
+/**
+ * @author danbai
+ * @date 2019-11-04 21:06
+ */
+@Configuration
+public class WebsocketAutoConfig {
+    @Bean
+    public ServerEndpointExporter endpointExporter() {
+        return new ServerEndpointExporter();
+    }
+}

src/main/java/com/danbai/ys/config/WebsocketAutoConfig.java

@@ -3,16 +3,26 @@
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.danbai.ys.entity.*;
+import com.danbai.ys.service.YsService;
 import com.danbai.ys.service.impl.AdminServiceImpl;
 import com.danbai.ys.service.impl.YsServiceImpl;
+import com.danbai.ys.utils.HtmlUtils;
 import com.github.pagehelper.PageInfo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.OutputStream;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -118,7 +128,11 @@ String dsj(int page, Model model) {
         model.addAttribute("page", page);
         return "type/dsj";
     }
-
+    @RequestMapping(value = "/type/tv", produces = "text/plain;charset=UTF-8", method = RequestMethod.GET)
+    String dsj(Model model) {
+        model.addAttribute("tvs",ysService.getAllTv());
+        return "type/tv";
+    }
     @RequestMapping(value = "/type/dm", produces = "text/plain;charset=UTF-8", method = RequestMethod.GET)
     String dm(int page, Model model) {
         PageInfo page1 = ysService.getYs("动漫", page, 24);

src/main/java/com/danbai/ys/controller/YsController.java

@@ -31,7 +31,6 @@ public BaseResult ys() {
 
     /**
      * 根据id获取影视
-     *
      * @param id 影视id
      * @return BaseResult
      */
@@ -50,5 +49,8 @@ public BaseResult ysOne(@PathVariable int id) {
     public BaseResult search(@PathVariable String gjc) {
         return ResultUtil.success(ysService.qcsy(ysService.selectYsByGjc(gjc)));
     }
-
+    @GetMapping("/ys/tv")
+    public BaseResult tv(){
+        return ResultUtil.success(ysService.getAllTv());
+    }
 }

src/main/java/com/danbai/ys/controller/restful/v1/Ys.java

@@ -1,6 +1,6 @@
 package com.danbai.ys.entity;
 
-/**
+/**统计类
  * @author danbai
  * @date 2019-10-18 12:30
  */