Spring boot + LayIM + t-io 文件上传、 监听用户状态的实现


声明:本文转载自https://my.oschina.net/panzi1/blog/1582389,转载目的在于传递更多信息,仅供学习交流之用。如有侵权行为,请联系我,我会及时删除。

前言

    继上篇实现用户登录之后,项目进展缓慢。各种原因吧。昨晚看到一篇挺不错的:https://www.oschina.net/news/91024/qiqi-im-and-layim,LayIM的基础功能基本都实现了。不过我还是继续我的步伐,下面进行今天的内容记录吧。

        今天的主要内容是:LayIM消息中图片,文件的上传对接、用户状态的监听、群在线人数的监听。下面我将挨个介绍。

图片上传

    关于Spring boot中的文件上传的博客很多,我也是摘抄了部分代码。上传部分简单介绍,主要介绍在开发过程中遇到的问题。首先我们看一下LayIM的相应的接口:

 layim.config({     //上传图片接口     ,uploadImage: {url: '/upload/file'}     //上传文件接口     ,uploadFile: {url: '/upload/file'}     //其他代码  })                  

    是的,没错我们只要写两个接口就能实现LayIM中发图片,发文件的功能了,我这里省点事,由于LayIM已经判断了文件类型,所以我这里只用了一个上传接口。返回的格式是酱紫的:

{"code":0,"msg":"success","data":{"src":"/upload/d8740baa-cf7e-497c-a085-5c6ed9633f35.gif","name":"8.gif"}}

    上传代码就很简单了,获取文件后缀,生成guid的名称,保存到相应文件夹下。最后返回LayIM想要的响应数据。

    刚开始想的是直接传到 /resources/static/upload/文件夹下,后来发现上传成功之后访问路径会出现404的情况,原因就是:即使文件夹下有那个文件,但是target相应的文件夹下没有,所以重新编译运行之后才可以,那这样肯定不行。于是我就找解决方案,后来看到这么一种处理方式,就是把每个文件请求也映射到Controller中的一个路径上,然后使用 ResourceLoader 去找响应的文件。代码如下:

     /**      * 上传文件的路径配置      * */     @Value("${layim.upload.dir}")     private String fileDirPath;      private final ResourceLoader resourceLoader;      @Autowired     public UploadController(ResourceLoader resourceLoader){         this.resourceLoader = resourceLoader;     }

    获取文件代码,那么在访问那个文件的时候,指定文件名,Resource就会根据路径返回相应的资源。

 /**      * 访问文件路径,使用resourceLoader获取文件      * */     @GetMapping(value = "/{filename:.+}")     @ResponseBody     public ResponseEntity<?> getFile(@PathVariable String filename) {         try {             String location = "file:"+ Paths.get(fileDirPath, filename).toString();             Resource resource = resourceLoader.getResource(location);             return ResponseEntity.ok(resource);         } catch (Exception e) {             return ResponseEntity.notFound().build();         }     }

    看一下效果:(为了给大家做演示截图的时候遇到上传文件大小限制的问题,配置改一下就可以了。)

  http:         multipart:           max-file-size: 30MB           max-request-size: 30MB

    上文中的代码 value 配置为:filename:.+,这样我们访问路径如果遇到 比如 /abc.jpg 那么就会匹配上 getFile这个方法。然后由ResourceLoader帮我们找文件。不过为了多了解一点,我跟踪了一下源代码。先看一下DefaultResourceLoader中的getResource方法。

@Override 	public Resource getResource(String location) { 		Assert.notNull(location, "Location must not be null");  		for (ProtocolResolver protocolResolver : this.protocolResolvers) { 			Resource resource = protocolResolver.resolve(location, this); 			if (resource != null) { 				return resource; 			} 		}         //我们是使用file:开头的 		if (location.startsWith("/")) { 			return getResourceByPath(location); 		}         //这里判断是不是走 classpath: 		else if (location.startsWith(CLASSPATH_URL_PREFIX)) { 			return new ClassPathResource(location.substring(CLASSPATH_URL_PREFIX.length()), getClassLoader()); 		} 		else { 			try {                  //最后将文件地址转化成了url  				// Try to parse the location as a URL... 				URL url = new URL(location); 				return new UrlResource(url); 			} 			catch (MalformedURLException ex) { 				// No URL -> resolve as resource path. 				return getResourceByPath(location); 			} 		} 	}

    后来在我调试的过程中发现,比如我访问的路径是 /abc.gif,那么他后台就会转换成这个地址:file:///G:/JavaProject/SpringBootLayIM/upload/abc.gif,所以同理,在本机上直接将这个地址打开也是能够访问的。上文中的地址(file:///..)就是 layim.upload.dir 的值。同样,我把文件夹改为resources/static/upload/下同样适用,因为,通过ResourceLoader,他将文件定位到了服务器的物理地址。

   target下甚至连uplaod文件夹都没有,但是文件还是能够访问到

文件上传

    和图片用的是同一个接口,差别在于上传大文件需要改一下配置,上文中已经写到,这里不在详述。

用户在线状态

    在LayIM的状态监听中,有这么一项:

       //监听天窗口的切换         layim.on('chatChange', function(res){             console.log(res.data);                     });

    其实在读取列表的时候就应该要加载用户在线离线状态。不过这里只演示,当窗口切换时候,查一下对面的状态。所以,在触发chatChange事件后,我们向服务器发送一条请求。

 var t = res.data.type=='friend';  socket.send({     mtype:t? socket.mtype.checkIsOnline:socket.mtype.checkOnlineCount,     id:res.data.id  });

    上面有两个情况,第一种单聊的时候,我需要知道对方的状态。第二种,群聊的时候我想知道有多少人在线。所以稍微做了下区分。

    新加两个消息处理类:

    其实判断是否在线的代码如下:

 ChannelContext checkChannelContext =                  Aio.getChannelContextByUserid(channelContext.getGroupContext(),body.getId());  //检查是否在线  boolean isOnline = checkChannelContext != null && !checkChannelContext.isClosed();

    然后封装消息返回给服务器。消息流程在 单聊群聊的实现 中已经介绍过,这里不在赘述。

    判断群里有多少人的方法如下:

 SetWithLock<ChannelContext> channelLocks =                  Aio.getChannelContextsByGroup(channelContext.getGroupContext(),body.getId());  int onlineCount = channelLocks.getObj().size();

    看一下效果,数据量有点小,就两个用户,不过作为演示还是够用哒。

    

    

    另外的账号登录后:

    

    

总结

    本篇内容不是很多,就是一个文件的上传和tio中的个别api的简单应用,不过令我兴奋的是在我调试代码的时候,发现了很多可玩的东西,比如这玩意:

    当然,作者已经在框架介绍中介绍过了,可以监听每个客户端的发送消息情况,作为统计之类的。所以,下一步可以拿这些数据搞一些事情。

    最后,由于剩下的内容就是一些简单的消息历史记录,消息的保存,好友申请等增删改查的东西,后续不在过多介绍。项目正式写完之后在发一篇。接下来的准备玩玩t-io里面的数据~~(等等,是不是跑偏了,本来是学习springboot的。。。)

    代码地址:https://github.com/fanpan26/SpringBootLayIM

本文发表于2017年11月30日 22:33
(c)注:本文转载自https://my.oschina.net/panzi1/blog/1582389,转载目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责。如有侵权行为,请联系我们,我们会及时删除.

阅读 2745 讨论 0 喜欢 0

抢先体验

扫码体验
趣味小程序
文字表情生成器

闪念胶囊

你要过得好哇,这样我才能恨你啊,你要是过得不好,我都不知道该恨你还是拥抱你啊。

直抵黄龙府,与诸君痛饮尔。

那时陪伴我的人啊,你们如今在何方。

不出意外的话,我们再也不会见了,祝你前程似锦。

这世界真好,吃野东西也要留出这条命来看看

快捷链接
网站地图
提交友链
Copyright © 2016 - 2021 Cion.
All Rights Reserved.
京ICP备2021004668号-1