Java网络编程学习笔记

时间：2021-06-01 00:07:03

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+"\r\n");

			}

		} catch (IOException e) {

			e.printStackTrace();

		}

	}

	@Override

	public void actionPerformed(ActionEvent e) {

		//进行相应的操作

		if(e.getSource()==jb)

		{

			//点击发送按钮后，将消息发送出去

			String resp=jtf.getText();

			jta.append("你对客户端说：  "+resp+"\r\n");

			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+"\r\n");

					}

				} 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+"\r\n");

			pw.println(resp);

			//清空

			jtf.setText("  ");

		}

	}

}



代码执行过程截图如下：


Java网络编程学习笔记



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