当前位置:首页 > Java技术 > [零散篇]Java学习笔记---Java的Socket网络编程以及多线程

[零散篇]Java学习笔记---Java的Socket网络编程以及多线程

2022年08月05日 22:17:57Java技术2

1.Socket是代表两台机器之间网络连接的对象(java.net.Socket)。

   Socket的建立如下,参数分别是服务器端的IP地址和端口号: Socket socket  =  new Socket("167.5.75.1",5000);

2.    客户端(Client)Socket的使用 

 2.1 Socket读出数据步骤

// 1.创建Socket连接,告知Server的IP地址以及端口号
Socket socket = new Socket("127.0.0.1", 4242);	
// 2.创建InputStreamReader,用于读取socket输入流
InputStreamReader stream = new InputStreamReader(socket.getInputStream());
// 3.使用BufferedReader链接输入流
BufferedReader br = new BufferedReader(stream);

// 4.读出数据
String line = null;
while ((line = br.readLine()) != null)
{
System.out.println("Today's advice is: " + line);
}

// 5. 关闭输入流BufferedReader
br.close();

  2.2 Scoket写入数据步骤: 

// 1.创建Socket连接,告知Server的IP地址以及端口号
Socket socket = new Socket("127.0.0.1", 4242);
// 2.创建PrintWriter对象,用以接收socket输出流
PrintWriter writer = new PrintWriter(socket.getOutputStream());
// 3.使用PrintWriter对象写出输出数据
String advice ="Today's advice";
writer.println(advice);
// 4. 关闭连接
writer.close();

3.  服务器端(Server)Socket的使用 

// 1.创建一个SercerSocket,使用4242端口监听客户端请求
ServerSocket serverSocket = new ServerSocket(4242);
System.out.println("The server is started, listening on port 4242");

while (true)
{
// 2.ServerSocket的accept()在等待用户连接的时候闲置;在用户连接上来的时候,返回一个Socket来与客户端通信
Socket socket = serverSocket.accept();
// 3.创建PrintWriter对象,用以接收socket输出流
PrintWriter writer = new PrintWriter(socket.getOutputStream());
// 4.使用PrintWriter对象写出输出数据
String advice = "notifier's blog";
writer.println(advice);

// 5. 关闭连接
writer.close();
}

4.   线程的状态

       线程总共有5种状态:

  1. 新建 (Thread t = new Thread())

  2. 就绪 (t.start())

  3. 运行

  4. 堵塞

    线程被block的原因很多,比如: 等待IO操作, sleep(), 等待被占用对象释放

     5. 死亡

5.    解决线程同步化问题的方法是: 对使用到共享对象的方法使用synchronized

   需要注意的是:

       虽说是方法进行了synchronized,但锁不是加在方法上的而是对象上的,也就是说,是synchronized方法获取对象锁。如果对象(类)有两个或者多个synchronized方法,就表示两个线程不能同时进入同一个方法,也不能同时进入不同的方法。 因为同一时间,只有一个方法在占有对象锁。

6.    synchronized代码块

       有时候在一个方法中做了很多事情,但只有一部分逻辑是需要synchronized的,这时候我们可以使用synchronized代码块。如下,其中this表示当前对象: 

public void function()
{
	doSomething();
	
	//以下方法需要同步化
	synchronized (this)
	{
		doCriticalStuff();
		moreCriticalStuff();
	}
	
	doSomeOtherThing();
}

7. 以下是一个Socket简单的例子:

客户端代码及详细注释:

/**
 * @author notifier
 * @create 2010-9-25 上午10:12:10
 * @version 1.0
 */
public class DailyAdviceClient
{
	public static void main(String[] args)
	{
		DailyAdviceClient client = new DailyAdviceClient();
		client.receiveMsg();
	}
	
	public void receiveMsg()
	{
		try
		{
			// 1.创建Socket连接,告知Server的IP地址以及端口号
			Socket socket = new Socket("127.0.0.1", 4242);
			// 2.创建InputStreamReader,用于读取socket输入流
			InputStreamReader stream = new InputStreamReader(socket
					.getInputStream());
			// 3.使用BufferedReader链接输入流
			BufferedReader br = new BufferedReader(stream);

			// 4.读出数据
			String line = null;
			while ((line = br.readLine()) != null)
			{
				System.out.println("Today's advice is: " + line);
			}

			// 5. 关闭输入流BufferedReader
			br.close();
		} catch (UnknownHostException e)
		{
			e.printStackTrace();
		} catch (IOException e)
		{
			e.printStackTrace();
		}
	}
}

服务器端代码及详细注释:

/**
 * @author notifier
 * @create 2010-9-25 下午07:06:54
 * @version 1.0
 */
public class SimpleChatServer
{
	// 保存客户端列表
	private ArrayList clientList = new ArrayList();;
	
	public static void main(String[] args)
	{
		new SimpleChatServer().startUp();
	}
	
