java版本使用springboot vue websocket webrtc实现视频通话
创始人
2024-11-19 06:08:11
0

使用java版本 websocket webrtc实现视频通话

  • 原理简单解释
  • 使用技术
  • 搭建websocket环境依赖
  • 最终演示效果

原理简单解释

​ 浏览器提供获取屏幕、音频等媒体数据的接口,

​ 双方的媒体流数据通过Turn服务器传输

websocket传递信令服务

使用技术

  1. java jdk17
  2. springboot 3.2.2
  3. websocket
  4. 前端使用 vue

搭建websocket环境依赖

	                      org.springframework.boot             spring-boot-starter-web                               org.springframework.boot             spring-boot-starter-websocket                                org.springframework.boot             spring-boot-starter-test             test               

websocket的配置类

package com.example.webrtc.config;  import com.example.webrtc.Interceptor.AuthHandshakeInterceptor; import com.example.webrtc.Interceptor.MyChannelInterceptor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.messaging.converter.MessageConverter; import org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver; import org.springframework.messaging.handler.invocation.HandlerMethodReturnValueHandler; import org.springframework.messaging.simp.config.ChannelRegistration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; import org.springframework.web.socket.config.annotation.*; import org.springframework.web.socket.server.standard.ServerEndpointExporter;  import java.util.List;  @Configuration @EnableWebSocketMessageBroker public class WebSocketConfig extends WebSocketMessageBrokerConfigurationSupport implements WebSocketMessageBrokerConfigurer {     private static final Logger log = LoggerFactory.getLogger(WebSocketConfig.class);      @Autowired     private AuthHandshakeInterceptor authHandshakeInterceptor;       @Autowired     private MyChannelInterceptor myChannelInterceptor;      @Bean     public ServerEndpointExporter serverEndpointExporter(){         return new ServerEndpointExporter();     }      @Override     public void registerStompEndpoints(StompEndpointRegistry registry) {         registry.addEndpoint("/chat-websocket")                 .setAllowedOriginPatterns("*")                 .addInterceptors(authHandshakeInterceptor)                 .setAllowedOriginPatterns("*")              //   .setHandshakeHandler(myHandshakeHandler)                 .withSockJS();     }      @Override     public void configureWebSocketTransport(WebSocketTransportRegistration registry) {             registry.setMessageSizeLimit(Integer.MAX_VALUE);             registry.setSendBufferSizeLimit(Integer.MAX_VALUE);             super.configureWebSocketTransport(registry);     }      @Override     public void configureMessageBroker(MessageBrokerRegistry registry) {         //客户端需要把消息发送到/message/xxx地址         registry.setApplicationDestinationPrefixes("/webSocket");         //服务端广播消息的路径前缀,客户端需要相应订阅/topic/yyy这个地址的消息         registry.enableSimpleBroker("/topic", "/user");         //给指定用户发送消息的路径前缀,默认值是/user/         registry.setUserDestinationPrefix("/user/");     }       @Override     public void configureClientInboundChannel(ChannelRegistration registration) {         registration.interceptors(myChannelInterceptor);     }      @Override     public void configureClientOutboundChannel(ChannelRegistration registration) {         WebSocketMessageBrokerConfigurer.super.configureClientOutboundChannel(registration);     }      @Override     public void addArgumentResolvers(List argumentResolvers) {         WebSocketMessageBrokerConfigurer.super.addArgumentResolvers(argumentResolvers);     }      @Override     public void addReturnValueHandlers(List returnValueHandlers) {         WebSocketMessageBrokerConfigurer.super.addReturnValueHandlers(returnValueHandlers);     }      @Override     public boolean configureMessageConverters(List messageConverters) {         return WebSocketMessageBrokerConfigurer.super.configureMessageConverters(messageConverters);     }  } 

控制层 WebSocketController

package com.example.webrtc.controller;  import com.example.webrtc.config.Message; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.handler.annotation.MessageMapping; import org.springframework.messaging.simp.SimpMessagingTemplate; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController;  import java.security.Principal; import java.util.HashMap; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger;  // 私信聊天的控制器 @RestController public class WebSocketController {     @Autowired     private SimpMessagingTemplate messagingTemplate;     private AtomicInteger i=new AtomicInteger(1);     @RequestMapping("/user")     public String findUser(){         return "00"+i.decrementAndGet();     }     @MessageMapping("/api/chat")     //在springmvc 中可以直接获得principal,principal 中包含当前用户的信息     public void handleChat(Principal principal, Message messagePara) {          String currentUserName = principal.getName();         System.out.println(currentUserName);          try {             messagePara.setFrom(principal.getName());             System.out.println("from" + messagePara.getFrom());             messagingTemplate.convertAndSendToUser(messagePara.getTo(),                     "/queue/notifications",                     messagePara);         } catch (Exception e) {             // 打印异常             e.printStackTrace();         }     } }  

前端交互拨号index.vue

   {{ toUserId + '请求连接!' }}      取 消     确 定         

最终演示效果

在这里插入图片描述

具体代码查看

相关内容

热门资讯

一分钟内幕!科乐吉林麻将系统发... 一分钟内幕!科乐吉林麻将系统发牌规律,福建大玩家确实真的是有挂,技巧教程(有挂ai代打);所有人都在...
一分钟揭秘!微扑克辅助软件(透... 一分钟揭秘!微扑克辅助软件(透视辅助)确实是有挂(2024已更新)(哔哩哔哩);1、用户打开应用后不...
五分钟发现!广东雀神麻雀怎么赢... 五分钟发现!广东雀神麻雀怎么赢,朋朋棋牌都是是真的有挂,高科技教程(有挂方法)1、广东雀神麻雀怎么赢...
每日必看!人皇大厅吗(透明挂)... 每日必看!人皇大厅吗(透明挂)好像存在有挂(2026已更新)(哔哩哔哩);人皇大厅吗辅助器中分为三种...
重大科普!新华棋牌有挂吗(透视... 重大科普!新华棋牌有挂吗(透视)一直是有挂(2021已更新)(哔哩哔哩)1、完成新华棋牌有挂吗的残局...
二分钟内幕!微信小程序途游辅助... 二分钟内幕!微信小程序途游辅助器,掌中乐游戏中心其实存在有挂,微扑克教程(有挂规律)二分钟内幕!微信...
科技揭秘!jj斗地主系统控牌吗... 科技揭秘!jj斗地主系统控牌吗(透视)本来真的是有挂(2025已更新)(哔哩哔哩)1、科技揭秘!jj...
1分钟普及!哈灵麻将攻略小,微... 1分钟普及!哈灵麻将攻略小,微信小程序十三张好像存在有挂,规律教程(有挂技巧)哈灵麻将攻略小是一种具...
9分钟教程!科乐麻将有挂吗,传... 9分钟教程!科乐麻将有挂吗,传送屋高防版辅助(总是存在有挂)1、完成传送屋高防版辅助透视辅助安装,帮...
每日必看教程!兴动游戏辅助器下... 每日必看教程!兴动游戏辅助器下载(辅助)真是真的有挂(2025已更新)(哔哩哔哩)1、打开软件启动之...