android與服務端websocket通訊示例

阿新 • • 發佈：2019-01-08

服務端庫依賴詳見章末

spring websocket服務端程式碼(會話過程)

public class HandshakeInterceptor extends HttpSessionHandshakeInterceptor {
    private static final Logger logger = LoggerFactory.getLogger(HandshakeInterceptor.class);

    //會話開始
    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws 
 Exception {
        attributes.put(Constant.WEBSOCKET_USERNAME,"LSH");
        //  從session中獲取使用者
        /*if (request instanceof ServletServerHttpRequest) {
            ServletServerHttpRequest serverHttpRequest = (ServletServerHttpRequest) request;
            HttpSession session = serverHttpRequest.getServletRequest().getSession(false);
            if (session!=null) {
                String username = (String) session.getAttribute(Constant.SESSION_USERNAME);
                attributes.put(Constant.WEBSOCKET_USERNAME,username);
            }
        }*/ 

        return true;
    }

    //會話結束
    @Override
    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception ex) {
        System.out.println("After Handshake");
        super.afterHandshake(request, response, wsHandler, ex);
    }
}

服務端websocket訊息處理

import com.beesgame.sanguo.constant.Constant;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;

import java.io.IOException;
import java.util.ArrayList;

/**
 * Created by hackway on
 * Date: 2016/1/15.
 * Time:11:15
 */
public class WebSocketEndPoint extends TextWebSocketHandler {

    private static final ArrayList<WebSocketSession> users;
    private static final Logger logger;

