(网页)websocket后台调用Service层

2022-11-21 10:44:09

百度论坛里面有很多好的方法,借鉴.

重点:因为项目是StringBoot所以我用的是下面的方法很好使:

　　

Service.... service = (Service....) ContextLoader.getCurrentWebApplicationContext().getBean(Service.....class);
 ContextLoader.getCurrentWebApplicationContext().getBean(BeanName)

下面的是其他人的回答,第一个有用了，其他的先看看吧:

例子1:

当时 做开发的时候 在2015年7月份的时候 碰到跟楼主一样的问题
网上找遍 都找不到自动注入的方法，最后没办法，在websocket的握手驱动类里面 返回一个能拿到注入权限的类，然后利用这个类 实现websocket接口 拿到自动注入权限。绕了他娘的好大一圈。

例子2:

今天也遇到了这个问题，找了半天也没找到自动注入的方法。最后选择的最原始的方法解决。下面是我的代码

@Component

@Lazy(false)

public class ApplicationContextRegister implements ApplicationContextAware {

    private static ApplicationContext APPLICATION_CONTEXT;

    /**

     * 设置spring上下文  *  * @param applicationContext spring上下文  * @throws BeansException

     */

    @Override

    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {

        APPLICATION_CONTEXT = applicationContext;

    }

    public static ApplicationContext getApplicationContext() {

        return APPLICATION_CONTEXT;

    }

}

webScoket的注入service

  {

        ApplicationContext act = ApplicationContextRegister.getApplicationContext();

        userService=act.getBean(UserService.class);

        chatService=act.getBean(ChatService.class);

    }

举个自己写过的例子:html+js+后台

<div class="View" style="width: 100%;height:100%;">

                                    <h1>Java后端WebSocket的Tomcat实现</h1>

                                     Welcome<br/><input id="text" type="text"/>

                                     <button onclick="send()">发送消息</button>

                                     <hr/>

                                     <button onclick="closeWebSocket()">关闭WebSocket连接</button>

                                     <hr/>

                                     <div id="message"></div>

                                </div>

js:

     var websocket = null;

     //判断当前浏览器是否支持WebSocket

     if ('WebSocket' in window) {

         websocket = new WebSocket("ws://localhost:8084/websocket");

     }

     else {

         alert('当前浏览器 Not support websocket')

     }

     //连接发生错误的回调方法

     websocket.onerror = function () {

         setMessageInnerHTML("WebSocket连接发生错误");

     };

     //连接成功建立的回调方法

     websocket.onopen = function () {

         setMessageInnerHTML("WebSocket连接成功");

         websocket.send(sessionStorage.getItem("dealerId"));

     }

     //接收到消息的回调方法

     websocket.onmessage = function (event) {

         setMessageInnerHTML(event.data);

     }

     //连接关闭的回调方法

     websocket.onclose = function () {

         setMessageInnerHTML("WebSocket连接关闭");

     }

     //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。

     window.onbeforeunload = function () {

         closeWebSocket();

     }

     //将消息显示在网页上

     function setMessageInnerHTML(innerHTML) {

         document.getElementById('message').innerHTML += innerHTML + '<br/>';

     }

     //关闭WebSocket连接

     function closeWebSocket() {

         websocket.close();

     }

     //发送消息

     function send() {

         //var message = document.getElementById('text').value;

         websocket.send(sessionStorage.getItem("dealerId"));

     }

后台:

<dependency>

            <groupId>javax.websocket</groupId>

            <artifactId>javax.websocket-api</artifactId>

            <version>1.1</version>

            <scope>provided</scope>

        </dependency>

参考,如果缺少包的话，还是的百度。

import java.util.concurrent.CopyOnWriteArraySet;

import javax.annotation.Resource;

import javax.websocket.*;

import javax.websocket.server.ServerEndpoint;

import org.springframework.stereotype.Component;

import org.springframework.stereotype.Controller;

import org.springframework.web.context.ContextLoader;

import jy.api.form.JyChangeInStatusHistoryApiForm;

import jy.component.BaseController;

import jy.component.ServiceFacade;

import jy.service.JyChangeInStatusHistoryService;

@Component

@ServerEndpoint("/websocket")

public class WebsocketTest extends BaseController{

    public WebsocketTest(){

        System.out.println("WebsocketTest..");

    }

    @OnOpen

