Java消息队列的简单实现代码

　　

今天看到我们的招聘信息有对消息队列有要求,然后就思索了一翻,网上一搜一大堆。
　　

　　

癑ava消息队列的简单实现代码"

　　

我可以举个小例子先说明应用场景
　　

　　

假设你的服务器每分钟的处理量为200个,但客户端再峰值的时候可能一分钟会发1000个消息给你,这时候你就可以把他做成队列,然后按正常有序的处理,先进后出(后进先出),先进先出(FIFO)可根据自己的情况进行定夺
　　

　　

stack 先进后出(后进先出)- - - - - - - - - Java对应的类堆栈
　　

　　

队列先进先出(FIFO) - - - - - - - - - - java对应的类队列
　　

　　

这两种都可用Linkedlist进行封装和实现,下面是我自己写的一个栈的例子

　　 　　/* * 　　* @author刘伊凡 　　* - - - - - - - - - -→祝辞祝辞祝辞祝辞祝辞队列的实现- - - - - - - - - - - - - - - 　　*/公开课MyStack{ 　　私人LinkedList存储=new LinkedList (); 　　 　　公共同步空白推(T e){//需要加上同步 　　storage.addFirst (e); 　　} 　　 　　公共T peek () { 　　返回storage.getFirst (); 　　} 　　 　　公共空间pop () { 　　storage.removeFirst (); 　　} 　　 　　公共布尔空(){ 　　返回storage.isEmpty (); 　　} 　　 　　@Override 　　公共字符串toString () { 　　返回storage.toString (); 　　} 　　 　　} 　　 　　之前 　　 　　

下面是一个测试类

　　 　　/* * 　　* @author刘伊凡 　　* 　　*/公开课StackTest { 　　公共静态void main (String [] args) { 　　MyStack堆栈=new MyStack (); 　　(字符串s:“完美的代码”。分割(" ")){//后进先出 　　stack.push(年代); 　　} 　　而(! stack.empty ()) { 　　System.out.print (stack.peek () + " "); 　　stack.pop (); 　　} 　　 　　System.out.println (); 　　(char年代:“写了个一句话倒起来说的程序”.toCharArray()){//用例:正话反说 　　stack.push (String.valueOf (s)); 　　} 　　而(! stack.empty ()) { 　　System.out.print (stack.peek ()); 　　stack.pop (); 　　} 　　} 　　} 　　 　　之前 　　 　　

挺有意思的,让我想了,以前在学校的晚会上,主持人互动的时候会让人上台去答题拿奖品,其中有一个题目就是主持人说一句话,然后要求选手倒起来说,我们的这个程序很符合需求嘛,哈哈,我们可以用java来作弊,学以致用

　　

<>强消息队列的应用场景,补充(来自互联网)
　　

　　

个人认为消息队列的主要特点是异步处理,主要目的是减少请求响应时间和解耦,所以主要的使用场景就是将比较耗时而且不需要即时(同步)返回结果的操作作为消息放入消息队列。同时由于使用了消息队列,只要保证消息格式不变,消息的发送方和接收方并不需要彼此联系,也不需要受对方的影响,即解耦和。

　　

使用场景的话,举个例子:
　　

　　

假设用户在你的软件中注册,服务端收到用户的注册请求后,它会做这些操作:
　　

　　

校验用户名等信息,如果没问题会在数据库中添加一个用户记录
　　

　　

如果是用邮箱注册会给你发送一封注册成功的邮件,手机注册则会发送一条短信
　　

　　

分析用户的个人信息,以便将来向他推荐一些志同道合的人,或向那些人推荐他
　　

　　

发送给用户一个包含操作指南的系统通知
　　

　　

等等……
　　

　　

但是对于用户来说,注册功能实际只需要第一步,只要服务端将他的账户信息存到数据库中他便可以登录上去做他想做的事情了。至于其他的事情,非要在这一次请求中全部完成么?值得用户浪费时间等你处理这些对他来说无关紧要的事情么?所以实际当第一步做完后,服务端就可以把其他的操作放入对应的消息队列中然后马上返回用户结果,由消息队列异步的进行这些操作。

　　

或者还有一种情况,同时有大量用户注册你的软件,再高并发情况下注册请求开始出现一些问题,例如邮件接口承受不住,或是分析信息时的大量计算使cpu满载,这将会出现虽然用户数据记录很快的添加到数据库中了,但是却卡在发邮件或分析信息时的情况,导致请求的响应时间大幅增长,甚至出现超时,这就有点不划算了。面对这种情况一般也是将这些操作放入消息队列(生产者消费者模型),消息队列慢慢的进行处理,同时可以很快的完成注册请求,不会影响用户使用其他功能。

Java消息队列的简单实现代码