[Java TCP/IP Soket]― TCP套接字的基本使用(一)

2014-11-24 07:56:26 · 作者: · 浏览: 0

一.套接字地址

客户端要发起一次通信,首先要知道运行服务器端程序的主机IP地址。在Java中,地址可以是IP地址(如192.0.2.27),

可以是主机名(server.example.com).

InetAddress类代表了一个网络目标地址,包括主机名或IP地址信息。该类有两个子类,Inet4Address和Inet6Address,

分别对应目前IP地址的两个版本。

NetworkInterface类代表了一个网络接口,其中包括了很多InetAddress网络目标地址。

二.TCP套接字

Java为TCP协议提供了两个类:Socket类和Server类。一个Socket实例代表了TCP连接的一端。一个TCP连接是一条抽象的双向信息通道,

两端分别有地址和端口号确定。在开始通信之前,必须要建立一个TCP连接,这需要先由客户端向服务端发送连接请求。ServerSocket实例

则监听连接请求,并为每个请求创建新的Socket实例。也就是说,服务端要同时处理ServerSocket实例和Socket实例,而客户端只需要使用

Socket实例。

1.TCP客户端

客户端向服务器发起连接请求后,就被动的等待服务器响应。

第一步:创建一个Socket实例:构造函数向指定的远程主机和端口建立一个TCP连接;

第二步:通过套接字的输入输出流进行通信:一个Socket实例其中包括一个InputStream和一个OutputStream;

第三步:使用Socket类的close()方法关闭连接;

TCP客户端类:

package com.tcp.test;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

public class ClientTest {

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

		InetAddress inetAddr = InetAddress.getLocalHost();
		Socket client = new Socket(inetAddr, 8888);

		OutputStream output = client.getOutputStream();
		InputStream input = client.getInputStream();

		output.write(new String("Hello Server").getBytes());
		output.flush();
		// 关闭输出流,这里必须关闭输出流,read()方法才能返回-1,否则,就会造成死锁
 		client.shutdownOutput();

 		ByteArrayOutputStream byteOutput = new ByteArrayOutputStream();
 		byte[] msg = new byte[1024];
 		int readLen = 0;
 		while ((readLen = input.read(msg)) != -1) {

 			byteOutput.write(msg, 0, readLen);
 	 	}

 		byte[] receiveMsg = byteOutput.toByteArray();
 		System.out.println("Client receive data:" + new String(receiveMsg));

		output.close();
 		input.close();
		client.close();
	}
}

2.TCP服务端

服务端的工作是建立一个通信终端,并被动地等待客户端连接。

第一步:创建一个ServerSocket实例并指定本地端口。此套接字的功能是侦听该指定端口收到的连接。

第二步:重复执行;

(1)调用ServerSocket的accept()方法以获取下一个客户端连接;

(2)使用所返回Socket实例的InputStream与OutputStream与客户端进行通信;

(3)通信完毕后,使用Socket类的close()方法关闭该客户端套接字连接;

TCP服务端类:

package com.tcp.test;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerTest {

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

		Socket client;
		OutputStream output;
		InputStream input;
		ByteArrayOutputStream byteOutput;

		ServerSocket server = new ServerSocket(8888);

		while (true) {
			byteOutput = new ByteArrayOutputStream();
			client = server.accept();
			output = client.getOutputStream();
			input = client.getInputStream();

			System.out.println("handling client at:"
					+ client.getRemoteSocketAddress());

			byte[] msg = new byte[1024];
			int readLen = 0;
			while ((readLen = input.read(msg)) != -1) {
				byteOutput.write(msg, 0, readLen);
			}

			byte[] receiveMsg = byteOutput.toByteArray();
			System.out.println("Server receive data:" + new String(receiveMsg));

			output.write(new String("Hello Client").getBytes());
			output.flush();
			client.shutdownOutput();

			input.close();
			output.close();
			cl