前言
目录1.网络基础1.1 计算机网络分层计算机网络分为五层：物理层、数据链路层、网络层、运输层、应用层 其中：
1.2 端口号（PORT）端口号规定为16位，即允许一个IP主机有2的16次方65535个不同的端口。其中：
1.3 C/S结构
如图：  可以看出，Socket的使用可以基于TCP或者UDP协议。 1.4 TCP协议
这样就完成TCP三次握手 = 一条TCP连接建立完成 = 可以开始发送数据
为什么TCP建立连接需要三次握手？答：防止服务器端因为接收了早已失效的连接请求报文从而一直等待客户端请求，从而浪费资源
采用“三次握手”的办法可以防止上述现象发生：
为什么TCP释放连接需要四次挥手？为了保证双方都能通知对方“需要释放连接”，即在释放连接后都无法接收或发送消息给对方
1.5 UDP协议
1.6 HTTP协议详情请看我写的另外一篇文章你需要了解的HTTP知识都在这里了！ 2. Socket定义
Socket ={(IP地址1:PORT端口号)，(IP地址2:PORT端口号)}3. 原理
具体原理图如下： 4. Socket 与 Http 对比
由于二者不属于同一层面，所以本来是没有可比性的。但随着发展，默认的Http里封装了下面几层的使用，所以才会出现
5. 使用步骤
// 步骤1：创建客户端 & 服务器的连接 // 创建Socket对象 & 指定服务端的IP及端口号 Socket socket = new Socket('192.168.1.32', 1989); // 判断客户端和服务器是否连接成功 socket.isConnected());// 步骤2：客户端 & 服务器 通信// 通信包括：客户端 接收服务器的数据 & 发送数据 到 服务器 <-->作1：接收服务器的数据 --> // 步骤1：创建输入流对象InputStream InputStream is = socket.getInputStream() // 步骤2：创建输入流读取器对象 并传入输入流对象 // 该对象作用：获取服务器返回的数据 InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); // 步骤3：通过输入流读取器对象 接收服务器发送过来的数据 br.readLine()； <-->作2：发送数据 到 服务器 --> // 步骤1：从Socket 获得输出流对象OutputStream // 该对象作用：发送数据 OutputStream outputStream = socket.getOutputStream(); // 步骤2：写入需要发送的数据到输出流对象中 outputStream.write（（'Carson_Ho'+'\n'）.getBytes('utf-8')）； // 特别注意：数据的结尾加上换行符才可让服务器端的readline()停止阻塞 // 步骤3：发送数据到服务端 outputStream.flush(); // 步骤3：断开客户端 & 服务器 连接 os.close(); // 断开 客户端发送到服务器 的连接，即关闭输出流对象OutputStream br.close(); // 断开 服务器发送到客户端 的连接，即关闭输入流读取器对象BufferedReader socket.close(); // 最终关闭整个Socket连接6. 具体实例
6.1 客户端 实现步骤1：加入网络权限 uses-permission android:name='android.permission.INTERNET' />步骤2：主布局界面设置
Button android:id='@+id/connect' android:layout_width='match_parent' android:layout_height='wrap_content' android:text='connect' /> Button android:id='@+id/disconnect' android:layout_width='match_parent' android:layout_height='wrap_content' android:text='disconnect' /> TextView android:id='@+id/receive_message' android:layout_width='match_parent' android:layout_height='wrap_content' /> Button android:id='@+id/Receive' android:layout_width='match_parent' android:layout_height='wrap_content' android:text='Receive from message' /> EditText android:id='@+id/edit' android:layout_width='match_parent' android:layout_height='wrap_content' /> Button android:id='@+id/send' android:layout_width='match_parent' android:layout_height='wrap_content' android:text='send'/>步骤3：创建Socket连接、客户端 & 服务器通信
MainActivity.java package scut.carson_ho.socket_carson;import android.os.Bundle;import android.os.Handler;import android.os.Message;import android.support.v7.app.AppCompatActivity;import android.view.View;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.Socket;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class MainActivity extends AppCompatActivity { /** * 主 变量 */ // 主线程Handler // 用于将从服务器获取的消息显示出来 private Handler mMainHandler; // Socket变量 private Socket socket; // 线程池 // 为了方便展示,此处直接采用线程池进行线程管理,而没有一个个开线程 private ExecutorService mThreadPool; /** * 接收服务器消息 变量 */ // 输入流对象 InputStream is; // 输入流读取器对象 InputStreamReader isr ; BufferedReader br ; // 接收服务器发送过来的消息 String response; /** * 发送消息到服务器 变量 */ // 输出流对象 OutputStream outputStream; /** * 按钮 变量 */ // 连接 断开连接 发送数据到服务器 的按钮变量 private Button btnConnect, btnDisconnect, btnSend; // 显示接收服务器消息 按钮 private TextView Receive,receive_message; // 输入需要发送的消息 输入框 private EditText mEdit; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); /** * 初始化操作 */ // 初始化所有按钮 btnConnect = (Button) findViewById(R.id.connect); btnDisconnect = (Button) findViewById(R.id.disconnect); btnSend = (Button) findViewById(R.id.send); mEdit = (EditText) findViewById(R.id.edit); receive_message = (TextView) findViewById(R.id.receive_message); Receive = (Button) findViewById(R.id.Receive); // 初始化线程池 mThreadPool = Executors.newCachedThreadPool(); // 实例化主线程,用于更新接收过来的消息 mMainHandler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.what) { case 0: receive_message.setText(response); break; } } }; /** * 创建客户端 & 服务器的连接 */ btnConnect.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { // 利用线程池直接开启一个线程 & 执行该线程 mThreadPool.execute(new Runnable() { @Override public void run() { try { // 创建Socket对象 & 指定服务端的IP 及 端口号 socket = new Socket('192.168.1.172', 8989); // 判断客户端和服务器是否连接成功 System.out.println(socket.isConnected()); } catch (IOException e) { e.printStackTrace(); } } }); } }); /** * 接收 服务器消息 */ Receive.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { // 利用线程池直接开启一个线程 & 执行该线程 mThreadPool.execute(new Runnable() { @Override public void run() { try { // 步骤1：创建输入流对象InputStream is = socket.getInputStream(); // 步骤2：创建输入流读取器对象 并传入输入流对象 // 该对象作用：获取服务器返回的数据 isr = new InputStreamReader(is); br = new BufferedReader(isr); // 步骤3：通过输入流读取器对象 接收服务器发送过来的数据 response = br.readLine(); // 步骤4:通知主线程,将接收的消息显示到界面 Message msg = Message.obtain(); msg.what = 0; mMainHandler.sendMessage(msg); } catch (IOException e) { e.printStackTrace(); } } }); } }); /** * 发送消息 给 服务器 */ btnSend.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { // 利用线程池直接开启一个线程 & 执行该线程 mThreadPool.execute(new Runnable() { @Override public void run() { try { // 步骤1：从Socket 获得输出流对象OutputStream // 该对象作用：发送数据 outputStream = socket.getOutputStream(); // 步骤2：写入需要发送的数据到输出流对象中 outputStream.write((mEdit.getText().toString()+'\n').getBytes('utf-8')); // 特别注意：数据的结尾加上换行符才可让服务器端的readline()停止阻塞 // 步骤3：发送数据到服务端 outputStream.flush(); } catch (IOException e) { e.printStackTrace(); } } }); } }); /** * 断开客户端 & 服务器的连接 */ btnDisconnect.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { try { // 断开 客户端发送到服务器 的连接，即关闭输出流对象OutputStream outputStream.close(); // 断开 服务器发送到客户端 的连接，即关闭输入流读取器对象BufferedReader br.close(); // 最终关闭整个Socket连接 socket.close(); // 判断客户端和服务器是否已经断开连接 System.out.println(socket.isConnected()); } catch (IOException e) { e.printStackTrace(); } } }); }}6.2 服务器 实现
步骤1：导入 请直接移步到百度网盘：下载链接（密码: q73e） 步骤2：创建服务器线程 package mina;// 导入包public class TestHandler extends IoHandlerAdapter { @Override public void exceptionCaught(IoSession session, Throwable cause) throws Exception { System.out.println('exceptionCaught: ' + cause); } @Override public void messageReceived(IoSession session, Object message) throws Exception { System.out.println('recieve : ' + (String) message); session.write('hello I am server'); } @Override public void messageSent(IoSession session, Object message) throws Exception { } @Override public void sessionClosed(IoSession session) throws Exception { System.out.println('sessionClosed'); } @Override public void sessionOpened(IoSession session) throws Exception { System.out.println('sessionOpen'); } @Override public void sessionIdle(IoSession session, IdleStatus status) throws Exception { }}步骤3：创建服务器主代码 package mina;import java.io.IOException;import java.net.InetSocketAddress;import org.apache.mina.filter.codec.ProtocolCodecFilter;import org.apache.mina.filter.codec.textline.TextLineCodecFactory;import org.apache.mina.transport.socket.nio.NioSocketAcceptor;public class TestServer { public static void main(String[] args) { NioSocketAcceptor acceptor = null; try { acceptor = new NioSocketAcceptor(); acceptor.setHandler(new TestHandler()); acceptor.getFilterChain().addLast('mFilter', new ProtocolCodecFilter(new TextLineCodecFactory())); acceptor.setReuseAddress(true); acceptor.bind(new InetSocketAddress(8989)); } catch (Exception e) { e.printStackTrace(); } }}至此，客户端 & 服务器的代码均实现完毕。 6.3 测试结果
6.4 源码地址7. 总结
请帮顶或评论点赞！因为你的鼓励是我写作的最大动力！ |
|
|
来自： fishpan_oliver > 《待分类》
