Socket编程

通信基础：ip地址（位置）、协议（语言）、端口（软件程序）；

java提供网络功能的四大类：

InetAddress没有构造函数，不够里面有一些方法是可以返回实例，如：

InetAddress.getLocalHost();返回本机的实例；

InetAddress.getByName(String NAME);根据主机名或ip返回实例；

URL类实例化后可以获取URL的主机名、端口、文件的路径、文件名等等信息，需要注意的是，如果URL在实例化时没有指定端口号，会传入默认端口号，通过url.getPort()获取的端口号是-1而不是80；

URL提供了一个openStream（），用来获取URL的输入流，例：

public void urlTest() throws IOException {
URL baidu = new URL("http://www.baidu.com");
InputStream in = baidu.openStream();//获取URL的输入流，此时输入流是字节数组
InputStreamReader isr = new InputStreamReader(in,"utf-8");//将输入流转换为字符输入流
BufferedReader br = new BufferedReader(isr);//为字符流添加缓冲
String data = br.readLine();
while(data!=null) {
System.out.println(data);
data = br.readLine();
}
br.close();
isr.close();
in.close();
}

给予TCP协议实现网络通信的类：

客户端：Socket类

服务器端；ServerSocket类

Socket实现通信的步骤：

常用的创建构造方法及常用方法：

ServerSocket类：

构造方法：

ServerSocket（int port）；指定端口号创建ServerSocket类；

调用方法：

accept();监听并接收此套接字的连接，返回一个Socket；

close（）；关闭套接字

getInetAddress（），返回InetAddress类，返回服务器的本地地址；

getLocalPort（），返回int类，返回套接字监听的接口；

Socket类：

构造方法：

Socket（String host，int port）；指定主机地址和端口创建Socket类；

调用方法；

close（）；关闭套接字

getInetAddress（），返回InetAddress类，返回套接字的本地地址；

getLocalPort（），返回int类，返回套接字绑定的接口；

getInputStream（），返回InputStream类，获取套接字的输入流

getOutputStream（），返回OutputStream类，获取套接字的输出流

通过Socket编码演示实现服务器端和客户端之间的通讯：

服务器端：

package com.Socket;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class server {
public static void main(String[] args) throws IOException {
ServerSocket serversocket = new ServerSocket(8889);//创建服务器套接字
System.out.println("===服务器即将启动，正在等待客户端的连接===");
Socket socket = serversocket.accept();//开始监听，等待客户端的连接
InputStream in = socket.getInputStream();//获取输入流
InputStreamReader inr = new InputStreamReader(in);//将字节输入流转为字符输入流
BufferedReader binr = new BufferedReader(inr);//将输入流添加到缓冲流
String info =null;
while((info = binr.readLine())!=null) {
System.out.println("我是服务器，客户端说："+info);
}
socket.shutdownInput();
OutputStream output = socket.getOutputStream();
PrintWriter pw = new PrintWriter(output);
pw.write("欢迎您");
pw.flush();
pw.close();
binr.close();
inr.close();in.close();
socket.close();
serversocket.close();
}
}

客户端：

package com.Socket;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class client {
public static void main(String[] args) throws UnknownHostException, IOException {
Socket socket = new Socket("localhost",8889);//创建客户端Socket套接字
OutputStream output = socket.getOutputStream();//创建字节输出流
PrintWriter pw = new PrintWriter(output);//将输出流包装为打印流
pw.write("用户名：admin；密码：123");
pw.flush();
socket.shutdownOutput();
InputStream in = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(in));
String info;
while((info = br.readLine())!=null) {
System.out.print("客户端对我说："+info);
}
br.close();
in.close();
pw.close();
output.close();
socket.close();
}

}

多线程的通信：

建立一个线程类：

package com.Socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread extends Thread {
Socket socket = null;
public ServerThread(Socket socket) {
this.socket = socket;
}
public void run() {
try {
InputStream in = socket.getInputStream();//获取输入流
InputStreamReader inr = new InputStreamReader(in);//将字节输入流转为字符输入流
BufferedReader binr = new BufferedReader(inr);//将输入流添加到缓冲流
String info =null;
while((info = binr.readLine())!=null) {
System.out.println("我是服务器，客户端说："+info);
}
socket.shutdownInput();
OutputStream output = socket.getOutputStream();
PrintWriter pw = new PrintWriter(output);
pw.write("欢迎您");
pw.flush();
if(pw!=null)
pw.close();
if(binr!=null)
binr.close();
if(inr!=null)
inr.close();
if(in!=null)
in.close();
if(socket!=null)
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

在服务器类中循环调用accept（）方法并不断实例化线程类，在accept（）连接返回一个Socket后又继续调用进行监听：

package com.Socket;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class server {
public static void main(String[] args) throws IOException {
ServerSocket serversocket = new ServerSocket(8889);//创建服务器套接字
Socket socket = null;
int count = 0;
System.out.println("===服务器即将启动，正在等待客户端的连接===");
while(true) {
socket = serversocket.accept();
//开始监听，等待客户端的连接
ServerThread serverthread = new ServerThread(socket);
serverthread.start();
count++;
System.out.println("客户端的数量："+count);
InetAddress address =socket.getInetAddress();
System.out.println("客户端的IP："+address);
}
}
}

这样既可实现多客户端的多次连接；

UDP信息传输

DatagramPacket:表示数据报包

DatagramSocket:表示端到端通信的类

服务器端：

package com.Socket;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

public class Udpserver {
public static void main(String[] args) throws IOException {
DatagramSocket socket = new DatagramSocket(8887);//创建Socket
byte[] data = new byte[1024];//创建数组，在创建数据报的时候需将该字节数组传入
DatagramPacket packet = new DatagramPacket(data, data.length);//创建数据报,将数据传入数组中
System.out.println("服务器已经启动，正在等待客户端的连接=====");
socket.receive(packet);//等待接收数据报，在接收前会一直阻塞
String info = new String(data,0,packet.getLength());
System.out.println("我是服务器，客户端发来信息："+info);
//向客户端相应数据
InetAddress address = packet.getAddress();//根据传过来的数据报获取客户端的地址
int port = packet.getPort();//获取客户端端口
byte[] data2 = "欢迎您".getBytes();
DatagramPacket packet2 = new DatagramPacket(data2, data2.length,address,port);
socket.send(packet2);
socket.close();
}
}

客户端：

package com.Socket;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;

public class Udpclient {
public static void main(String[] args) throws IOException {
InetAddress adress = InetAddress.getByName("localhost");
int port = 8887;
byte[] data = "用户名：admin；密码：123".getBytes();//定义发送信息并存到字节数组中
DatagramPacket packet =new DatagramPacket(data,data.length,adress,port);//将定义好的字节数组和传送的目标地址，目标端口封装成数据报
DatagramSocket socket = new DatagramSocket();//创建socket套接字
socket.send(packet);//发送数据报
byte[] data3 = new byte[1024];
DatagramPacket packet3 =new DatagramPacket(data3,data3.length);
socket.receive(packet3);
String info2 = new String(data3,0,packet3.getLength());
System.out.println("服务器对我说："+info2);
socket.close();
}
}