Android Socket编程(tcp)初探

简介: 前言之前一直对socket编程这块比较陌生,并且在刚开始工作的时候比较抗拒。其实,都是因为当时自己比较菜,这块比较难处理,在舒适区呆的习惯了。所以,还是应该让自己走出舒适区,多接触一些陌生的区域。

前言

之前一直对socket编程这块比较陌生,并且在刚开始工作的时候比较抗拒。其实,都是因为当时自己比较菜,这块比较难处理,在舒适区呆的习惯了。所以,还是应该让自己走出舒适区,多接触一些陌生的区域。

首先

在将socket编程前,先了解一下socket的知识。

TCP/IP协议

我们举个不恰当的例子:比如通过QQ和服务器进行通信,都需要哪些东西呢?
两台电脑建立连接进行通信,需要知道双方的地址(也就是IP地址);知道两台电脑的IP地址之后,我们还需要知道我发送到目标电脑的目标软件(使用端口标记)。如果两台电脑连接成功之后就可以进行通信了。
那么这些东西如何进行规定的呢,这就需要有一定的通讯协议,比如我和张三约定在西安钟楼见面,然后两个人都必须手拿一把白色茉莉花。只有当我们双方见面并且看到对方拿的是我们之前商量好的白色茉莉花才可以进行通讯。那么,这个白色茉莉花就是我们之间的约定,也就是socket中的协议。大家都使用这个协议,统一成一个规范,这样符合这个规范的各种设备之间能够进行兼容性的通信。
最为广泛的的协议就是OSI协议和TCP/IP协议了,但是OSI协议较为繁琐,未推广(想了解的自己Google)。反而TCP/IP(transfer control protocol/internet protocol,传输控制协议/网际协议)协议简单明了,得到现今的广泛使用。


img_fa239603af4710b08aa18a5bd2e2c2c3.png
协议.png
img_b08accee80c621c8e38ad3bbd799697f.jpe
协议传输示意图.jpg

其次

