java-Socket编程之（tcp/ip）

一、相关概念

 1为了能够方便的开发网络应用软件，由美国伯克利大学在Unix上推出了一种应用程序访问通信协议的操作系统调用socket(套接字)。socket的出现，使程序员可以很方便地访问TCP/IP，从而开发各种网络应用的程序。
随着Unix的应用推广，套接字在编写网络软件中得到了极大的普及。后来，套接字又被引进了Windows等操作系统中。Java语言也引入了套接字编程模型。
2什么是Socket?
Socket是连接运行在网络上的两个程序间的双向通讯的端点
3使用Socket进行网络通信的过程

服务器程序将一个套接字绑定到一个特定的端口，并通过此套接字等待和监听客户的连接请求。

客户程序根据服务器程序所在的主机名和端口号发出连接请求。 
4如果一切正常，服务器接受连接请求。并获得一个新的绑定到不同端口地址的套接字。（多线程并发地操作）
客户和服务器通过读、写套接字进行通讯。

 

5使用ServerSocket和Socket实现服务器端和客户端的 Socket通信

流程：

 

 总结：
1) 建立Socket连接
2) 获得输入/输出流
3）读/写数据
4) 关闭输入/输出流
5) 关闭Socket

 

6、参考程序

1）服务器端

package com.network;

import java.net.ServerSocket;
import java.net.Socket;

public class Server
{

	public static void main(String[] args) throws Exception
	{
		ServerSocket serverSocket = new ServerSocket(5678);

		while (true)
		{
			Socket socket = serverSocket.accept();

			new ServerThread(socket).start();
		}

		// InputStream is = socket.getInputStream();
		//
		// OutputStream os = socket.getOutputStream();
		//
		// byte[] buffer = new byte[100];
		//
		// int length = is.read(buffer);
		//
		// String content = new String(buffer, 0, length);
		//
		// System.out.println("read from client: " + content);
		//
		// int strLength = content.length();
		//
		// String str = String.valueOf(strLength);
		//
		// byte[] b = str.getBytes();
		//
		// os.write(b);
		//
		// is.close();
		//
		// os.close();
		//
		// socket.close();

	}

}

 

package com.network;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class ServerThread extends Thread
{
	private Socket socket;

	public ServerThread(Socket socket)
	{
		this.socket = socket;
	}

	@Override
	public void run()
	{
		try
		{
			InputStream is = socket.getInputStream();

			OutputStream os = socket.getOutputStream();

			byte[] buffer = new byte[100];

			int length = is.read(buffer);

			String content = new String(buffer, 0, length);

			System.out.println("read from client: " + content);

			int strLength = content.length();

			String str = String.valueOf(strLength);

			byte[] b = str.getBytes();

			os.write(b);

			is.close();

			os.close();

			socket.close();
		}
		catch (Exception ex)
		{
			ex.printStackTrace();
		}
	}
}

 

2、客户端

package com.network;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class Client
{

	public static void main(String[] args) throws Exception
	{
		for (int i = 0; i < 5000; ++i)
		{
			Socket socket = new Socket("localhost", 5678);

			InputStream is = socket.getInputStream();

			OutputStream os = socket.getOutputStream();

			String str = "This comes from client";

			os.write(str.getBytes());

			byte[] buffer = new byte[100];

			int length = is.read(buffer);

			String s = new String(buffer, 0, length);

			System.out.println("string's length: " + s);

			is.close();

			os.close();

			socket.close();

		}

	}

}