本站首页 收藏本站
广告位联系

APP正在开发中...
返回顶部
您的位置： 主页 > 软件编程 > Android >

收藏
分享到

Android中socket通信的实现

Android 来源：互联网搜集 作者：秩名 发布时间：2020-04-05 17:19:40 人浏览
摘要

socket通信需要有一个服务器和客户端，可以把同一个APP作为服务器跟客户端，也可以分开成两个APP。 先上个图： 这里以一个APP作为服务器跟客户端为示例 1、添加网络访问权限 ? 1 uses-permission android:name = android.permission.INTERNET / uses-permiss

socket通信需要有一个服务器和客户端，可以把同一个APP作为服务器跟客户端，也可以分开成两个APP。
先上个图：

这里以一个APP作为服务器跟客户端为示例

1、添加网络访问权限

?
1
<uses-permission android:name="android.permission.INTERNET" />

2、写服务器，在APP上启动

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
 
public class Server {
 
 ServerSocket serverSocket = null;
 public final int port = 9998;
 private int i = 0;
 
 public Server(){
 
  //输出服务器的IP地址
  try {
   InetAddress addr = InetAddress.getLocalHost();
   System.out.println("local host:"+addr);
   serverSocket = new ServerSocket(port);
   System.out.println("0k");
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
 
 public void startService(){
 
  try {
   Socket socket = null;
   System.out.println("waiting...");
   //等待连接，每建立一个连接，就新建一个线程
   while(true){
    socket = serverSocket.accept();//等待一个客户端的连接，在连接之前，此方法是阻塞的
    System.out.println("connect to"+socket.getInetAddress()+":"+socket.getLocalPort());
    new ConnectThread(socket).start();
   }
 
  } catch (IOException e) {
   // TODO Auto-generated catch block
   System.out.println("IOException");
   e.printStackTrace();
  }
 }
 
 //向客户端发送信息
 class ConnectThread extends Thread{
  Socket socket = null;
 
  public ConnectThread(Socket socket){
   super();
   this.socket = socket;
  }
 
  @Override
  public void run(){
   try {
    DataInputStream dis = new DataInputStream(socket.getInputStream());
    DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
    while(true){
     i++;
     String msgRecv = dis.readUTF();
     System.out.println("msg from client:"+msgRecv);
     dos.writeUTF(msgRecv + i);
     dos.flush();
    }
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
 }
}
 

需要在线程中调用，调用方法：

?
1
new Thread(() -> new Server().startService()).start();
 

3、客户端代码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
import androidx.appcompat.app.AppCompatActivity;
 
/**
 * @author fenghaitao
 * @time 2020年4月2日14:34:33
 * scoket客户端连接测试
 */
public class SocketActivity extends AppCompatActivity {
 //IP地址和端口号
 public static String IP_ADDRESS = "";
 public static int PORT = 9998;
 //三个控件
 EditText et_message = null; //需要发送的内容
 Button bt_getAdress = null; //获取本机IP地址
 Button bt_connect = null; //连接并发送
 Button bt_startServer = null; //启动服务端
 TextView tv_adress = null; //ip地址
 TextView tv_reply = null; //服务器回复的消息
 //handler
 Handler handler = null;
 Socket soc = null;
 DataOutputStream dos = null;
 DataInputStream dis = null;
 String messageRecv = null;
 
 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_socket);
  et_message = findViewById(R.id.et_message);
  bt_getAdress = findViewById(R.id.bt_getAdress);
  bt_connect = findViewById(R.id.bt_connect);
  bt_startServer = findViewById(R.id.bt_startServer);
 
  tv_adress = findViewById(R.id.tv_adress);
  tv_reply = findViewById(R.id.tv_reply);
  bt_getAdress.setOnClickListener(v -> {
   new Thread(() -> {
    try {
     InetAddress addr = InetAddress.getLocalHost();
     System.out.println("local host:"+addr);
     runOnUiThread(() -> tv_adress.setText(addr.toString().split("/")[1]));
    } catch (UnknownHostException e) {
     e.printStackTrace();
    }
   }).start();
  });
 
  bt_startServer.setOnClickListener(v -> {
   new Thread(() -> new Server().startService()).start();
   Toast.makeText(SocketActivity.this,"服务已启动",Toast.LENGTH_SHORT).show();
  });
  bt_connect.setOnClickListener(v -> {
   IP_ADDRESS = tv_adress.getText().toString();
   new ConnectionThread(et_message.getText().toString()).start();
  });
  handler = new Handler(msg -> {
   Bundle b = msg.getData(); //获取消息中的Bundle对象
   String str = b.getString("data"); //获取键为data的字符串的值
   tv_reply.append(str);
   return false;
  });
 }
 
 //新建一个子线程，实现socket通信
 class ConnectionThread extends Thread {
  String message = null;
 
  public ConnectionThread(String msg) {
   message = msg;
  }
 
  @Override
  public void run() {
   if (soc == null) {
    try {
     //Log.d("socket","new socket");
     if ("".equals(IP_ADDRESS)) {
      return;
     }
     soc = new Socket(IP_ADDRESS, PORT);
     //获取socket的输入输出流
     dis = new DataInputStream(soc.getInputStream());
     dos = new DataOutputStream(soc.getOutputStream());
    } catch (IOException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }
   try {
    dos.writeUTF(message);
    dos.flush();
    messageRecv = dis.readUTF();//如果没有收到数据，会阻塞
    Message msg = new Message();
    Bundle b = new Bundle();
    b.putString("data", messageRecv);
    msg.setData(b);
    handler.sendMessage(msg);
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
 }
}
 

下面是xml页面代码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout 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=".SocketActivity">
 <LinearLayout
  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:layout_marginTop="10dp">
   <Button
    android:id="@+id/bt_getAdress"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="获取IP地址"/>
 
   <TextView
    android:id="@+id/tv_adress"
    android:layout_width="200dp"
    android:layout_height="match_parent"
    android:layout_marginLeft="15dp"
    android:textSize="20dp"
    android:gravity="center"/>
  </LinearLayout>
  <Button
   android:id="@+id/bt_startServer"
   android:text="启动服务"
   android:layout_marginTop="10dp"
   android:layout_width="wrap_content"
   android:layout_height="wrap_content"/>
  <EditText
   android:id="@+id/et_message"
   android:layout_marginTop="10dp"
   android:hint="请输入发送信息"
   android:layout_width="wrap_content"
   android:layout_height="wrap_content"/>
  <Button
   android:id="@+id/bt_connect"
   android:text="连接发送"
   android:layout_marginTop="10dp"
   android:layout_width="wrap_content"
   android:layout_height="wrap_content"/>
 
  <TextView
   android:id="@+id/tv_reply"
   android:layout_width="wrap_content"
   android:layout_height="wrap_content"
   android:layout_marginTop="10dp"
   android:text="服务端返回消息："
   android:textSize="30sp"/>
 </LinearLayout>
</LinearLayout>
 

客户端跟服务器进行通信之前记得先启动服务器，如果端口被占用需要换个端口。
版权声明 : 本文内容来源于互联网或用户自行发布贡献，该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权， 违法违规的内容， 请发送邮件至2530232025#qq.cn(#换@)举报，一经查实，本站将立刻删除。

您可能感兴趣的文章 :

原文链接 : https://blog.csdn.net/weixin_42574892/article/details/105270472
相关文章

  • Kotlin的Collection与Sequence操作异同点介绍

    Kotlin的Collection与Sequence操作异同点介绍
    在Android开发中，集合是我们必备的容器，Kotlin的标准库中提供了很多处理集合的方法，而且还提供了两种基于容器的工作方式：Collection 和

  • 实现一个Kotlin函数类型方法

    实现一个Kotlin函数类型方法
    接口与函数类型 业务开发中，经常会有实现一个函数式接口（即接口只有一个方法需要实现）的场景，大家应该都会不假思索的写出如下代
  • Android10 App启动Activity源码分析
    ActivityThread的main方法 让我们把目光聚焦到ActivityThread的main方法上。 ActivityThread的源码路径为/frameworks/base/core/java/android/app/ActivityThread。 1 2

  • Android10客户端事务管理ClientLifecycleManager源码解析

    Android10客户端事务管理ClientLifecycleManager源码解析
    在Android 10 App启动分析之Activity启动篇（二）一文中，简单地介绍了Activity的生命周期管理器是如何调度Activity进入onCreate生命周期的流程。这

  • Kotlin对象的懒加载方式by lazy与lateinit异同介绍

    Kotlin对象的懒加载方式by lazy与lateinit异同介绍
    属性或对象的延时加载是我们相当常用的，一般我们都是使用 lateinit 和 by lazy 来实现。 他们两者都是延时初始化，那么在使用时那么他们两

  • Android类加载流程分析

    Android类加载流程分析
    本文分析的代码基于Android8.1.0源码。 流程分析 从loadClass开始，我们来看下Android中类加载的流程 /libcore/ojluni/src/main/java/java/lang/ClassLoader.ja

  • Android实现读写USB串口数据的代码

    Android实现读写USB串口数据的代码
    最近在研究USB方面的内容；先后做了关于Android读写HID、串口设备的DEMO。本文比较简单，主要介绍的是Android实现读取串口数据的功能 废话不
  • Epoxy - 在RecyclerView中构建复杂界面
    Diffing 对于复杂数据结构支持的多个视图类型展示在屏幕上, Epoxy此时是尤其有用的. 在这些场景中, 数据可能会被网络请求, 异步 Observable, 用

  • Android性能优化的详细介绍

    Android性能优化的详细介绍
    性能优化是一个app很重要的一部分，一个性能优良的app从被下载到启动到使用都能给用户到来很好的体验。自然我们做性能优化也是从被下

  • Android进阶宝典-插件化2（Hook启动插件中四大组件

    Android进阶宝典-插件化2（Hook启动插件中四大组件
    在上一节，我们主要介绍了如果通过反射来加载插件中的类，调用类中的方法；既然插件是一个apk，其实最重要的是启动插件中的Activity、
推荐阅读
最新更新
友情链接
  • 本站所有内容来源于互联网或用户自行发布，本站仅提供信息存储空间服务，不拥有版权，不承担法律责任。如有侵犯您的权益，请您联系站长处理！
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计