说了那么多的文字性描述,那么接下来看看我们的基于TCP协议的客户端和服务端实现

  • 客户端图片
    这里封装到了线程中,如果需要修改,那么自行修改,小可这里只是抛砖引玉,废话不说先上图


    img_028f6f3a0ba4b2cea5bdd0be8de70ff9.png
    tcp客户端.png
  • 客户端代码(线程中)
    代码中的注释比较详细,我这里就不逐一解释了

    public class TcpClientThread extends Thread {
    
    //IP地址
    private String address;
    //端口
    private int port;
    //发送内容
    private String msg;
    private Handler mHandler;
    
    public TcpClientThread(Handler handler, String address, int port, String msg) {
      this.mHandler = handler;
      this.address = address;
      this.port = port;
      this.msg = msg;
    }
    
    @Override
    public void run() {
      super.run();
      sendSocket();
    }
    
    /**
     * 设置
     */
    private void sendSocket() {
      InputStreamReader reader = null;
      BufferedReader bufReader = null;
      Socket socket = null;
      try {
          //1.创建监听指定服务器地址以及指定服务器监听的端口号
          //IP地址,端口号
          socket = new Socket(address, port);
          // 2.拿到客户端的socket对象的输出流发送给服务器数据
          OutputStream os = socket.getOutputStream();
          //写入要发送给服务器的数据
          os.write(msg.getBytes());
          os.flush();
          socket.shutdownOutput();
          //拿到socket的输入流,这里存储的是服务器返回的数据
          InputStream is = socket.getInputStream();
          //解析服务器返回的数据
          reader = new InputStreamReader(is);
          bufReader = new BufferedReader(reader);
          String s = null;
          final StringBuffer sb = new StringBuffer();
          while ((s = bufReader.readLine()) != null) {
              sb.append(s);
          }
          sendMsg(0, sb.toString());
      } catch (UnknownHostException e) {
          e.printStackTrace();
      } catch (IOException e) {
          e.printStackTrace();
      } finally { //3、关闭IO资源
          try {
              if (bufReader != null)
                  bufReader.close();
          } catch (IOException ex) {
              ex.printStackTrace();
          }
          try {
              if (socket != null)
                  socket.close();
          } catch (IOException ex) {
              ex.printStackTrace();
          }
    
      }
     }
    
    /**
     * 发送消息
     */
    private void sendMsg(int what, Object object) {
      Message msg = new Message();
      msg.what = what;
      msg.obj = object;
      mHandler.sendMessage(msg);
    }
    }
    
  • 客户端(Activity中使用)

    public class TcpClientActivity extends AppCompatActivity 
       implements   View.OnClickListener {
    
      EditText mEdtContent;
     TextView mTxtContent;
     Button mBtnSend;
     String address = "192.168.0.197";
     int port = 12345;
    
    
     @Override
     protected void onCreate(@Nullable Bundle savedInstanceState) {
      super.onCreate(savedInstanceState);
      setContentView(R.layout.activity_tcpclient);
      initView();
     }
    
    private void initView() {
      mEdtContent = findViewById(R.id.edt_content);
      mBtnSend = findViewById(R.id.btn_send);
      mTxtContent = findViewById(R.id.txt_content);
      mBtnSend.setOnClickListener(this);
    }
    
     @Override
     public void onClick(View view) {
      switch (view.getId()) {
          case R.id.btn_send: {//发送
              TcpClientThread mThread = new TcpClientThread(mHandler, address, port,
                      mEdtContent.getText().toString());
              mThread.start();
    
              break;
          }
      }
    }
    
    /**
     * Handler
     */
    private Handler mHandler = new Handler(Looper.myLooper()) {
      @Override
      public void handleMessage(Message msg) {
          super.handleMessage(msg);
          switch (msg.what) {
              case 0: {
                  String content= (String) msg.obj;
                  mTxtContent.setText(content);
                  break;
              }
          }
      }
    };
    }
    
  • 服务端(图片)

    img_eba7c33ddc5d608b5bff1101055face3.png
    tcp服务端.png
  • 服务端(代码-->线程中)

    public class TcpServerThread extends Thread {
     private Socket socket;
    
    /**
     * 初始化
     * 
     * @param socket
     */
    public TcpServerThread(Socket socket) {
      this.socket = socket;
    }
    
    @Override
    public void run() {
      super.run();
    
      InputStreamReader reader = null;
      BufferedReader bufReader = null;
      OutputStream os = null;
      try {
          reader = new InputStreamReader(socket.getInputStream());
          bufReader = new BufferedReader(reader);
          String s = null;
          StringBuffer sb = new StringBuffer();
          while ((s = bufReader.readLine()) != null) {
              sb.append(s);
          }
          System.out.println("服务器:" + sb.toString());
          // 关闭输入流
          socket.shutdownInput();
    
          // 返回给客户端数据
          os = socket.getOutputStream();
          os.write(("我是服务端,客户端发给我的数据就是:" + sb.toString()).getBytes());
          os.flush();
          socket.shutdownOutput();
      } catch (IOException e2) {
          e2.printStackTrace();
      } finally {// 关闭IO资源
          if (reader != null) {
              try {
                  reader.close();
              } catch (IOException e) {
                  e.printStackTrace();
              }
          }
    
          if (bufReader != null) {
              try {
                  bufReader.close();
              } catch (IOException e) {
                  e.printStackTrace();
              }
          }
          if (os != null) {
              try {
                  os.close();
              } catch (IOException e) {
                  e.printStackTrace();
              }
          }
      }
    
    }
    
    }
    
  • 服务端(调用)

    public class TcpServer {
    
    /**
     * @param args
     */
    public static void main(String[] args) {
      try {
          @SuppressWarnings("resource")
          ServerSocket serverSocket = new ServerSocket(12345);
          while (true) {
              System.out.println("Server开始~~~监听~~~");
              // accept方法会阻塞,直到有客户端与之建立连接
              Socket socket = serverSocket.accept();
              TcpServerThread serverThread = new TcpServerThread(socket);
              serverThread.start();
          }
      } catch (IOException e) {
          e.printStackTrace();
      }
    }
    }
    
  • 说明
    这里用了一个while循环,然后就可以无限接收客户端发送的数据,如果把while中的条件改成你需要的,就会实现你所需要的东西。