    static {
        users = new ArrayList<WebSocketSession>();
        logger = LoggerFactory.getLogger(WebSocketEndPoint.class);
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        super.handleTextMessage(session, message);
        TextMessage returnMessage = new TextMessage(message.getPayload()+" received at server");
        session.sendMessage(returnMessage);
    }

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        logger.info("connect to the websocket success......");
        //新增使用者到session
        users.add(session);
        String username = (String) session.getAttributes().get(Constant.WEBSOCKET_USERNAME);
        if (username!=null) {
            session.sendMessage(new TextMessage("使用者名稱："+username));
        }
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        if (session.isOpen()) {
            session.close();
        }
        logger.info("websocket transport error, connection closed......");
        users.remove(session);
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        logger.info("websocket connection closed......");
        users.remove(session);
    }

    @Override
    public boolean supportsPartialMessages() {
        return super.supportsPartialMessages();
    }

    // 傳送資訊給特定使用者(LSH)
    public void sendMessageToUser(String username, TextMessage message) {
        for (WebSocketSession user:users) {
            if (user.getAttributes().get(Constant.WEBSOCKET_USERNAME).equals(username)) {
                try {
                    if (user.isOpen()) {
                        user.sendMessage(message);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
                break;
            }
        }
    }

     //傳送資訊給所用使用者，廣播
    public void sendMessageToAllUser(TextMessage message) {
        for (WebSocketSession user:users) {
            try {
                if (user.isOpen()) {
                    user.sendMessage(message);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

使用註解配置websocket(需要在springmvc配置檔案中開啟相應註解支援)

@Configuration
//@EnableWebMvc
@EnableWebSocket
public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry webSocketHandlerRegistry) {
        webSocketHandlerRegistry.addHandler(getWebSocketEndPoint(),"/websocket").addInterceptors(new HandshakeInterceptor());
        webSocketHandlerRegistry.addHandler(getWebSocketEndPoint(),"/websocket/sockjs").addInterceptors(new HandshakeInterceptor()).withSockJS();
    }

    @Bean
    public WebSocketEndPoint getWebSocketEndPoint() {
        return new WebSocketEndPoint();
    }
}

controller呼叫websocket傳送資訊

@Controller("/*")
public class IndexController extends BaseController {



    @Autowired
    private UserInfoService userInfoService;

    //注入websocket
    @Bean
    public WebSocketEndPoint getWebSocketEndpoint() {
        return new WebSocketEndPoint();
    }

    @RequestMapping(value = "socket.do", produces = "text/json;charset=UTF-8", method = RequestMethod.GET)
    @ResponseBody
    public String socket(@RequestParam(value = "uid") long uid) throws IOException {
        UserInfoVO userToken = userInfoService.getUserInfoVOByUid(uid);
        String result = objectMapper.writeValueAsString(userToken);
        getWebSocketEndpoint().sendMessageToUser("LSH", new TextMessage(result));
        return result;
    }
}

服務端啟動截圖

這裡寫圖片描述

客戶端websocket連結服務端(android)

gradle中新增java-websocket依賴

compile ‘org.java-websocket:Java-WebSocket:1.3.0’

websocket客戶端類

import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.widget.TextView;

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.drafts.Draft;
import org.java_websocket.drafts.Draft_17;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.util.Date;

/**
 * Created by hackway on 16/2/24.
 */
public class SiteWebsocket extends WebSocketClient {


    //handler通知主執行緒更新textview
    private Handler handler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            textView.setText(String.valueOf(msg.obj));
        }
    };
    private TextView textView;
    public SiteWebsocket(URI serverUri, Draft draft, TextView tv) {
        super(serverUri, draft);
        this.textView = tv;
    }
    @Override
    public void onOpen(ServerHandshake handshakedata) {
        Log.d("websocket","open connection");
    }

    @Override
    public void onMessage(String message) {
        Log.d("websocket","receive: "+message);
        Message msg = new Message();
        msg.obj = message;
        handler.sendMessage(msg);
    }

    @Override
    public void onClose(int code, String reason, boolean remote) {
        Log.d("websocket","Connection close by "+(remote?"remote peer":"us") +" at "+new Date(System.currentTimeMillis()));
    }

    @Override
    public void onError(Exception ex) {
        ex.printStackTrace();
    }
}

客戶端建立連結(MainActivity.java)

import android.os.Bundle;
import android.support.design.widget.FloatingActionButton;
import android.support.design.widget.Snackbar;
import android.support.v7.app.AppCompatActivity;
import android.support.v7.widget.Toolbar;
import android.view.View;
import android.view.Menu;
import android.view.MenuItem;
import android.widget.TextView;

import org.java_websocket.drafts.Draft_17;

import java.net.URI;
import java.net.URISyntaxException;

import site.hackway.www.androidsite.websocket.SiteWebsocket;

public class MainActivity extends AppCompatActivity {

    private TextView textView;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Toolbar toolbar = (Toolbar) findViewById(R.id.toolbar);
        setSupportActionBar(toolbar);

        textView = (TextView) findViewById(R.id.txvw);
        SiteWebsocket siteWebsocket = null;
        try {
            siteWebsocket = new SiteWebsocket(new URI("ws://192.168.1.103:8080/sanguo/websocket"),new Draft_17(),textView);
            siteWebsocket.connectBlocking();
        } catch (URISyntaxException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        /*FloatingActionButton fab = (FloatingActionButton) findViewById(R.id.fab);
        fab.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                Snackbar.make(view, "Replace with your own action", Snackbar.LENGTH_LONG)
                        .setAction("Action", null).show();
            }

        });*/
    }

    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.menu_main, menu);
        return true;
    }

    @Override
    public boolean onOptionsItemSelected(MenuItem item) {
        // Handle action bar item clicks here. The action bar will
        // automatically handle clicks on the Home/Up button, so long
        // as you specify a parent activity in AndroidManifest.xml.
        int id = item.getItemId();

        //noinspection SimplifiableIfStatement
        if (id == R.id.action_settings) {
            return true;
        }

        return super.onOptionsItemSelected(item);
    }
}

客戶端程式碼編寫完畢，啟動模擬器(注意客戶端服務端需處於統一區域網)

輸入圖片說明

出現使用者名稱：LSH 說明連線成功

接著測試服務端向客戶端傳送訊息
通過瀏覽器訪問 http://ip:port/your project name/socket.do?uid=1

輸入圖片說明

服務端推送資訊成功

