package cn.mccreefei.web;
import cn.mccreefei.enums.MessageTypeEnum;
import cn.mccreefei.model.Message;
import cn.mccreefei.model.MessageRecordDo;
import cn.mccreefei.model.User;
import cn.mccreefei.service.UserService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Date;
/**
* 发送消息控制器
*/
@Controller
public class MessageController {
private Logger logger = LoggerFactory.getLogger(this.getClass());
private static final String SUBSCRIBE_MESSAGE_URI = "/topic/chat/message"; //订阅接收消息地址
private static final String IMAGE_PREFIX = "/resources/media/image/"; //服务器储存上传图片地址的前缀
@Autowired
private SimpMessagingTemplate messagingTemplate;
@Autowired
private UserService userService;
/**
* 接收并且转发消息
* @param message
*/
@MessageMapping("/chat/message")
public void receiveMessage(Message message){
message.setSendDate(new Date());
message.setMessageType("text");
logger.info(message.getSendDate() + "," + message.getUserName() + " send a message:" + message.getContent());
//保存聊天信息
User userByName = userService.getUserByName(message.getUserName());
MessageRecordDo messageRecordDo = MessageRecordDo.messageRecordBuilder()
.userId(userByName == null ? null : userByName.getId())
.userName(message.getUserName()).content(message.getContent())
.messageType(MessageTypeEnum.TEXT.getCode()).createTime(new Date()).build();
userService.addUserMessageRecord(messageRecordDo);
messagingTemplate.convertAndSend(SUBSCRIBE_MESSAGE_URI, message);
}
/**
* 接收转发图片
* @param request
* @param imageFile
* @param userName
* @return
*/
@RequestMapping(value = "/upload/image", method = RequestMethod.POST)
@ResponseBody
public String handleUploadImage(HttpServletRequest request, @RequestParam("image")MultipartFile imageFile,
@RequestParam("userName")String userName){
if (!imageFile.isEmpty()){
String imageName = userName + "_" + (int)(Math.random() * 1000000) + ".jpg";
String path = request.getSession().getServletContext().getRealPath(IMAGE_PREFIX) +"/" + imageName;
File localImageFile = new File(path);
try {
//上传图片到目录
byte[] bytes = imageFile.getBytes();
BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(localImageFile));
bufferedOutputStream.write(bytes);
bufferedOutputStream.close();
Message message = new Message();
message.setMessageType("image");
message.setUserName(userName);
message.setSendDate(new Date());
message.setContent(request.getContextPath() + IMAGE_PREFIX + imageName);
//保存发送图片信息
User userByName = userService.getUserByName(message.getUserName());
MessageRecordDo messageRecordDo = MessageRecordDo.messageRecordBuilder()
.userId(userByName == null ? null : userByName.getId())
.userName(userName).content(message.getContent())
.messageType(MessageTypeEnum.IMAGE.getCode()).createTime(new Date()).build();
userService.addUserMessageRecord(messageRecordDo);
messagingTemplate.convertAndSend(SUBSCRIBE_MESSAGE_URI, message);
} catch (IOException e) {
logger.error("图片上传失败:" + e.getMessage(), e);
return "upload false";
}
}
return "upload success";
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
别再对比了,资源中的源码都是经过本地编译过可运行的,下载后按照文档配置好环境就可以运行。资源项目的难度比较适中,内容都是经过助教老师审定过的,能够满足使用、学习需求,如果有需要的话可以放心下载使用。有任何问题也可以直接私信博主,博主会第一时间给您解答!!! 别再对比了,资源中的源码都是经过本地编译过可运行的,下载后按照文档配置好环境就可以运行。资源项目的难度比较适中,内容都是经过助教老师审定过的,能够满足使用、学习需求,如果有需要的话可以放心下载使用。有任何问题也可以直接私信博主,博主会第一时间给您解答!!! 别再对比了,资源中的源码都是经过本地编译过可运行的,下载后按照文档配置好环境就可以运行。资源项目的难度比较适中,内容都是经过助教老师审定过的,能够满足使用、学习需求,如果有需要的话可以放心下载使用。有任何问题也可以直接私信博主,博主会第一时间给您解答!!!
资源推荐
资源详情
资源评论
收起资源包目录
基于SSM+Websocket的实时在线聊天室项目源码.zip (112个子文件)
sweetalert.css 22KB
login.css 5KB
main.css 1KB
68.gif 39KB
54.gif 34KB
55.gif 33KB
66.gif 31KB
67.gif 29KB
63.gif 28KB
29.gif 27KB
43.gif 25KB
11.gif 24KB
56.gif 24KB
52.gif 23KB
23.gif 15KB
53.gif 15KB
28.gif 14KB
6.gif 14KB
12.gif 14KB
5.gif 14KB
4.gif 14KB
64.gif 14KB
65.gif 14KB
10.gif 13KB
33.gif 13KB
60.gif 13KB
7.gif 13KB
2.gif 12KB
69.gif 12KB
16.gif 12KB
19.gif 12KB
45.gif 12KB
62.gif 12KB
9.gif 11KB
21.gif 11KB
38.gif 11KB
48.gif 11KB
25.gif 11KB
59.gif 11KB
49.gif 10KB
13.gif 10KB
26.gif 9KB
47.gif 9KB
41.gif 9KB
34.gif 8KB
24.gif 8KB
15.gif 8KB
36.gif 8KB
8.gif 8KB
32.gif 8KB
1.gif 8KB
3.gif 7KB
17.gif 7KB
22.gif 7KB
51.gif 6KB
18.gif 6KB
40.gif 6KB
61.gif 6KB
58.gif 6KB
57.gif 6KB
27.gif 6KB
20.gif 6KB
14.gif 5KB
31.gif 5KB
42.gif 5KB
50.gif 4KB
37.gif 4KB
44.gif 4KB
46.gif 4KB
39.gif 4KB
35.gif 4KB
30.gif 2KB
.gitignore 268B
favicon.ico 203KB
MessageController.java 4KB
LoginController.java 4KB
MessageRecordDo.java 3KB
WebSocketDisconnectHandler.java 3KB
LoginInfoDo.java 2KB
WebSocketConfig.java 2KB
UserDAOTest.java 2KB
UserServiceImpl.java 1KB
Message.java 1KB
User.java 1KB
ReplyLoginMessage.java 1KB
ParticipantRepository.java 940B
UserDAO.java 899B
UserService.java 875B
ReplyRegistMessage.java 860B
LoginTypeEnum.java 432B
MessageTypeEnum.java 431B
MessageRecordDAO.java 230B
LoginInfoDAO.java 210B
chris_619283.jpg 260KB
1.jpg 182KB
sweetalert.min.js 17KB
chatroom.js 8KB
login.js 7KB
index.jsp 5KB
chatroom.jsp 3KB
共 112 条
- 1
- 2
资源评论
白话机器学习
- 粉丝: 8213
- 资源: 7687
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- Flume进阶-自定义拦截器jar包
- Dubins曲线算法讲解和在运动规划中的使用.pdf
- 上市公司-股票性质数据-工具变量(民企、国企、央企)2003-2022年.dta
- 上市公司-股票性质数据-工具变量(民企、国企、央企)2003-2022年.xlsx
- Reeds+Shepp曲线算法讲解和实现.pdf
- 毕业设计基于SpringBoot+MyBatisPlus+MySQL+Vue的外卖配送信息系统源代码+数据库
- 词向量(Word Embeddings)是自然语言处理(NLP)领域的一种重要技术.txt
- Surfer,线性函数
- MyBatis 的动态 SQL 是其核心特性之一.txt
- 时代的sdddsddsddsd
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功