使用Android网络编程实现简易聊天室
16lz
2021-01-23
在Java中我们可以利用socket编程实现聊天室,在Android中也一样,因为Android完全支持JDK本身的TCP、UDP网络通信API。我们可以使用ServerSocket、Socket来建立基于TCP/IP协议的网络通信;也可以使用DatagramSocket、Datagrampacket、MulticastSocket来建立基于UDP协议的网络通信。下面实现一个简单的聊天室,服务器端完全用Java代码实现,跟Android无关,客户端用Android应用来实现。
服务器不断读取来自客户端的信息,并即时地将信息发送给每个连接到本服务器上的客户端,每个客户端可以向服务器发送消息,并不断地接收来自服务器的消息,并将消息显示在界面上。这样就实现了客户端与客户端之间的即时聊天功能。代码如下:
服务器端:
创建服务器的主类:
[java] view plain copy- packagecom.home.server;
- importjava.io.IOException;
- importjava.net.ServerSocket;
- importjava.net.Socket;
- importjava.util.ArrayList;
- publicclassMyServer{
- //定义保存所有Socket的集合
- publicstaticArrayList<Socket>socketList=newArrayList<Socket>();
- publicstaticvoidmain(String[]args)throwsIOException{
- ServerSocketss=newServerSocket(20000);
- System.out.println("服务器创建成功!");
- System.out.println("等待客戶端的连接。。。");
- while(true){
- //此行代码会阻塞,等待用户的连接
- Socketsocket=ss.accept();
- System.out.println("有客户端连接进来!");
- socketList.add(socket);
- //每当客户端连接后启动一条ServerThread线程为该客户端服务
- newThread(newServerThread(socket)).start();
- }
- }
- }
服务器的线程类:
[java] view plain copy- packagecom.home.server;
- importjava.io.BufferedReader;
- importjava.io.IOException;
- importjava.io.InputStreamReader;
- importjava.io.OutputStream;
- importjava.net.Socket;
- publicclassServerThreadimplementsRunnable{
- //定义当前线程所处理的Socket
- privateSocketsocket=null;
- //该线程所处理的Socket所对应的输入流
- BufferedReaderbr=null;
- publicServerThread(Socketsocket)throwsIOException{
- this.socket=socket;
- //初始化该Socket对应的输入流
- br=newBufferedReader(newInputStreamReader(socket.getInputStream(),
- "utf-8"));
- }
- @Override
- publicvoidrun(){
- try{
- Stringcontent=null;
- //采用循环不断从Socket中读取客户端发送过来的数据
- while((content=readFromClient())!=null){
- //遍历socketList中的每个Socket,将读到的内容向每个Socket发送一次
- for(Sockets:MyServer.socketList){
- OutputStreamos=s.getOutputStream();
- os.write((content+"\n").getBytes("utf-8"));
- }
- }
- }catch(Exceptione){
- e.printStackTrace();
- }
- }
- /**
- *定义读取客户端数据的方法
- *
- *@return
- */
- privateStringreadFromClient(){
- try{
- returnbr.readLine();
- }
- //如果捕捉到异常,表明该Socket对应的客户端已经关闭
- catch(Exceptione){
- //删除该Socket
- MyServer.socketList.remove(socket);
- e.printStackTrace();
- }
- returnnull;
- }
- }
客户端主类(Activity):
[java] view plain copy- packagecom.home.activity;
- importjava.io.OutputStream;
- importjava.net.Socket;
- importandroid.app.Activity;
- importandroid.os.Bundle;
- importandroid.os.Handler;
- importandroid.os.Message;
- importandroid.view.View;
- importandroid.view.View.OnClickListener;
- importandroid.widget.Button;
- importandroid.widget.EditText;
- importcom.home.R;
- importcom.home.util.ClientThread;
- publicclassMultiThreadClientextendsActivity{
- privateEditTextinput,show;
- privateButtonsendBtn;
- privateOutputStreamos;
- privateHandlerhandler;
- @Override
- protectedvoidonCreate(BundlesavedInstanceState){
- super.onCreate(savedInstanceState);
- setContentView(R.layout.activity_main);
- input=(EditText)findViewById(R.id.main_et_input);
- show=(EditText)findViewById(R.id.main_et_show);
- sendBtn=(Button)findViewById(R.id.main_btn_send);
- handler=newHandler(){
- @Override
- publicvoidhandleMessage(Messagemsg){
- //如果消息来自子线程
- if(msg.what==0x234){
- //将读取的内容追加显示在文本框中
- show.append("\n"+msg.obj.toString());
- }
- }
- };
- Socketsocket;
- try{
- socket=newSocket("192.168.0.101",20000);
- //客户端启动ClientThread线程不断读取来自服务器的数据
- newThread(newClientThread(socket,handler)).start();
- os=socket.getOutputStream();
- }catch(Exceptione){
- e.printStackTrace();
- }
- sendBtn.setOnClickListener(newOnClickListener(){
- @Override
- publicvoidonClick(Viewv){
- try{
- //将用户在文本框内输入的内容写入网络
- os.write((input.getText().toString()+"\r\n").getBytes());
- //清空input文本框数据
- input.setText("");
- }catch(Exceptione){
- e.printStackTrace();
- }
- }
- });
- }
- }
客户端线程类:
[java] view plain copy- packagecom.home.util;
- importjava.io.BufferedReader;
- importjava.io.IOException;
- importjava.io.InputStreamReader;
- importjava.net.Socket;
- importandroid.os.Handler;
- importandroid.os.Message;
- publicclassClientThreadimplementsRunnable{
- privateHandlerhandler;
- //该线程所处理的Socket所对应的输入流
- privateBufferedReaderbr=null;
- publicClientThread(Socketsocket,Handlerhandler)throwsIOException{
- this.handler=handler;
- br=newBufferedReader(newInputStreamReader(socket.getInputStream()));
- }
- @Override
- publicvoidrun(){
- try{
- Stringcontent=null;
- //不断读取Socket输入流的内容
- while((content=br.readLine())!=null){
- //每当读到来自服务器的数据之后,发送消息通知程序界面显示该数据
- Messagemsg=newMessage();
- msg.what=0x234;
- msg.obj=content;
- handler.sendMessage(msg);
- }
- }catch(Exceptione){
- e.printStackTrace();
- }
- }
- }
Activity的布局XML:
[html] view plain copy- <LinearLayoutxmlns:android="http://schemas.android.com/apk/res/android"
- android:layout_width="match_parent"
- android:layout_height="match_parent"
- android:orientation="vertical">
- <LinearLayout
- android:layout_width="match_parent"
- android:layout_height="wrap_content"
- android:orientation="horizontal">
- <EditText
- android:id="@+id/main_et_input"
- android:layout_width="240dp"
- android:layout_height="wrap_content"/>
- <Button
- android:id="@+id/main_btn_send"
- android:layout_width="match_parent"
- android:layout_height="wrap_content"
- android:paddingLeft="10dp"
- android:text="发送"/>
- </LinearLayout>
- <EditText
- android:id="@+id/main_et_show"
- android:layout_width="match_parent"
- android:layout_height="match_parent"
- android:cursorVisible="false"
- android:editable="false"
- android:gravity="top"/>
- </LinearLayout>
权限:
[html] view plain copy- <uses-permissionandroid:name="android.permission.INTERNET"/>
更多相关文章
- android异步任务完成后再执行主线程任务
- Android使用线程获取网络图片的方法
- android中使用多线程——HandlerThread举例
- android 多线程断点下载,listview 模式 开始 暂停等功能
- Android从服务器获取图片的实例方法
- Android客户端连接PC服务器端(Socket连接)
- android使用JSON进行网络数据交换(服务端、客户端)的实现
- Android文字转语音TTS离线程序
- Android下调用webservice的服务器端和客户端详解