服務端maven依賴，(其中spring的版本需要大於4)

    <properties>
        <spring.version>4.2.4.RELEASE</spring.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-web</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-expression</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-websocket</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-messaging</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.freemarker</groupId>
            <artifactId>freemarker</artifactId>
            <version>2.3.20</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>2.1.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.1.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>2.1.0</version>
        </dependency>

        <!-- logback日誌配置 -->
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-classic</artifactId>
            <version>1.1.3</version>
        </dependency>
        <dependency>
            <groupId>org.logback-extensions</groupId>
            <artifactId>logback-ext-spring</artifactId>
            <version>0.1.2</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>jcl-over-slf4j</artifactId>
            <version>1.7.12</version>
        </dependency>
    </dependencies>

android與服務端websocket通訊示例

服務端庫依賴詳見章末 spring websocket服務端程式碼(會話過程) public class HandshakeInterceptor extends HttpSessionHandshakeInterceptor { priva

Android與服務端（SSM）互動

客戶端 Android在Android Studio平臺，採用OkHttp進行網路請求服務端服務端採用了SSM（Spring+SpringMVC+MyBatis）框架這裡介紹服務端接收並返回json資料的多種方法方式一：PrintWriter @RequestMa

android與服務端互動的兩種方式

做android開發的程式設計師必須知道android客戶端應該如何與服務端進行互動，這裡主要介紹的是使用json資料進行互動。服務端從資料庫查出資料並以json字串的格式或者map集合的格式返回到客戶端，客戶端進行解析並輸出到手機螢幕上。此處介紹兩種方式：

客戶端與服務端Socket通訊原理詳解

對於Java Socket程式設計而言，有兩個概念，一個是ServerSocket，一個是Socket。服務端和客戶端之間通過Socket建立連線，之後它們就可以進行通訊了。首先ServerSocket將在服務端監聽某個埠，當發現客戶端有Socket來試圖連線它時，

Android與PHP互動：客戶端用HTTP協議與服務端通訊

為了實現Android客戶端和服務端的通訊，Android SDK為我們提供了Apache的HttpClient來方便我們使用各種HTTP服務。可以把HttpClient看成一個瀏覽器，通過它可以方便地發出GET請求和POST請求來獲得服務端響應。下面我們

Android端與服務端基於TCP/IP協議的Socket通訊

什麼是TCP/IP協議？百度百科的解釋：Transmission Control Protocol/Internet Protocol的簡寫，中譯名為傳輸控制協議/因特網互聯協議，又名網路通訊協議，是Internet最基本的協議、Internet國

Android（客戶端）通過socket與QT（服務端）通訊

一、概述在這裡我想實現一個跨平臺的socket通訊，Android手機作為客戶端向Ubuntu的QT平臺上的服務端傳送一個字元命令，由於是隻傳送一個字元，這裡我儘可能簡化socket通訊的過程以供後人參考。文中貼上主要程式碼，末尾會給出完整原始碼的下載。

android移動端與服務端通訊保持Session會話

移動端在向伺服器請求登入並且登入成功的時候，伺服器的訂單介面需要獲取當前登入的Session，才能夠以當前使用者身份下單，與web端不同，移動端的Session不會自動儲存到web端，每次請求都認為是一次新的請求。因此在移動端只要獲取到當前登入的Session並且記錄下來，在

Android BLE與終端通信（三）——client與服務端通信過程以及實現數據通信

.sh 沒有 indexof 實例解析 rip listview filter @override Android BLE與終端通信（三）——client與服務端通信過程以及實現數據通信前面的終究僅僅是小知識點。上不了臺面，也僅僅能算是起

基於socket.io客戶端與服務端的相互通訊

dem send ins 返回 on() .com cal selector req socket.io是對websocket的封裝，用於客戶端與服務端的相互通訊。官網:https://socket.io/。下面是socket.io的用法： 1、由於使用express

nio 客戶端與服務端通訊Demo

本篇博文主要是從網上收集和整理眾多網友關於NIO的理解所寫的博文，非作者原創（除最後的服務端與客戶端通訊的Demo），在此宣告。 1. NIO入門概念：主要參考文獻：Java nio 使用及原理分析 Java NIO 使用及原理分析（一）： &nb

Netty入門——客戶端與服務端通訊

Netty簡介Netty是一個基於JAVA NIO 類庫的非同步通訊框架，它的架構特點是：非同步非阻塞、基於事件驅動、高效能、高可靠性和高可定製性。換句話說，Netty是一個NIO框架，使用它可以簡單快速地開發網路應用程式，比如客戶端和服務端的協議。Netty大大簡化了網路程式的開發過程比如TCP和UDP的

Vue+Java servlet 通過websocket實現伺服器與客戶端雙向通訊

1. vue程式碼 methods: { //在方法裡呼叫 this.websocketsend()傳送資料給伺服器 onConfirm () { //需要傳輸的資料 let data = { cod

網路通訊——>TCP協議和UDP協議的客戶端與服務端之間的建立

網路程式設計 OSI有七層模型：它從低到高分別是：物理層、資料鏈路層、網路層、傳輸層、會話層、表示層和應用層。如下圖：網路程式設計的三要素： 1、IP地址 ## 獲取ip地址和主機名的方式 #需要匯入socket模組 import socket name = socket.g

【Android 開發】: Android客戶端與服務端之間使用JSON互動資料。

在前面的兩講中，我們講解了JSON資料格式的一些基本知識,以及做一些小Demo,這一講我們在前面的基礎上來做一個綜合的可擴充套件的Demo，主要是針對Android客戶端解析服務端傳遞過來的JSON資料。整個Demo所作的操作如下圖所示 1. 服務端服務端

android學習筆記之客戶端與服務端保持session登入狀態

剛進公司不久，也沒有具體專案任務，只有一個混合開發模式，使用AppCan開發的專案。雖然混合開發很便捷、很高效，使用html和js就可以完成。但我依然對android原生開發有著極高的熱情，尤其是在體驗了Android 5.0版本之後，更是對原生體驗著迷。所以，我利用

SOCKET客戶端與服務端長時間通訊後，會連線不上服務端的問題，以及server端UDP丟包的問題

人生第一篇部落格，希望能以一個好的開始，持之以恆下去！這兩天在做有關負載均衡的一個專案，期間在除錯時遇到了一個問題：客戶端與服務端依靠socket通訊，但是長時間通訊後，會發生客戶端連線不上服務端的狀況。而後查詢了一些資料後，終於搞清楚問題的緣由了，在此和大家分享一下！

AIDL使用詳解（三）客戶端通過AIDL與服務端通訊例項專案

專案簡介我們要實現一個計算器的功能。首先實現一個服務端，用於提供計算服務，供客戶端去呼叫。它接受客戶端提供的兩個值，計算之後，返回兩個數之和。第二，實現客戶端介面進行操作。第三：我們命名客戶端和服務端。第四：定義AIDL，連線客戶

Java Socket實現客戶端與服務端通訊例項

首先,建立一個Server.java的伺服器端類package socket; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; impor

java Socket通訊，客戶端與服務端相互發訊息

1.通訊過程網路分為應用層，http、ssh、telnet就是屬於這一類，建立在傳輸層的基礎上、其實就是定義了各自的編碼解碼格式，分層如下： 2.Socket連線上述通訊都要先在傳輸層有建立連線的基礎上才能完成，TCP通過三次握手建立連線：

android與服務端websocket通訊示例

spring websocket服務端程式碼(會話過程)

服務端websocket訊息處理

使用註解配置websocket(需要在springmvc配置檔案中開啟相應註解支援)

controller呼叫websocket傳送資訊

*服務端啟動截圖*

客戶端websocket連結服務端(android)

compile ‘org.java-websocket:Java-WebSocket:1.3.0’

websocket客戶端類

客戶端建立連結(MainActivity.java)

相關推薦

服務端啟動截圖