增加缓存消息功能

src/main/java/com/yg84/Login.java

@@ -11,6 +11,7 @@ import javax.annotation.PostConstruct;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by fangzhipeng on 2017/7/16.
@@ -57,4 +58,14 @@ public class Login {
         }
         return messages;
     }
+
+    @RequestMapping(value = "/syncLoadMessage")
+    public List<Message> syncLoadMessage() throws Exception{
+        List<Message> messages = new ArrayList<>();
+        Message message;
+        while ((message = messageQueue.poll(5, TimeUnit.SECONDS)) != null) {
+            messages.add(message);
+        }
+        return messages;
+    }
 }