Java网络编程学习笔记

Java网络编程，我们先来看下面这一张图：

由图可得：想要进行网络编程，首先是服务器端通过ServerSocket对某一个端口进行监听。通过accept来判断是否有客户端与其相连。若成功连上，则通过readline和println函数来进行数据的发送和接收。实现网络编程。

示例如下：

服务器端代码：

/*
 * 功能：演示Java网络编程的服务器端
 * author：ywq
 */
import java.io.*;
import java.net.*;
public class TestServer {

	InputStreamReader isr;
	BufferedReader br;
	PrintWriter pw;

	
	public static void main(String[] args) {
		TestServer ts=new TestServer();

	}
    public TestServer()
    {

    	try {
    		//监听某个端口
			ServerSocket ss=new ServerSocket(9999);
			System.out.println("我是socket服务器正在监听9999端口.........");
			//等待某个客户端来连接，accept()函数将返回一个socket连接
			Socket s=ss.accept();
			
			//要读取s中传递的数据
			isr =new InputStreamReader(s.getInputStream());
			br=new BufferedReader(isr);
 			//通过readline()函数来读写数据
			 String info=br.readLine();
			 System.out.println("服务器收到的消息为："+info);
			
			//我们通过pw向s写数据,true表示即时刷新
			 pw=new PrintWriter(s.getOutputStream(),true);
			 pw.println("你也好，我是服务器！！！");
	 } catch (IOException e) {
 			e.printStackTrace();
		}finally{
			 try {				
 				if(pw!=null) 
 					pw.close();
				if(br!=null)
					  br.close();
				if(isr!=null)
					 isr.close();
			} catch (IOException e) {
				e.printStackTrace();
			 }
		}
    }
}

客户端代码：

/*
 * 功能：这是一个客户端，可以连接服务器端
 * author：ywq
 */
import java.io.*;
import java.net.*;
public class TestClient {

	InputStreamReader isr;
	BufferedReader br;
	PrintWriter pw;

	
	public static void main(String[] args) {
		TestClient tc=new TestClient();
	}

	public TestClient()
	{
		try {
			//socket()函数就是去连接某个服务器，ip+端口
			Socket s=new Socket("127.0.0.1",9999);
			
			//如果s连接成功，就可以发送数据到服务器端
			//我们通过pw向s写数据,true表示即时刷新
		        pw=new PrintWriter(s.getOutputStream(),true);
			 pw.println("你好，我是客户端！！！");
			
			//读取s中传递的数据
			isr =new InputStreamReader(s.getInputStream());
			br=new BufferedReader(isr);
			/ /通过readline()函数来读写数据
			 String info=br.readLine();
			System.out.println("客户端收到的消息为："+info);
			
		} catch (IOException e) {
		
			e.printStackTrace();
		}finally{
			try {				
				if(pw!=null) 
					pw.close();
				if(br!=null)
					br.close();
				if(isr!=null)
					isr.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}

	}
}

发送数据时用到了PrintlnWriter对象，标准形式为：

PrintWriter pw=new PrintWriter(s.getOutputStream(),true)

其中true参数表示即时刷新。

通过InputStreamReader以及readline函数来实现数据的读取。

下边是一个半双工的示例：

服务器端代码：

/*
 * 功能：演示从控制台进行对话
 * author：ywq
 */
import java.net.*;
import java.io.*;
public class TestServer {

	InputStreamReader isr,isr2;
	BufferedReader br,br2;
	PrintWriter pw;	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TestServer  ts=new TestServer();
	}
 