    public void onopen(Session session){

        System.out.println("连接成功");

        try {

            session.getBasicRemote().sendText("hello client...");

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    @OnClose

    public void onclose(Session session){

        System.out.println("close....");

    } 

     @OnMessage

    public void onsend(Session session,String msg){

        try {

            System.out.println('就是客户端传到后台的值'+msg);

            Service... service =  ContextLoader.getCurrentWebApplicationContext().getBean(service....class);

            session.getBasicRemote().sendText(""+传到HTML网页上的值);

        } catch (IOException e) {

            e.printStackTrace();

            System.out.println(e.getMessage());

        }

    }

}

之前老报这个错就是调Service层的时候报的:

}

09:34:32.179 [http-bio-8084-exec-9] ERROR o.a.t.w.pojo.PojoEndpointBase - No error handling configured for [jy.websocket.WebsocketTest] and the following error occurred

java.lang.IllegalArgumentException: java.lang.reflect.InvocationTargetException

        at org.apache.tomcat.websocket.pojo.PojoMessageHandlerWholeBase.onMessage(PojoMessageHandlerWholeBase.java:84)

        at org.apache.tomcat.websocket.WsFrameBase.sendMessageText(WsFrameBase.java:369)

        at org.apache.tomcat.websocket.WsFrameBase.processDataText(WsFrameBase.java:468)

        at org.apache.tomcat.websocket.WsFrameBase.processData(WsFrameBase.java:272)

        at org.apache.tomcat.websocket.WsFrameBase.processInputBuffer(WsFrameBase.java:116)

        at org.apache.tomcat.websocket.server.WsFrameServer.onDataAvailable(WsFrameServer.java:54)

        at org.apache.tomcat.websocket.server.WsHttpUpgradeHandler$WsReadListener.onDataAvailable(WsHttpUpgradeHandler.java:192)

        at org.apache.coyote.http11.upgrade.AbstractServletInputStream.onDataAvailable(AbstractServletInputStream.java:178)

        at org.apache.coyote.http11.upgrade.AbstractProcessor.upgradeDispatch(AbstractProcessor.java:92)

        at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:601)

        at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:310)

        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

        at java.lang.Thread.run(Thread.java:745)

Caused by: java.lang.reflect.InvocationTargetException: null

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:483)

        at org.apache.tomcat.websocket.pojo.PojoMessageHandlerWholeBase.onMessage(PojoMessageHandlerWholeBase.java:80)

        ... 13 common frames omitted

Caused by: java.lang.NullPointerException: null

        at jy.websocket.WebsocketTest.onsend(WebsocketTest.java:53)

        ... 18 common frames omitted

Long.valueOf(msg)3465007

09:34:32.188 [http-bio-8084-exec-9] ERROR o.a.t.w.pojo.PojoEndpointBase - No error handling configured for [jy.websocket.WebsocketTest] and the following error occurred

java.lang.IllegalArgumentException: java.lang.reflect.InvocationTargetException

        at org.apache.tomcat.websocket.pojo.PojoMessageHandlerWholeBase.onMessage(PojoMessageHandlerWholeBase.java:84)

        at org.apache.tomcat.websocket.WsFrameBase.sendMessageText(WsFrameBase.java:369)

        at org.apache.tomcat.websocket.WsFrameBase.processDataText(WsFrameBase.java:468)

        at org.apache.tomcat.websocket.WsFrameBase.processData(WsFrameBase.java:272)

        at org.apache.tomcat.websocket.WsFrameBase.processInputBuffer(WsFrameBase.java:116)

        at org.apache.tomcat.websocket.server.WsFrameServer.onDataAvailable(WsFrameServer.java:54)

        at org.apache.tomcat.websocket.server.WsHttpUpgradeHandler$WsReadListener.onDataAvailable(WsHttpUpgradeHandler.java:192)

        at org.apache.coyote.http11.upgrade.AbstractServletInputStream.onDataAvailable(AbstractServletInputStream.java:178)

        at org.apache.coyote.http11.upgrade.AbstractProcessor.upgradeDispatch(AbstractProcessor.java:92)

        at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:601)

        at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:310)

        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

        at java.lang.Thread.run(Thread.java:745)

Caused by: java.lang.reflect.InvocationTargetException: null

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

        at java.lang.reflect.Method.invoke(Method.java:483)

        at org.apache.tomcat.websocket.pojo.PojoMessageHandlerWholeBase.onMessage(PojoMessageHandlerWholeBase.java:80)

        ... 13 common frames omitted

Caused by: java.lang.NullPointerException: null

        at jy.websocket.WebsocketTest.onsend(WebsocketTest.java:53)

　　

上一篇：使用Java(Jedis)链接redis报java.net.ConnectException: Connection refused: connect的错误


下一篇：使用jedisPool管理jedis，使用jedis操作redis