web socket 2

springWebSocket/pom.xml

@@ -50,6 +50,12 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-websocket</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-messaging</artifactId>
+            <version>4.2.3.RELEASE</version>
+        </dependency>
     </dependencies>
 
 

springWebSocket/src/main/java/com/us/example/Application.java

@@ -5,10 +5,14 @@ package com.us.example;
  */
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 import static org.springframework.boot.SpringApplication.run;
 
+@ComponentScan(basePackages ="com.us.example")
 @SpringBootApplication
+@EnableScheduling
 public class Application {
 
     public static void main(String[] args) {

springWebSocket/src/main/java/com/us/example/controller/WebSocketController.java

@@ -4,11 +4,14 @@ package com.us.example.controller;
 
 import com.us.example.bean.Message;
 import com.us.example.bean.Response;
+import com.us.example.service.WebSocketService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.messaging.handler.annotation.SendTo;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
 
 import java.security.Principal;
 
@@ -18,7 +21,10 @@ import java.security.Principal;
  */
 @Controller
 public class WebSocketController {
+    @Autowired
+    private WebSocketService ws;
 
+    //http://localhost:8080/ws
     @MessageMapping("/welcome")//浏览器发送请求通过@messageMapping 映射/welcome 这个地址。
     @SendTo("/topic/getResponse")//服务器端有消息时,会订阅@SendTo 中的路径的浏览器发送消息。
     public Response say(Message message) throws Exception {
@@ -26,6 +32,15 @@ public class WebSocketController {
         return new Response("Welcome, " + message.getName() + "!");
     }
 
+    //http://localhost:8080/Welcome1
+    @RequestMapping("/Welcome1")
+    @ResponseBody
+    public String say2()throws Exception
+    {
+        ws.sendMessage();
+        return "is ok";
+    }
+
 //    @Autowired
 //    private SimpMessagingTemplate messagingTemplate;//1
 //

springWebSocket/src/main/java/com/us/example/service/WebSocketService.java

+package com.us.example.service;
+
+/**
+ * Created by yangyibo on 17/1/12.
+ */
+
+import com.us.example.bean.Response;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Service;
+
+@Service
+public class WebSocketService {
+    @Autowired
+    private SimpMessagingTemplate template;
+
+    public void sendMessage() throws Exception{
+        for(int i=0;i<10;i++)
+        {
+            Thread.sleep(1000);
+            template.convertAndSend("/topic/getResponse",new Response("Welcome,yangyibo !"+i));
+            System.out.println("----------------------yangyibo"+i);
+        }
+    }
+
+}