网络socket连接
Java API的网络功能包(java.net)已经将底层的TCP连接等都封装好了,我们只需要通过Socket对象来建立客户端和服务器的连接,然后客户端能向服务器发送请求,并接收服务端发来的数据即可
服务端和客户端大概的交互如下所示:
编写客户端程序
第一步:建立socket连接
需要客户端和服务器端都建立以下连接
Socket chatSocket=new Socket(“对方IP地址”,TCP端口号);
IP类似门牌号,做寻址,找到服务器。端口号是找到这台服务器上的某个程序
端口号是一个用来识别服务器上特定程序的数字,在某台机器上,会唯一标识某个程序
每个服务器上的端口号限制为0~65536,而0~1023都已经保留给已知的特定服务(例如HTTP的端口为80,HTTPS的为443),所以我们自己的程序要用1024~65536的端口号,且不要和当前机器已有的程序冲突端口号
第二步:用PrintWriter写数据到Socket上
1.建立链接到Socket的PrintWriter
PrintWriter writer=new PrintWriter(chatSocket.getOutputStream());
2.写入数据
writer.println(“message to send”);
writer.print(“another message”);
第三步:使用BufferedReader从Socket上读取数据
Socket可以用串流来进行连接沟通,和上一章讲的文件到对象的串流一样,我们并不在意上游实际是什么,只要是串流BufferedReader就可以接收
1.从Socket连接上获得低层输入串流的InputStreamReader
InputStreamReader stream = new InputStreamReader(chatSocket.getInputStream());
2.建立BufferedReader来读取InputStreamReader
BufferedReader reader= new BufferedReader(stream);
String message=reader.readLine();
编写简单的服务器程序
服务器的引用程序需要创建两个Socket。一个用来等待用户请求的ServerSocket;一个与用户通信用的Socket。
第一步:使用特定端口创建ServerSocket
ServerSocket serverSock=new ServerSocket(4242);//该服务器会去监听来4242端口的客户端请求
第二步:客户端对服务器引用程序建立Socket连接
Socket sock=new Socket(“127.0.0.1”,4242);//服务器的ip和监听端口
第三步:服务器创建与客户端通信的新Socket
Socket sock=serverSock.accept();
accept()等待用户连接,如果有用户连接会返回一个和ServerSocket不同端口号的Socket,通过上面讲的PrintWriter来给客户端传送数据
如果没有用户连接,那程序会一直停留在accept()这步,直到有用户连入才会执行下一步
说明:一定要先启动服务端后,客户端才可以和服务端进行连接,否则会抛出连接不上Socket的异常
我们什么时候去接口服务端返回的请求呢?隔一段时间去查询一次服务器?或者每次发送信息时都去查询一次?都不是很合理(因为我们要有Socket才能去查询)。java有多线程,可以实现单独开启一个线程,一直用来等待服务器信息
java多线程multithreading
线程:线程是独立的,它有独立的执行空间。每个Java程序都会启动一个主线程(main()),程序需要自己去创建需要的其他线程
线程实际上不是并发执行的(除非是多处理器),它是在100毫秒内切换不同的线程去执行(具体由Java虚拟机的线程调度机制决定),让人们感觉是在并行处理的
使用java.lang.Thread类创建线程,它有启动线程、连接线程和让线程闲置的方法
启动一个线程的方法如下:
Runnable threadJob=new MyRunnable();//线程要执行的任务,Runnable是一个接口,只有一个public void run(){}方法
Thread t=new Thread(threadJob);//建立Thread对象,并赋值Runnable任务
t.start();//启动线程,这时才会开启一个线程并执行Runnable任务
线程说明:
1.也可以通过继承Thread,子类重写run()方法来创建新进程,但这种方法不建议
2.run()是新线程所执行的第一个方法
3.线程执行完毕run()后就不能重复启动了
4.线程start()后就处于可执行状态
5.调度器选择某个线程后,它就处于可执行状态,单处理器的机器只能有一个执行中的线程
6.调度不一定是完全公平的,不是所有机器上调度都是完全一致的
7.有时线程会因为某些原因堵塞
8.添加sleep()会使执行中的线程强制离开执行中状态变为休眠,当sleep时间结束后变为可执行状态
线程并发会引起的问题:数据存取或更新问题
如果多个线程操作同一个对象的某一数据(getter或setter),如果其他线程引用时没有去查询当前数据的状态,有可能造成严重的问题。(例如文中的例子A查询余额充足后就进入可执行状态了,B花了钱;A再次进入执行中状态时没有检查余额直接花钱,导致余额不足的情况下扣钱了)
解决方法:通过synchronized关键字添加同步化的方法
例如private synchronized void makeWithdrawal(int amount){}
说明:每一个对象都一个锁,每个锁只有一把钥匙。通常对象都没有上锁,只有看到同步化的synchronized方法时才会上锁,同步化的目标是保护重要的数据,实际锁住的是存取数据的方法。只有同步化的方法结束后才会放开钥匙
同步化会引发的问题:死锁,如果同步化的两个进程互相需要持有对方正在等待的东西,就会造成死锁