当前位置:编程学习 > JAVA >>

java学习之路——基于TCP的Socket网络通信实例

 

第一部分:

 1.什么是socket

 

   所谓socket通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。

 2.重要的Socket API:

 

  java.net.Socket继承于java.lang.Object,有八个构造器,其方法并不多,下面介绍使用最频繁的三个方法,其它方法大家可以见JDK-1.3文档。

 

  . Accept方法用于产生"阻塞",直到接受到一个连接,并且返回一个客户端的Socket对象实例。"阻塞"是一个术语,它使程序运行暂时"停留"在这个地方,直到一个会话产生,然后程序继续;通常"阻塞"是由循环产生的。

 

  . getInputStream方法获得网络连接输入,同时返回一个IutputStream对象实例,。

 

  . getOutputStream方法连接的另一端将得到输入,同时返回一个OutputStream对象实例。

 

   注意:其中getInputStream和getOutputStream方法均会产生一个IOException,它必须被捕获,因为它们返回的流对象,通常都会被另一个流对象使用。

 

第二部分:

如何开发一个Server-Client模型的程序

 

   开发原理:

 

   服务器,使用ServerSocket监听指定的端口,端口可以随意指定(由于1024以下的端口通常属于保留端口,在一些操作系统中不可以随意使用,所以建议使用大于1024的端口),等待客户连接请求,客户连接后,会话产生;在完成会话后,关闭连接。

 

   客户端,使用Socket对网络上某一个服务器的某一个端口发出连接请求,一旦连接成功,打开会话;会话完成后,关闭Socket。客户端不需要指定打开的端口,通常临时的、动态的分配一个1024以上的端口。

 

代码示例:

1:建立主服务器类

 

package com.lcq.network; 

 

/**

 * 

 * 类名:MainServer

 * 功能:建立主服务器类,接受客户端的信息并显示,与客户端进行交互

 * 时间:

 * 作者:lcq

 * 版本:

 * 

 */ 

 

import java.net.ServerSocket; 

import java.net.Socket; 

 

public class MainServer { 

 

    /**

     * @param args

     * @throws Exception 

     */ 

    public static void main(String[] args) throws Exception { 

         

        ServerSocket serverSocket = new ServerSocket(4000); 

        //调用socket的accept()方法侦听并接受到此套接字的连接,此方法在连接传入之前一直阻塞。  

        while(true){ 

             

            Socket socket = serverSocket.accept(); 

             

            new ServerInputThread(socket).start(); 

            new SeverOutputThread(socket).start(); 

             

             

             

        } 

         

 

    } 

 

 

2:建立主服务器的两个线程类(包括向客户端输出和输入的线程)

 

package com.lcq.network; 

 

 

/**

 * 

 * 类名:ServerInputThread

 * 功能:建立主服务器的输入线程类,接收客户端的信息后打印出来

 * 时间:

 * 作者:lcq

 * 版本:

 * 

 */ 

 

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() { 

         

         

        while(true){ 

            try { 

                 

                //建立输入流 

                InputStream is = socket.getInputStream(); 

                byte[] by = new byte[1024]; 

                //将输入流里的字节读到字节数组里,并返回读的字节数 

                int length = is.read(by); 

                //将字节数组里的length个字节转换为字符串 

                String str = new String(by,0,length); 

                //打印出字符串 

                System.out.println(str); 

                 

                 

                 

            } catch (IOException e) { 

                e.printStackTrace(); 

            } 

             

        } 

    } 

 

     

     

     

     

     

     

     

     

     

     

     

 

 

 

package com.lcq.network; 

&nb

补充:软件开发 , Java ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,