本篇文章給大家分享的是有關(guān)如何在android中使用websocket協(xié)議進(jìn)行服務(wù)器通信，小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

創(chuàng)新互聯(lián)為您提適合企業(yè)的網(wǎng)站設(shè)計(jì)?讓您的網(wǎng)站在搜索引擎具有高度排名，讓您的網(wǎng)站具備超強(qiáng)的網(wǎng)絡(luò)競(jìng)爭(zhēng)力！結(jié)合企業(yè)自身，進(jìn)行網(wǎng)站設(shè)計(jì)及把握，最后結(jié)合企業(yè)文化和具體宗旨等，才能創(chuàng)作出一份性化解決方案。從網(wǎng)站策劃到網(wǎng)站設(shè)計(jì)制作、成都網(wǎng)站制作， 我們的網(wǎng)頁(yè)設(shè)計(jì)師為您提供的解決方案。

客戶端代碼：

import com.example.test.R; 
 
import android.app.Activity; 
import android.os.Bundle; 
import android.view.View; 
import android.view.View.OnClickListener; 
import android.widget.Button; 
import android.widget.EditText; 
import android.widget.Toast; 
import de.tavendo.autobahn.WebSocketConnection; 
import de.tavendo.autobahn.WebSocketConnectionHandler; 
import de.tavendo.autobahn.WebSocketException; 
 
public class MainActivity extends Activity implements OnClickListener { 
 
 private Button bt; 
 private EditText ed_name; 
 private EditText ed_text; 
 private Button bt1; 
 WebSocketConnection wsc; 
 @Override 
 protected void onCreate(Bundle savedInstanceState) { 
 super.onCreate(savedInstanceState); 
 setContentView(R.layout.activity_main); 
 bt = (Button) findViewById(R.id.bt); 
 ed_name = (EditText) findViewById(R.id.ed_name); 
 ed_text = (EditText) findViewById(R.id.ed_text); 
 bt1 = (Button) findViewById(R.id.bt1); 
 bt.setOnClickListener(this); 
 bt1.setOnClickListener(this); 
 wsc = new WebSocketConnection(); 
 
 } 
 
 private void connect() { 
 System.out.println("開(kāi)始連接websocket///"); 
 
 try { 
 
  wsc.connect("ws://192.168.1.245:8080/DriveServer/mainservlet", 
   new WebSocketConnectionHandler() { 
   
   @Override 
   public void onBinaryMessage(byte[] payload) { 
    System.out.println("onBinaryMessage size=" 
     + payload.length); 
   } 
 
   @Override 
   public void onClose(int code, String reason) { 
    System.out.println("onClose reason=" + reason); 
   } 
 
   @Override 
   public void onOpen() { 
    System.out.println("onOpen"); 
    showtext("連接成功"); 
    // wsc.sendTextMessage("Hello!"); 
    // wsc.disconnect(); 
   } 
   @Override 
   public void onRawTextMessage(byte[] payload) { 
    System.out.println("onRawTextMessage size=" 
     + payload.length); 
   } 
 
   @Override 
   public void onTextMessage(String payload) { 
    System.out.println("onTextMessage" + payload); 
    showtext(payload); 
   } 
 
   }); 
 } catch (WebSocketException e) { 
  // TODO Auto-generated catch block 
  e.printStackTrace(); 
 } 
 
 } 
 @Override 
 public void onClick(View v) { 
 // TODO Auto-generated method stub 
 int id = v.getId(); 
 switch (id) { 
  case R.id.bt : 
  wsc.sendTextMessage("我是客戶端，我通過(guò)ws往服務(wù)器發(fā)數(shù)據(jù)"); 
  break; 
  case R.id.bt1 : 
  connect(); 
  break; 
  default : 
  break; 
 } 
 } 
 private void showtext(String msg) { 
 Toast.makeText(this, msg, 0).show(); 
 } 
}

下面是服務(wù)器代碼：

用的是jetty7自帶的websocket庫(kù)

package com.websocket; 
 
import java.io.IOException; 
import java.io.UnsupportedEncodingException; 
import java.nio.ByteBuffer; 
import java.nio.CharBuffer; 
import java.text.SimpleDateFormat; 
import java.util.ArrayList; 
import java.util.Date; 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 
import java.util.Set; 
 
import javax.servlet.ServletException; 
import javax.servlet.http.HttpServletRequest; 
import javax.servlet.http.HttpServletResponse; 
 
import org.eclipse.jetty.websocket.WebSocket; 
import org.eclipse.jetty.websocket.WebSocket.OnTextMessage; 
import org.eclipse.jetty.websocket.WebSocketServlet; 
 
public class ChatWebSocketServlet extends WebSocketServlet { 
 
 private static final long serialVersionUID = 911879078000755859L; 
 
 private List<MyWebSocket> list = new ArrayList<MyWebSocket>(); 
 
 class MyWebSocket implements OnTextMessage { 
 private String userName = "匿名用戶"; 
 
 public MyWebSocket(String userName) { 
  if (userName != null && userName.length() > 0) { 
  this.userName = userName; 
  } 
 } 
 
 private Connection conn; 
 
 public void onClose(int arg0, String arg1) { 
  // TODO Auto-generated method stub 
  System.out.println("onOpen 斷開(kāi)連接了。。。。。。。。" + arg1 + " " + arg0); 
  list.remove(this); 
 } 
 
 public void onOpen(Connection arg0) { 
  // TODO Auto-generated method stub 
  System.out 
   .println("onOpen 連接了。。。。。。。。。。。。" + arg0.getMaxIdleTime()); 
  this.conn = arg0; 
  
  if (!list.contains(arg0)) { 
  list.add(this); 
  } else { 
  System.out.println("這個(gè)用戶已經(jīng)連接了"); 
  } 
  System.out.println(".." + list.size()); 
 } 
 
 public void onMessage(String arg0) { 
  
  String toname = arg0.substring(0, 3); 
  System.out.println("toname-->" + toname); 
  try { 
   
  list.get(0).getConn() 
   .sendMessage(arg0.substring(3)); 
  System.out.println("發(fā)送的數(shù)據(jù)" + arg0.substring(3)); 
  } catch (IOException e) { 
  // TODO Auto-generated catch block 
  e.printStackTrace(); 
  } 
 } 
 
 private Connection getConn() { 
  return this.conn; 
 } 
 } 
 
 public WebSocket doWebSocketConnect(HttpServletRequest arg0, String arg1) { 
 // TODO Auto-generated method stub 
 String name = ""; 
 name = arg0.getParameter("username"); 
 System.out.println(name + "is connected"); 
 return new MyWebSocket(name); 
 } 
 
 @Override 
 protected void service(HttpServletRequest request, 
  HttpServletResponse response) throws ServletException, IOException { 
 // TODO Auto-generated method stub 
 super.service(request, response); 
 } 
 
}

以上就是如何在android中使用websocket協(xié)議進(jìn)行服務(wù)器通信，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

本文名稱：如何在android中使用websocket協(xié)議進(jìn)行服務(wù)器通信-創(chuàng)新互聯(lián)
文章起源：http://aaarwkj.com/article22/ihccc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計(jì)、搜索引擎優(yōu)化、域名注冊(cè)、品牌網(wǎng)站制作、網(wǎng)站維護(hù)、軟件開(kāi)發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)