Android Socket通信的简单实现
更新时间:2021年9月26日 16:01 点击:1310
公司要实现一个简单的聊天功能,提前研究一下Socket通信,而公司的服务端功能又没有实现,所以这里就把服务端的功能放到一个界面实现了。
直接上代码:
<?xml version="1.0" encoding="utf-8"?> <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" tools:context=".MainActivity"> <EditText android:id="@+id/et_ip" android:layout_width="0dp" android:layout_height="wrap_content" android:hint="IP:端口" android:text="127.0.0.1:8081" android:layout_margin="10dp" android:padding="10dp" app:layout_constraintLeft_toLeftOf="parent" app:layout_constraintRight_toLeftOf="@+id/btn_connect" app:layout_constraintTop_toTopOf="parent" /> <Button android:id="@+id/btn_connect" android:layout_width="wrap_content" android:layout_height="wrap_content" app:layout_constraintTop_toTopOf="parent" app:layout_constraintRight_toRightOf="parent" android:layout_margin="10dp" android:text="连接"/> <TextView android:id="@+id/tv_receive" android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="接受数据:" app:layout_constraintTop_toBottomOf="@+id/et_ip" app:layout_constraintLeft_toLeftOf="parent" android:textSize="14sp" android:layout_margin="10dp"/> <ScrollView android:id="@+id/sv_content" android:layout_width="match_parent" android:layout_height="200dp" app:layout_constraintTop_toBottomOf="@+id/tv_receive" app:layout_constraintLeft_toLeftOf="parent"> <LinearLayout android:layout_width="match_parent" android:layout_height="wrap_content"> <TextView android:id="@+id/tv_content" android:layout_width="match_parent" android:layout_height="wrap_content" android:text="聊天内容" android:textColor="#000" android:textSize="16sp" android:layout_margin="10dp"/> </LinearLayout> </ScrollView> <EditText android:id="@+id/et_input" android:layout_width="match_parent" android:layout_height="wrap_content" android:hint="发送内容" android:layout_margin="10dp" android:padding="10dp" app:layout_constraintLeft_toLeftOf="parent" app:layout_constraintTop_toBottomOf="@+id/sv_content" /> <Button android:id="@+id/btn_service" android:layout_width="0dp" android:layout_height="wrap_content" app:layout_constraintTop_toBottomOf="@+id/et_input" app:layout_constraintLeft_toLeftOf="parent" app:layout_constraintRight_toLeftOf="@+id/btn_send" android:layout_margin="10dp" android:text="服务端发送"/> <Button android:id="@+id/btn_send" android:layout_width="0dp" android:layout_height="wrap_content" app:layout_constraintTop_toBottomOf="@+id/et_input" app:layout_constraintLeft_toRightOf="@+id/btn_service" app:layout_constraintRight_toRightOf="parent" android:layout_margin="10dp" android:text="发送"/> </androidx.constraintlayout.widget.ConstraintLayout>
主要代码:
package com.app.socketdemo; import android.annotation.SuppressLint; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.text.Html; import android.text.TextUtils; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.ScrollView; import android.widget.TextView; import android.widget.Toast; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import androidx.appcompat.app.AppCompatActivity; import butterknife.BindView; import butterknife.ButterKnife; import butterknife.OnClick; public class MainActivity extends AppCompatActivity { @BindView(R.id.et_ip) EditText etIp; @BindView(R.id.btn_connect) Button btnConnect; @BindView(R.id.tv_receive) TextView tvReceive; @BindView(R.id.tv_content) TextView tvContent; @BindView(R.id.et_input) EditText etInput; @BindView(R.id.btn_send) Button btnSend; @BindView(R.id.sv_content) ScrollView svContent; @BindView(R.id.btn_service) Button btnService; private StringBuffer strMsg = new StringBuffer(); private final int MESSAGE_ERROR = 0; private final int MESSAGE_SUCCEED = 1; private final int MESSAGE_RECEIVE = 2; private Socket sock; private OutputStream outx; private InputStream inx; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); ButterKnife.bind(this); //启动服务端 new Thread(() -> new Server().startService()).start(); } @OnClick({R.id.btn_connect, R.id.btn_service, R.id.btn_send}) public void onViewClicked(View view) { switch (view.getId()) { case R.id.btn_connect://连接服务端 String strip = etIp.getText().toString().trim(); if (strip.indexOf(":") >= 0) { //启动连接 new Socket_thread(strip).start(); } break; case R.id.btn_service: if (!TextUtils.isEmpty(etInput.getText().toString())) { sendString("服务端:" + etInput.getText().toString().trim()); etInput.setText(""); } else { Toast.makeText(this, "输入不可为空", Toast.LENGTH_SHORT).show(); } break; case R.id.btn_send: if (!TextUtils.isEmpty(etInput.getText().toString())) { sendStrSocket("客户端:" + etInput.getText().toString().trim()); etInput.setText(""); } else { Toast.makeText(this, "输入不可为空", Toast.LENGTH_SHORT).show(); } break; } } /** * 连接服务器 */ class Socket_thread extends Thread { private String IP = "";//ip地址 private int PORT = 0;//端口号 public Socket_thread(String strip) { //如: 127.0.0.1:8081 String[] stripx = strip.split(":"); this.IP = stripx[0]; this.PORT = Integer.parseInt(stripx[1]); } @Override public void run() { try { disSocket(); //连接服务器,此处会一直处于阻塞,直到连接成功 sock = new Socket(this.IP, this.PORT); //阻塞停止,表示连接成功 setMessage("连接成功", MESSAGE_SUCCEED); } catch (Exception e) { setMessage("连接服务器时异常", MESSAGE_ERROR); e.printStackTrace(); return; } try { //获取到输入输出流 outx = sock.getOutputStream(); inx = sock.getInputStream(); } catch (Exception e) { setMessage("获取输入输出流异常", MESSAGE_ERROR); e.printStackTrace(); return; } new Inx().start(); } } /** * 循环接收数据 */ class Inx extends Thread { @Override public void run() { while (true) { byte[] bu = new byte[1024]; try { int conut = inx.read(bu);//设备重启,异常 将会一直停留在这 if (conut == -1) { setMessage("服务器断开", MESSAGE_ERROR); disSocket(); return; } String strread = new String(bu, "GBK").trim(); setMessage(strread, MESSAGE_RECEIVE); } catch (IOException e) { System.out.println(e); } } } } /** * 断开连接 */ private void disSocket() { if (sock != null) { try { outx.close(); inx.close(); sock.close(); sock = null; } catch (Exception e) { setMessage("断开连接时发生错误", MESSAGE_ERROR); } } } @SuppressLint("HandlerLeak") private Handler handler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.arg1) { case MESSAGE_ERROR: disSocket(); strMsg.append(msg.obj + "<br>"); tvContent.setText(Html.fromHtml(strMsg.toString())); break; case MESSAGE_SUCCEED: strMsg.append(msg.obj + "<br>"); tvContent.setText(Html.fromHtml(strMsg.toString())); break; case MESSAGE_RECEIVE: //收到数据 strMsg.append(msg.obj); if (!strMsg.toString().substring(strMsg.length() - 4, strMsg.length()).equals("<br>")) { strMsg.append("<br>"); } tvContent.setText(Html.fromHtml(strMsg.toString())); svContent.fullScroll(ScrollView.FOCUS_DOWN); break; default: break; } } }; /** * 发送消息 */ private void sendStrSocket(final String senddata) { new Thread(new Runnable() { @Override public void run() { try { String str = "<font color='#EE2C2C'>" + senddata + "</font>"; outx.write(str.getBytes("gbk"));//"utf-8" } catch (Exception e) { setMessage("数据发送异常", MESSAGE_ERROR); } } }).start(); } /** * 消息处理 */ private void setMessage(String obj, int arg1){ Message message = new Message(); message.arg1 = arg1; message.obj = obj; handler.sendMessage(message); } /*************************************************************服务端(用于测试)**********************************************************************/ private String msg = ""; public class Server { ServerSocket serverSocket = null; public final int port = 8081; public Server() { //输出服务器的IP地址 try { InetAddress addr = InetAddress.getLocalHost(); serverSocket = new ServerSocket(port); } catch (IOException e) { e.printStackTrace(); } } public void startService() { try { while (true) { Socket socket = null; socket = serverSocket.accept();//等待一个客户端的连接,在连接之前,此方法是阻塞的 new ConnectThread(socket).start(); new ConnectThread1(socket).start(); } } catch (IOException e) { e.printStackTrace(); } } /** * 向客户端发送信息 */ class ConnectThread extends Thread { Socket socket = null; public ConnectThread(Socket socket) { super(); this.socket = socket; } @Override public void run() { try { DataOutputStream out = new DataOutputStream(socket.getOutputStream()); while (true) { Thread.sleep(1000); if (!TextUtils.isEmpty(msg)) { String str = "<font color='#4F94CD'>" + msg + "</font>"; out.write(str.getBytes("gbk")); out.flush(); msg = ""; } } } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } } } /** * 接收客户端信息 */ class ConnectThread1 extends Thread { Socket socket = null; public ConnectThread1(Socket socket) { super(); this.socket = socket; } @Override public void run() { try { DataInputStream inp = new DataInputStream(socket.getInputStream()); while (true) { byte[] bu = new byte[1024]; int conut = inp.read(bu);//设备重启,异常 将会一直停留在这 if (conut == -1) { setMessage("服务器断开", MESSAGE_ERROR); return; } String strread = new String(bu, "GBK").trim(); setMessage(strread, MESSAGE_RECEIVE); } } catch (IOException e) { e.printStackTrace(); } } } } private void sendString(String str) { msg = str; } }
运行效果:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持猪先飞。
上一篇: Androi原生绘图工具Paint
下一篇: android商户扫码枪读取手机二维码
相关文章
- 下面我们来看一篇关于Android子控件超出父控件的范围显示出来方法,希望这篇文章能够帮助到各位朋友,有碰到此问题的朋友可以进来看看哦。 <RelativeLayout xmlns:an...2016-10-02
Android开发中findViewById()函数用法与简化
findViewById方法在android开发中是获取页面控件的值了,有没有发现我们一个页面控件多了会反复研究写findViewById呢,下面我们一起来看它的简化方法。 Android中Fin...2016-09-20- 如果我们的项目需要做来电及短信的功能,那么我们就得在Android模拟器开发这些功能,本来就来告诉我们如何在Android模拟器上模拟来电及来短信的功能。 在Android模拟...2016-09-20
- 夜神android模拟器如何设置代理呢?对于这个问题其实操作起来是非常的简单,下面小编来为各位详细介绍夜神android模拟器设置代理的方法,希望例子能够帮助到各位。 app...2016-09-20
- 为了增强android应用的用户体验,我们可以在一些Button按钮上自定义动态的设置一些样式,比如交互时改变字体、颜色、背景图等。 今天来看一个通过重写Button来动态实...2016-09-20
- 如果我们要在Android应用APP中加载html5页面,我们可以使用WebView,本文我们分享两个WebView加载html5页面实例应用。 实例一:WebView加载html5实现炫酷引导页面大多...2016-09-20
- 深入理解Android中View和ViewGroup从组成架构上看,似乎ViewGroup在View之上,View需要继承ViewGroup,但实际上不是这样的。View是基类,ViewGroup是它的子类。本教程我们深...2016-09-20
- 下面我们来看一篇关于Android自定义WebView网络视频播放控件开发例子,这个文章写得非常的不错下面给各位共享一下吧。 因为业务需要,以下代码均以Youtube网站在线视...2016-10-02
- java开发的Android应用,性能一直是一个大问题,,或许是Java语言本身比较消耗内存。本文我们来谈谈Android 性能优化之MemoryFile文件读写。 Android匿名共享内存对外A...2016-09-20
- TextView默认是横着显示了,今天我们一起来看看Android设置TextView竖着显示如何来实现吧,今天我们就一起来看看操作细节,具体的如下所示。 在开发Android程序的时候,...2016-10-02
- 这篇文章主要介绍了c# socket网络编程,server端接收,client端发送数据,大家参考使用吧...2020-06-25
android.os.BinderProxy cannot be cast to com解决办法
本文章来给大家介绍关于android.os.BinderProxy cannot be cast to com解决办法,希望此文章对各位有帮助呀。 Android在绑定服务的时候出现java.lang.ClassCastExc...2016-09-20- 这篇文章主要介绍了JS WebSocket断开原因和心跳机制,对websocket感兴趣的同学,可以参考下...2021-05-08
- 这篇文章主要介绍了Android 实现钉钉自动打卡功能的步骤,帮助大家更好的理解和学习使用Android,感兴趣的朋友可以了解下...2021-03-15
- 这篇文章主要介绍了C#实现Socket通信的解决方法,需要的朋友可以参考下...2020-06-25
- 本篇文章主要介绍了C# Socket异步通信,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-25
- 下面我们来看一篇关于Android 开发之布局细节对比:RTL模式 ,希望这篇文章对各位同学会带来帮助,具体的细节如下介绍。 前言 讲真,好久没写博客了,2016都过了一半了,赶紧...2016-10-02
- 这篇文章主要为大家详细介绍了PC蓝牙通信C#代码实现,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-06-25
- 首先如果要在程序中使用sdcard进行存储,我们必须要在AndroidManifset.xml文件进行下面的权限设置: 在AndroidManifest.xml中加入访问SDCard的权限如下: <!--...2016-09-20
- 在.NET平台下创建C#串口通信程序,.NET 2.0提供了串口通信的功能,其命名空间是System.IO.Ports,创建C#串口通信程序的具体实现是如何的呢?让我们开始吧...2020-06-25