java学习之路――基于TCP的Socket网络通信实例(一)

2014-11-24 03:02:54 · 作者: · 浏览: 0

第一部分:

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;

/**

*

* 类名:SeverOutputThread

* 功能:建立主服务器的输出线程类, 向客户端传送信息

* 时间:

* 作者:lcq

* 版本:

*

*/

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.Socket;

public class SeverOutputThread extends Thread{

Socket socket = new Socket();

public SeverOutputThread(Socket socket){