	public TestServer()
	{
		try {
			ServerSocket ss=new ServerSocket(3002);
			System.out.println("服务器在监听3002端口...");
			//判断是否有客户端连接
			Socket s=ss.accept();
			//读取来自客户端的消息
			isr=new InputStreamReader(s.getInputStream());
			br=new BufferedReader(isr);
			
			pw=new PrintWriter(s.getOutputStream(),true);
			//接收从控制台输入的信息
			isr2=new InputStreamReader(System.in);
			br2=new BufferedReader(isr2);

			
			while(true)
			{
				
				String respone=br.readLine();
				if(respone.equals("再见"))
		    	{
					System.out.println("对话结束");
		    		s.close();
		    		break;
		    	}
				System.out.println("客户端说："+respone);
				
				System.out.println("请输入要发送到客户端的信息：");
				String info=br2.readLine();				
				//将消息发送给客户端
				pw.println(info);
				if(info.equals("再见"))
		    	{
					System.out.println("对话结束");
		    		s.close();
		    		break;
		    	}
				
			}
			
		} catch (IOException e) {
			
			e.printStackTrace();
		}finally
		{
			if(br2!=null)
				try {
					br2.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			if(isr2!=null)
				try {
					isr2.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			if(pw!=null) 
				pw.close();
			if(br!=null)
				try {
					br.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			if(isr!=null)
				try {
					isr.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

		}
	}
}

客户端代码如下：

/*
 * 功能：这是一个客户端，实现从控制台输入数据
 * author：ywq
 */
import java.io.*;
import java.net.*;
public class TestClient {

	InputStreamReader isr,isr2;
	BufferedReader br,br2;
	PrintWriter pw;	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TestClient tc=new TestClient();
	}
	
	public TestClient()
	{
		try {
			Socket s=new Socket("127.0.0.1",3002);
		    pw=new PrintWriter(s.getOutputStream(),true);
		    //从控制台接收消息
		    isr=new InputStreamReader(System.in);
		    br=new BufferedReader(isr);
		    
		     //从服务器接收信息
		    isr2=new InputStreamReader(s.getInputStream());
		    br2=new BufferedReader(isr2);		   		 
		    
		    while(true)
		    {
		    	System.out.println("请说出你想对服务器说的话，按回车键结束");
		    	//得到从控制台输入的消息
		    	String resp=br.readLine();
		    	//将数据发送给服务器
		    	pw.println(resp);
		    	if(resp.equals("再见"))
		    	{ 
		    		System.out.println("客户端使对话结束");
		    		s.close();
		    		break;
		    	}
		    	
		    	
		    	String respo=br2.readLine();
		    	if(respo.equals("再见"))
		    	{ 
		    		System.out.println("服务器使对话结束");
		    		s.close();
		    		break;
		    	}
					
		    	System.out.println("服务器说："+respo);
		    	
		    }
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally
		{
			if(br2!=null)
				try {
					br2.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			if(isr2!=null)
				try {
					isr2.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			if(pw!=null) 
				pw.close();
			if(br!=null)
				try {
					br.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			if(isr!=null)
				try {
					isr.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}


		}
		
	}

}

自此，学到了基本的Java网络编程知识，有待进一步拓展。

进一步学习：

下面看一个简易对讲机的实现：

服务器端代码：

/*
 * 功能：这是一个服务器，实现简易的对讲机,带界面
 * author：ywq
 */
import javax.swing.*;

import java.net.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;

public class TestServer3 extends JFrame implements ActionListener{

	//定义组件
	JTextArea jta=null;
	JTextField jtf=null;
	JButton jb=null;
	JPanel jp=null;
	JScrollPane jsp=null;
	
	InputStreamReader isr=null;
	BufferedReader br=null;
	PrintWriter pw=null;
	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TestServer3 ts=new TestServer3();
	}
    
	public TestServer3()
	{
		//创建组件
		jta=new JTextArea();
		jtf=new JTextField(10);
		jb=new JButton("发送");
		//设置监听
		jb.addActionListener(this);
		
		jsp=new JScrollPane(jta);
		
		jp=new JPanel();		
		jp.add(jtf);
		jp.add(jb);
		
		this.add(jp,"South");
		this.add(jsp,"Center");
		
		this.setSize(300, 300);
		this.setVisible(true);
		this.setTitle("简易QQ聊天--服务器");
		this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		
	
		//建立socket连接
		try {
			ServerSocket ss=new ServerSocket(1234);
			Socket s=ss.accept();
			
			isr=new InputStreamReader(s.getInputStream());
			br=new BufferedReader(isr);
			pw=new PrintWriter(s.getOutputStream(),true);
			//做一个循环
			while(true)
			{
				//在循环中读取来自客户端的消息并且显示
				String info=br.readLine();
				jta.append("客户端说：  "+info+"
");
				
				
			}
			
			
		} catch (IOException e) {
			
			e.printStackTrace();
		}
		
		
		
		
		
	}

	@Override
	public void actionPerformed(ActionEvent e) {
		//进行相应的操作
		if(e.getSource()==jb)
		{
			//点击发送按钮后，将消息发送出去
			String resp=jtf.getText();
			jta.append("你对客户端说：  "+resp+"
");			
			pw.println(resp);
			jtf.setText("  ");
		}
		
	}
}

客户端如下：

/*
 * 功能：这是一个客户端。可以实现简易对讲机
 * author：ywq
 */

import javax.swing.*;

import java.net.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;

 public class TestClient3 extends JFrame implements ActionListener{

	   //定义组件
		JTextArea jta=null;
		JTextField jtf=null;
		JButton jb=null;
		JPanel jp=null;
		JScrollPane jsp=null;
		
		InputStreamReader isr=null;
		BufferedReader br=null;
		PrintWriter pw=null;
	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TestClient3 tc=new TestClient3();
	}
	
	public TestClient3()
	{
		//创建组件
				jta=new JTextArea();
				jtf=new JTextField(10);
				jb=new JButton("发送");
				//设置监听
				jb.addActionListener(this);
				
				jsp=new JScrollPane(jta);
				
				jp=new JPanel();		
				jp.add(jtf);
				jp.add(jb);
				
				this.add(jp,"South");
				this.add(jsp,"Center");
				
				this.setSize(300, 300);
				this.setVisible(true);
				this.setTitle("简易QQ聊天--客户端");
				this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
				
				//建立socket连接
				try {
					Socket s=new Socket("127.0.0.1",1234);
			        
					isr=new InputStreamReader(s.getInputStream());
					br=new BufferedReader(isr);
					pw=new PrintWriter(s.getOutputStream(),true);
					
					while(true)
					{
                                                //在循环中读取来自服务器的消息，并且显示
                                                 String info=br.readLine();
						jta.append("服务器说：  "+info+"
");
	
					}
					
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				
				
	}
	
	

	@Override
	public void actionPerformed(ActionEvent e) {
		//点击发送按钮后，将消息发送出去
		if(e.getSource()==jb)
		{
			String resp=jtf.getText();
			jta.append("你对服务器说：  "+resp+"
");			
			pw.println(resp);
			//清空
			jtf.setText("  ");
		}
	}

}

代码执行过程截图如下：

由截图可以看出：本实例较好的实现了聊天功能。但是距离真的模拟QQ聊天技术还差很多。有待进一步改进。