	/**
	 * 负责服务器端的启动
	 *
	 */
	public void startUp()
	{
		try
		{
			// 创建服务器端ServerSocket连接,监听端口号5000
			ServerSocket serverSocket = new ServerSocket(5000);
			
			// 轮询等待客户端请求
			while(true)
			{
				// 等待客户端请求,无请求则闲置;有请求到来时,返回一个对该请求的socket连接
				Socket clientSocket = serverSocket.accept();
				
				// 将该客户端加入到列表中
				PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
				clientList.add(writer);
				
				// 创建ClientHandler对象,通过socket连接通信
				Thread t = new Thread(new ClientHandler(clientSocket));
				t.start();

				System.out.println("有Client连进来");
			}
		}catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
	/**
	 * 客户端处理类, 主要负责:
	 * 1.接收客户端发来的消息
	 * 2.将消息转发其他客户端
	 * @author sdniu
	 * @create 2010-9-26 上午10:00:18
	 * @version 1.0
	 */
	public class ClientHandler implements Runnable
	{
		private BufferedReader reader;
		private Socket socket;
		
		/**
		 * ClientHandler的构造函数
		 * @param clientSocket
		 */
		public ClientHandler(Socket clientSocket)
		{
			
			try
			{
				// 得到socket连接
				socket = clientSocket;
				
				// 得到客户端发来的消息
				InputStreamReader isReader = new InputStreamReader(socket.getInputStream());
				reader = new BufferedReader(isReader);
			} catch (IOException e)
			{
				e.printStackTrace();
			}
		}
		
		public void run()
		{
			String message;
			try
			{
				while((message = reader.readLine()) != null)
				{
					System.out.println("客户端消息: " + message);
					// 将客户端发来的消息转发所有客户端
					notifyAllClients(message);
				}
			} catch (IOException e)
			{
				e.printStackTrace();
			}
		}
	}
	
	/**
	 * 
	 * @param message
	 */
	public void notifyAllClients(String message)
	{
		// 得到客户端列表的迭代器,语法格式为 Iterator it = clientList.iterator();
		Iterator it = clientList.iterator();
		
		while(it.hasNext())
		{
			try
			{
				// 得到的Iterator别忘了强制转换回PrintWriter
				PrintWriter writer = (PrintWriter) it.next();
				writer.println(message);
				writer.flush();
			} catch (Exception e)
			{
				e.printStackTrace();
			}			
		}
	}
}

8. 多线程Socket编程的例子, 代码比较长, 放在下载里了, 链接如下:

     https://files.cnblogs.com/notifier/SimpleChatroom.7z

来源链接:https://www.cnblogs.com/notifier/archive/2010/09/26/1835323.html

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/java/18004.html

分享给朋友:

“[零散篇]Java学习笔记---Java的Socket网络编程以及多线程” 的相关文章

Java空指针异常解决java.lang.NullPointerException解决心得

Java空指针异常解决java.lang.NullPointerException解决心得

今天做课设的时候运行程序报出以下错误 java.lang.NullPointerException 首先要理解的是此错误并不会在 程序中报错,只会在运行的时候报错。 是由于某个参数(集合,数组等数据)可能出现一个null值而导致后面的程序不能运行时...

Java实现Email发送

一、前言最近将项目的登录密码从图形验证码改为了短信验证码,同时也将忘记密码时长度进行了修改,在修改时,想到了之前在一些国外的网站上,使用过邮箱接收验证码的情况,故想到何妨不自己尝试整合一下Java程序发送邮件信息呢,所以动手整合了Email的发送实例。二、Email发送协议想要在互联网上提供电子邮件...

Java中四种访问修饰符的区别

在java中共有4种访问级别,按访问权限由高到低为:public(公有的)、protected(受保护的)、友好的(没有任何访问权限关键字修饰)和private(私有的)。 类型 类内部 同一个包其...

Java 内存模型

Java 内存模型

📦 本文以及示例源码已归档在 javacore Java 内存模型(Java Memory Model),简称 JMM。 JVM 中试图定义一种 JMM 来屏蔽各种硬件和操作系统的内存访问差异,以实现让 Java 程序在各种平台下都能达到一致的内存访问效果。...

Java虚拟机1:什么是Java

Java虚拟机1:什么是Java

前言 让我们来看一下Java的广告词,来自http://www.java.com/zh_CN/about/: 97%的企业桌面运行Java 美国有89%的桌面(或计算机)运行Java 全球有900万Java开发人员 开发人员的头号选择...

Java实现素数的判断

素数的定义只能被1和它本身整除,不包括1 例 2.3.5.7.11.13 实现代码 Scanner in=new Scanner(System.in); int n ; n=in.nextInt(); for(int n1=2;n1&l...

二分法(折半查找)的运用之java实现猜数字游戏

让计算机输入一个数 然后用户进行猜数游戏 一般而言,七次会猜对,如果猜不对,那么就是你的方法不对 在这儿涉及到的一个算法就是二分法 ***二分法查找,***也称为折半法,是一种在有序数组中查找特定元素的搜索算法。二分法查找的思路如下: (1)首先,从数组...

Java打印车票主要学习Java的比较语句

直接上代码 public static void main(String[] args) { // TODO Auto-generated method stub //初始化 Scanner in=new Scanner(S...

JAVA的JDK环境变量的配置JAVA

JAVA的JDK环境变量的配置JAVA

首先要在官网下载java 官网:http://www.oracle.com/technetwork/java/javase/downloads/ 到这个界面 选择我接受 记住该地址 最好的办法新建记事本,然后按ctrl+s保存 java环境变量的...

Java获取明天的时间(当前时间加一天)

import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Calendar;     public class&nbs...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。