国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 系統(tǒng) > Android > 正文

Android基于socket實(shí)現(xiàn)的簡單C/S聊天通信功能

2019-10-23 20:08:39
字體:
供稿:網(wǎng)友

本文實(shí)例講述了Android基于socket實(shí)現(xiàn)的簡單C/S聊天通信功能。分享給大家供大家參考,具體如下:

主要想法:在客戶端上發(fā)送一條信息,在后臺(tái)開辟一個(gè)線程充當(dāng)服務(wù)端,收到消息就立即回饋給客戶端。

第一步:創(chuàng)建一個(gè)繼續(xù)Activity的SocketClientActity類,包為com.pku.net

編寫布局文件socketclient.xml,代碼如下:

<?xml version="1.0" encoding="utf-8"?><LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"  android:layout_width="match_parent"  android:layout_height="match_parent"  android:orientation="vertical" >  <ScrollView    android:id="@+id/scrollview3"    android:layout_width="fill_parent"    android:layout_height="wrap_content" >    <TextView      android:id="@+id/chattxt2"      android:layout_width="fill_parent"      android:layout_height="wrap_content"      android:background="#98F5FF" />  </ScrollView>  <EditText    android:id="@+id/chattxt"    android:layout_width="fill_parent"    android:layout_height="wrap_content" />  <Button    android:id="@+id/chatOk"    android:layout_width="wrap_content"    android:layout_height="wrap_content"    android:text="發(fā)送" >  </Button></LinearLayout>

接下來編寫SocketClientActity.Java文件:

package com.pku.net;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.net.UnknownHostException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.Socket;import android.app.Activity;import android.os.Bundle;import android.view.View;import android.widget.*;public class SocketClientActivity extends Activity {  SocketServerThread yaochatserver;  /** Called when the activity is first created. */  @Override  public void onCreate(Bundle savedInstanceState) {    super.onCreate(savedInstanceState);    setContentView(R.layout.socketclient);    try {      yaochatserver = new SocketServerThread();    } catch (IOException e) {      // TODO Auto-generated catch block      e.printStackTrace();    }    if (yaochatserver != null) {      yaochatserver.start();    }    findviews();    setonclick();  }  private EditText chattxt;  private TextView chattxt2;  private Button chatok;  public void findviews() {    chattxt = (EditText) this.findViewById(R.id.chattxt);    chattxt2 = (TextView) this.findViewById(R.id.chattxt2);    chatok = (Button) this.findViewById(R.id.chatOk);  }  private void setonclick() {    chatok.setOnClickListener(new View.OnClickListener() {      @Override      public void onClick(View v) {        try {          connecttoserver(chattxt.getText().toString());        } catch (UnknownHostException e) {          // TODO Auto-generated catch block          e.printStackTrace();        } catch (IOException e) {          // TODO Auto-generated catch block          e.printStackTrace();        }      }    });  }  public void connecttoserver(String socketData) throws UnknownHostException,      IOException {    Socket socket = RequestSocket("127.0.0.1", 5000);    SendMsg(socket, socketData);    String txt = ReceiveMsg(socket);    this.chattxt2.setText(txt);  }  private Socket RequestSocket(String host, int port)      throws UnknownHostException, IOException {    Socket socket = new Socket(host, port);    return socket;  }  private void SendMsg(Socket socket, String msg) throws IOException {    BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(        socket.getOutputStream()));    writer.write(msg.replace("/n", " ") + "/n");    writer.flush();  }  private String ReceiveMsg(Socket socket) throws IOException {    BufferedReader reader = new BufferedReader(new InputStreamReader(        socket.getInputStream()));    String txt = reader.readLine();    return txt;  }}

編寫AndroidManifest.xml文件:

<?xml version="1.0" encoding="utf-8"?><manifest xmlns:android="http://schemas.android.com/apk/res/android"  package="com.pku.net"  android:versionCode="1"  android:versionName="1.0" >  <uses-sdk android:minSdkVersion="8" />  <uses-permission android:name="android.permission.INTERNET"/>  <application    android:icon="@drawable/ic_launcher"    android:label="@string/app_name" >    <activity      android:name=".HttpURLActivity"      android:label="@string/app_name" >      <intent-filter>        <action android:name="android.intent.action.MAIN" />        <category android:name="android.intent.category.LAUNCHER" />      </intent-filter>    </activity>    <activity android:name="GetNetImage"></activity>    <activity android:name="HttpClientActivity"></activity>    <activity android:name="SocketClientActivity"></activity>  </application></manifest>

最后編寫后臺(tái)服務(wù)端的文件SocketServerThread.java,代碼如下:

package com.pku.net;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.ServerSocket;import java.net.Socket;public class SocketServerThread extends Thread {  public SocketServerThread() throws IOException {    CreateSocket();    // 創(chuàng)建Socket服務(wù)器  }  public void run() {    Socket client;    String txt;    try {      while (true)      // 線程無限循環(huán),實(shí)時(shí)監(jiān)聽socket端口      {        client = ResponseSocket();        // 響應(yīng)客戶端鏈接請(qǐng)求。。        while (true) {          txt = ReceiveMsg(client);          System.out.println(txt);          // 鏈接獲得客戶端發(fā)來消息,并將其顯示在Server端的屏幕上          SendMsg(client, txt);          // 向客戶端返回消息          if (true)            break;          // 中斷,繼續(xù)等待鏈接請(qǐng)求        }        CloseSocket(client);        // 關(guān)閉此次鏈接      }    } catch (IOException e) {      System.out.println(e);    }  }  private ServerSocket server = null;  private static final int PORT = 5000;  private BufferedWriter writer;  private BufferedReader reader;  private void CreateSocket() throws IOException {    server = new ServerSocket(PORT, 100);    System.out.println("Server starting..");  }  private Socket ResponseSocket() throws IOException {    Socket client = server.accept();    System.out.println("client connected..");    return client;  }  private void CloseSocket(Socket socket) throws IOException {    reader.close();    writer.close();    socket.close();    System.out.println("client closed..");  }  private void SendMsg(Socket socket, String Msg) throws IOException {    writer = new BufferedWriter(new OutputStreamWriter(        socket.getOutputStream()));    writer.write(Msg + "/n");    writer.flush();  }  private String ReceiveMsg(Socket socket) throws IOException {    reader = new BufferedReader(new InputStreamReader(        socket.getInputStream()));    System.out.println("server get input from client socket..");    String txt = "Sever send:" + reader.readLine();    return txt;  } /*  public static void main(final String args[]) throws IOException {    SocketServerThread yaochatserver = new SocketServerThread();    if (yaochatserver != null) {      yaochatserver.start();    }  }  */}

運(yùn)行效果如下圖:

Android,socket,C/S,聊天,通信

希望本文所述對(duì)大家Android程序設(shè)計(jì)有所幫助。


注:相關(guān)教程知識(shí)閱讀請(qǐng)移步到Android開發(fā)頻道。
發(fā)表評(píng)論 共有條評(píng)論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 全南县| 新竹市| 兴业县| 商南县| 黄大仙区| 仁布县| 临城县| 云林县| 镇平县| 永靖县| 荣成市| 竹山县| 上蔡县| 丹棱县| 孝感市| 即墨市| 林甸县| 阳城县| 贞丰县| 平潭县| 商水县| 礼泉县| 大安市| 巨野县| 通州市| 仁寿县| 鹿泉市| 铁岭县| 石林| 临泉县| 灵宝市| 东平县| 伊金霍洛旗| 邹平县| 简阳市| 松桃| 无锡市| 莱芜市| 六安市| 松原市| 五家渠市|