Android中socket通信的简单实现

Android中socket通信简单实现,供大家参考,具体内容如下

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

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

1、添加网络访问权限

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

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

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();
   }
  }
 }
}

需要在线程中调用,调用方法:

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

3、客户端代码

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页面代码

<?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>

客户端跟服务器进行通信之前记得先启动服务器,如果端口被占用需要换个端口。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • Android Socket通信实现简单聊天室

    socket通信是基于底层TCP/IP协议实现的.这种服务端不需要任何的配置文件和tomcat就可以完成服务端的发布,使用纯java代码实现通信.socket是对TCP/IP的封装调用,本身并不是一种协议,我们通过socket来调用协议来跟服务端进行通信和数据的传输.socket就像客户端与服务端之间的一条信息通道,每一个不同的客户端都会建立一个独立的socket,双方都没有关闭连接的话,连接-也就是建立好的这条socket通道将一直保持,服务端要跟那一个客户端通信只需要找到对应的socket对

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

    本文实例讲述了Android基于socket实现的简单C/S聊天通信功能.分享给大家供大家参考,具体如下: 主要想法:在客户端上发送一条信息,在后台开辟一个线程充当服务端,收到消息就立即回馈给客户端. 第一步:创建一个继续Activity的SocketClientActity类,包为com.pku.net 编写布局文件socketclient.xml,代码如下: <?xml version="1.0" encoding="utf-8"?> <Lin

  • Android中使用socket通信实现消息推送的方法详解

    原理 最近用socket写了一个消息推送的demo,在这里和大家分享一下. 主要实现了:一台手机向另外一台手机发送消息,这两台手机可以随时自由发送文本消息进行通信,类似我们常用的QQ. 效果图: 原理:手机通过socket发送消息到服务器,服务器每接收到一条消息之后,都会把这条消息放进一个messageList里面,服务器会不停地检测messageList是否含有消息,如果有的话就会根据messageList里面item的数据,推送到相应的另一端手机上面. 下面简单画了一个图来说明这个原理: 演

  • android利用websocket协议与服务器通信

    最近做一个项目,需求中需要服务器主动推送消息到客户端.这样的话一般的http连接就不能使用了.博主问了个朋友,向我推荐websocket协议,特此测试了一下,发现效果很好. android本身没有websocket的库,需要自己下载 ,下载地址. 客户端代码: 界面布局自己写,很简单的两个button package com.example.test; import com.example.test.R; import android.app.Activity; import android.o

  • Android Socket通信详解

    一.Socket通信简介  Android与服务器的通信方式主要有两种,一是Http通信,一是Socket通信.两者的最大差异在于,http连接使用的是"请求-响应方式",即在请求时建立连接通道,当客户端向服务器发送请求后,服务器端才能向客户端返回数据.而Socket通信则是在双方建立起连接后就可以直接进行数据的传输,在连接时可实现信息的主动推送,而不需要每次由客户端想服务器发送请求. 那么,什么是socket?Socket又称套接字,在程序内部提供了与外界通信的端口,即端口通信.通过

  • Android开发中Socket通信的基本实现方法讲解

    一.Socket通信简介 Android与服务器的通信方式主要有两种,一是Http通信,一是Socket通信.两者的最大差异在于,http连接使用的是"请求-响应方式",即在请求时建立连接通道,当客户端向服务器发送请求后,服务器端才能向客户端返回数据.而Socket通信则是在双方建立起连接后就可以直接进行数据的传输,在连接时可实现信息的主动推送,而不需要每次由客户端想服务器发送请求. 那么,什么是socket?Socket又称套接字,在程序内部提供了与外界通信的端口,即端口通信.通过建

  • python服务器与android客户端socket通信实例

    本文实例讲述了python服务器与android客户端socket通信的方法.分享给大家供大家参考.具体实现方法如下: 首先,服务器端使用python完成,下面为python代码: 复制代码 代码如下: #server.py  import socket  def getipaddrs(hostname):#只是为了显示IP,仅仅测试一下      result = socket.getaddrinfo(hostname, None, 0, socket.SOCK_STREAM)      re

  • Android中Socket通信的实现方法概述

    本文实例简述了Android中Socket通信的实现方法,具体内容如下: 一.socket通信概述 通俗的来说套接字(socket)是通信的基石,是支持TCP/IP协议的网络通信的基本操作单元.它是网络通信过程中端点的抽象表示,包含进行网络通信必须的五种信息:连接使用的协议,本地主机的IP地址,本地进程的协议端口,远地主机的IP地址,远地进程的协议端口. 应用层通过传输层进行数据通信时,TCP会遇到同时为多个应用程序进程提供并发服务的问题.多个TCP连接或多个应用程序进程可能需要通过同一个TCP

  • 详解Android 基于TCP和UDP协议的Socket通信

    本来想讲一下基础的网络通信方面的知识点,发现太枯燥乏味了,不过笔试中也经常会问到这方面的问题,所以关于通信方面的知识点,小编会放到面试中去,因为实战中也就面试会用到这方面知识点 Android与服务器的通信方式主要有两种,一是Http通信,一是Socket通信.两者的最大差异在于,http连接使用的是"请求-响应方式",即在请求时建立连接通道,当客户端向服务器发送请求后,服务器端才能向客户端返回数据. 而Socket通信中基于TCP/IP协议的通信则是在双方建立起连接后就可以直接进行数

  • Android编程之客户端通过socket与服务器通信的方法

    本文实例讲述了Android编程之客户端通过socket与服务器通信的方法.分享给大家供大家参考,具体如下: 下面是一个demo,Android客户端通过socket与服务器通信. 由于Android里面可以完全使用java.io.*包和java.net.*包,那么,实际上,逻辑部分与J2SE没有区别.只是UI代码不一样. Android客户端通过socket与服务器通信分为下面5步: (1)通过IP地址和端口实例化Socket,请求连接服务器: 复制代码 代码如下: socket = new

随机推荐