最后

刚开始写的时候自己也是一脸懵逼,克服了重重困难才做了出来,当然这种也不是最终的,没有加入自己的协议。需要根据自己的实际需求做出来,然后改成自己的需要的东西。

致谢

Android网络编程之--Socket编程

相关文章
|
1月前
|
网络协议 Linux 网络性能优化
Linux基础-socket详解、TCP/UDP
综上所述,Linux下的Socket编程是网络通信的重要组成部分,通过灵活运用TCP和UDP协议,开发者能够构建出满足不同需求的网络应用程序。掌握这些基础知识,是进行更复杂网络编程任务的基石。
80 1
|
1月前
|
网络协议 测试技术 网络安全
Python编程-Socket网络编程
Python编程-Socket网络编程
|
3月前
|
网络协议 Java
一文讲明TCP网络编程、Socket套接字的讲解使用、网络编程案例
这篇文章全面讲解了基于Socket的TCP网络编程,包括Socket基本概念、TCP编程步骤、客户端和服务端的通信过程,并通过具体代码示例展示了客户端与服务端之间的数据通信。同时,还提供了多个案例分析,如客户端发送信息给服务端、客户端发送文件给服务端以及服务端保存文件并返回确认信息给客户端的场景。
一文讲明TCP网络编程、Socket套接字的讲解使用、网络编程案例
|
2月前
|
网络协议 Linux
TCP 和 UDP 的 Socket 调用
【9月更文挑战第6天】
|
4月前
|
网络协议 开发者 Python
深度探索Python Socket编程:从理论到实践,进阶篇带你领略网络编程的魅力!
【7月更文挑战第25天】在网络编程中, Python Socket编程因灵活性强而广受青睐。本文采用问答形式深入探讨其进阶技巧。**问题一**: Socket编程基于TCP/IP,通过创建Socket对象实现通信,支持客户端和服务器间的数据交换。**问题二**: 提升并发处理能力的方法包括多线程(适用于I/O密集型任务)、多进程(绕过GIL限制)和异步IO(asyncio)。**问题三**: 提供了一个使用asyncio库实现的异步Socket服务器示例,展示如何接收及响应客户端消息。通过这些内容,希望能激发读者对网络编程的兴趣并引导进一步探索。
48 4
|
4月前
|
网络协议 Python
网络世界的建筑师:Python Socket编程基础与进阶,构建你的网络帝国!
【7月更文挑战第26天】在网络的数字宇宙中,Python Socket编程是开启网络世界大门的钥匙。本指南将引领你从基础到实战,成为网络世界的建筑师。
63 2
|
4月前
|
网络协议 程序员 视频直播
|
4月前
|
开发者 Python
Python Socket编程:不只是基础,更有进阶秘籍,让你的网络应用飞起来!
【7月更文挑战第25天】在网络应用蓬勃发展的数字时代,Python凭借其简洁的语法和强大的库支持成为开发高效应用的首选。本文通过实时聊天室案例,介绍了Python Socket编程的基础与进阶技巧,包括服务器与客户端的建立、数据交换等基础篇内容,以及使用多线程和异步IO提升性能的进阶篇。基础示例展示了服务器端监听连接请求、接收转发消息,客户端连接服务器并收发消息的过程。进阶部分讨论了如何利用Python的`threading`模块和`asyncio`库来处理多客户端连接,提高应用的并发处理能力和响应速度。掌握这些技能,能使开发者在网络编程领域更加游刃有余,构建出高性能的应用程序。
31 3
|
4月前
|
消息中间件 网络协议 网络安全
Python Socket编程:打造你的专属网络通道,基础篇与进阶篇一网打尽!
【7月更文挑战第26天】在网络编程领域,Python以简洁语法和强大库支持成为构建应用的首选。Socket编程为核心,实现计算机间的数据交换。
64 1
|
3月前
|
网络协议
socket编程(2) -- TCP通信
socket编程(2) -- TCP通信
38 0