网络编程--使用TCP/IP的套接字（Socket）进行通信

1、什么是Socket？

Socket是连接运行在网络上的两个程序间的双向通讯的端点。

2、使用Socket进行网络通信的过程

（1）服务器程序将一个套接字绑定到一个特定的端口，并通过此套接字等待和和监听客户的连接请求。
（2）客户程序根据服务器程序所在的主机名和端口号发出连接请求。


image.png

（3）如果一切正常，服务器接受连接请求。并获得一个新的绑定到不同端口地址的套接字。
（4）客户和服务器通过读写套接字进行通讯。


image.png

（5）使用ServerSocket和Socket实现服务器端和客户端的Socket通信总结：
  • 建立Socket连接
  • 获得输入/输出流
  • 读/写数据
  • 关闭输入/输出流
  • 关闭Socket
image.png

3、代码实现

（1）未使用线程的实现
  • 服务器端
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 使用ServerSocket和Socket实现服务器端和客户端的 Socket通信
 * 这是服务器端
 * @author Chuan
 *
 */
public class TcpServer
{
    public static void main(String[] args) throws IOException
    {
        ServerSocket serverSocket = new ServerSocket(5000);
        
        Socket socket = serverSocket.accept();
        
        InputStream is = socket.getInputStream();
        OutputStream os = socket.getOutputStream();
        
        //读取客户端的会话
        byte[] buffer = new byte[1024];
        int length = is.read(buffer);
        System.out.println(new String(buffer, 0, length));
        
        os.write("welcom".getBytes());
        
        
        is.close();
        os.close();
        socket.close();
        serverSocket.close();
    }
}
  • 客户端代码
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 使用ServerSocket和Socket实现服务器端和客户端的 Socket通信
 * 这是客户端
 * @author Chuan
 *
 */
public class TcpClient
{
    public static void main(String[] args) throws UnknownHostException, IOException
    {
        Socket socket = new Socket("127.0.0.1", 5000);
        
        OutputStream oStream = socket.getOutputStream();
        InputStream iStream = socket.getInputStream();
        
        //向服务端发送消息
        oStream.write("hello".getBytes());
        
        //读取服务端发送过来的消息
        byte[] buffer = new byte[1024];
        int length = iStream.read(buffer);
        System.out.println(new String(buffer, 0, length));
        
        oStream.close();
        iStream.close();
        socket.close();
    }
}
（2）使用线程实现
  • 服务器端MainServer
    服务器端使用了两个线程：接收会话线程ServerInputThread，发送会话线程ServerOutputThread。需要注意的是在服务端使用了一个whlie循环，而客户端没有。这样做的原因是服务端可能需要处理来自不同客户端的连接将请求，没有一个客户端请求连接就会获得一个新的绑定到不同端口地址的套接字。
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 *服务器端
 * @author Chuan
 *
 */
public class MainServer
{
    public static void main(String[] args) throws IOException
    {
        @SuppressWarnings("resource")
        ServerSocket ss = new ServerSocket(4000);
        
        /**
         * 此处的while循环是为了可能有多个客户端，但是本程序中当有多个客户端时，
         * 客户端向服务端发消息没问题，服务端再往客户端发消息就会出问题，不能发送给相应的客户端
         */
        while (true)
        {
            Socket socket = ss.accept();
            new ServerInputThread(socket).start();
            new ServerOutputThread(socket).start();
        }   
    }
}
  • 接收会话线程ServerInputThread
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

/*
 * 服务器端的读取会话线程
 */
public class ServerInputThread extends Thread
{
    private Socket socket;
    
    public ServerInputThread(Socket socket)
    {
        this.socket = socket;
    }

    @Override
    public void run()
    {
        try
        {
            InputStream is = socket.getInputStream();
            byte[] buffer = new byte[1024];
            int length;
            while (true)
            {   
                length = is.read(buffer);
                System.out.println(new String(buffer, 0, length));
                
            }
            
        }
        catch (IOException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}
  • 发送会话线程ServerOutputThread
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

/*
 * 服务器端的发送会话线程
 */
public class ServerOutputThread extends Thread
{
    private Socket socket;
    
    public ServerOutputThread(Socket socket)
    {
        this.socket = socket;
    }
    
    @Override
    public void run()
    {
        try
        {
            OutputStream os = socket.getOutputStream();
            while (true)
            {
                BufferedReader br = new BufferedReader(
                        new InputStreamReader(System.in));
                String str = br.readLine();
                os.write(str.getBytes());
            }
        }
        catch (IOException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }
}
  • 客户端代码MainClient
    客户端代码中也使用了两个线程：接收会话线程ClientInputThread，发送会话线程ClientOutputThread
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 客户端
 * @author Chuan
 *
 */
public class MainClient
{
    public static void main(String[] args) throws UnknownHostException, IOException
    {
        Socket socket = new Socket("127.0.0.1", 4000);
        
            new ClientInputThread(socket).start();
            new ClientOutputThread(socket).start();
    }
}
  • 接收会话线程ClientInputThread，和服务端接手会话线程大同小异
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

/**
 * 客户端的读取会话线程
 */
public class ClientInputThread extends Thread
{
    private Socket socket;
    
    public ClientInputThread(Socket socket)
    {
        this.socket = socket;
    }
    
    @Override
    public void run()
    {
        try
        {
            InputStream is = socket.getInputStream();
            byte[] buffer = new byte[1024];
            int length;
            while (true)
            {   
                length = is.read(buffer);
                System.out.println(new String(buffer, 0, length));
                
            }
            
        }
        catch (IOException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}
  • 发送会话线程ClientOutputThread
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

/**
 * 客户端的发送会话线程
 */
public class ClientOutputThread extends Thread
{
    private Socket socket;
    
    public ClientOutputThread(Socket socket)
    {
        this.socket = socket;
    }
    
    @Override
    public void run()
    {
        try
        {
            OutputStream os = socket.getOutputStream();
            while (true)
            {
                BufferedReader br = new BufferedReader(
                        new InputStreamReader(System.in));
                String str = br.readLine();
                os.write(str.getBytes());
            }
        }
        catch (IOException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }
}
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 202,529评论 5赞 475
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,015评论 2赞 379
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 149,409评论 0赞 335
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,385评论 1赞 273
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,387评论 5赞 364
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,466评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,880评论 3赞 395
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,528评论 0赞 256
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,727评论 1赞 295
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,528评论 2赞 319
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,602评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,302评论 4赞 318
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,873评论 3赞 306
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,890评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,132评论 1赞 259
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,777评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,310评论 2赞 342

推荐阅读更多精彩内容