Java系列：Java Socket应用-代码实例

一.服务器端线程处理类
public class ServerThread extends Thread {
//和本线程相关的socket
Socket socket=null;
public ServerThread(Socket socket){
this.socket=socket;
}
//线程执行的操作，相应客户端请求
public void run(){
InputStream is=null;
InputStreamReader isr=null;
BufferedReader br=null;
OutputStream os=null;
PrintWriter pw=null;
try {
//3.获取输入流，读取客户端信息
is = socket.getInputStream();
isr=new InputStreamReader(is);//将字节流转化为字符流
br=new BufferedReader(isr);//将输入流添加缓冲
String info=null;
while ((info=br.readLine())!=null)
System.out.println("我是服务器，客户端说:"+info);
socket.shutdownInput();//关闭输入流
//4.获取输出流，相应客户端请求
os=socket.getOutputStream();
pw=new PrintWriter(os);
pw.write("欢迎您!");
pw.flush();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
//5.关闭资源
if(pw!=null)
pw.close();
if (os!=null)
os.close();
if(br!=null)
br.close();
if(isr!=null)
isr.close();
if(is!=null) {
is.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

二.服务器端实现步骤
1.创建datagramsocket 指定端口号
2.创建datagrampacket
3.接收客户端发送的数据信息
4.读取信息

public class Server{
public static void main(String[] args) {
try {
//1.创建一个服务器端socket，即serversocket，指定绑定的端口，并监听
ServerSocket serverSocket=new ServerSocket(8080);
//2.调用accept()方法开始监听，等待客户端连接
Socket socket=null;
int count=0;
System.out.println("服务器即将启动，等待客户端连接");
//循环监听等待客户端连接
while(true){
//调用accept()方法开始监听，等待客户端连接
socket=serverSocket.accept();
//创建一个新的线程
ServerThread serverThread=new ServerThread(socket);
//启动线程
serverThread.start();
count++;//统计客户端数量
System.out.println("客户端数量:"+count);
InetAddress address=socket.getInetAddress();
System.out.println("当前客户端IP:"+address.getHostAddress());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

三、客户端实现步骤
1.定义发送信息
2.创建datagrampacket 包含将要发送的信息
3.创建datagramsocket
4.发送数据
public class Client {
public static void main(String[] args) {
try {
//1.创建客户端socket，指定服务器地址和端口
Socket socket=new Socket("localhost",8080);
//2.获取输出流，向服务器端发送信息
OutputStream os=socket.getOutputStream();//字节输出流
PrintWriter pw=new PrintWriter(os);//将输出流包装成打印流
pw.write("用户名：admin1;密码：123");
pw.flush();
socket.shutdownOutput();//关闭输出流
//3.获取输入流。读取服务器端相应信息
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String info=null;
while ((info=br.readLine())!=null)
System.out.println("我是客户端，服务器说:"+info);
//4.关闭资源
br.close();
is.close();
pw.flush();
pw. close();
os.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}