IT博客汇
  • 首页
  • 精华
  • 技术
  • 设计
  • 资讯
  • 扯淡
  • 权利声明
  • 登录 注册

    Android基于socket实现的简单C/S聊天通信功能

    summer发表于 2016-10-31 01:05:18
    love 0

    本文实例讲述了Android基于socket实现的简单C/S聊天通信功能。分享给大家供大家参考,具体如下:

    主要想法:在客户端上发送一条信息,在后台开辟一个线程充当服务端,收到消息就立即回馈给客户端。

    第一步:创建一个继续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="发送" >
    </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>

    最后编写后台服务端的文件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();
    // 创建Socket服务器
    }
    public void run() {
    Socket client;
    String txt;
    try {
    while (true)
    // 线程无限循环,实时监听socket端口
    {
    client = ResponseSocket();
    // 响应客户端链接请求。。
    while (true) {
    txt = ReceiveMsg(client);
    System.out.println(txt);
    // 链接获得客户端发来消息,并将其显示在Server端的屏幕上
    SendMsg(client, txt);
    // 向客户端返回消息
    if (true)
    break;
    // 中断,继续等待链接请求
    }
    CloseSocket(client);
    // 关闭此次链接
    }
    } 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();
    }
    } */
    }

    运行效果如下图:

    更多关于Android相关内容感兴趣的读者可查看本站专题:《Android通信方式总结》、《Android开发入门与进阶教程》、《Android调试技巧与常见问题解决方法汇总》、《Android多媒体操作技巧汇总(音频,视频,录音等)》、《Android基本组件用法总结》、《Android视图View技巧总结》、《Android布局layout技巧总结》及《Android控件用法总结》

    希望本文所述对大家Android程序设计有所帮助。



沪ICP备19023445号-2号
友情链接