JAVA-socket通信基础(2)
2015-02-25 21:29
260 查看
由于现实情况远远复杂过理想情况,单线程的C/S结构不能满足实际的需求,使用多线程配合socket进行C/S服务的模拟。典型的方法是服务器端为每一个客户连接运行一个后台线程,这个后台线程是一个socket负责处理服务器和客户端之间的通信。
以下是服务器端程序代码:
package Server2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server2 {
public static void main(String[] args) throws IOException {
System.out.println("Server is starting……");
ServerSocket server=new ServerSocket(8888);
while(true){
Socket s =server.accept();
System.out.println("Accepting connection……");
new ServerThread(s).start();
}
}
}
//定义Server线程
class ServerThread extends Thread{
//在Server线程中有一个socket对象,可以在构造对象时给这个socket对象赋值。
private Socket s;
ServerThread(Socket s){
this.s=s;
}
public void run(){
//线程执行的run方法
BufferedReader br=null;
PrintWriter pw=null;
try {
//socket.getInputStream()获取这个连接的输入流,并且新建一个输入流保存它,连接客户端后这时在isr中已经有数据了
InputStreamReader isr=new InputStreamReader(s.getInputStream());
//使用BufferedReader包裹,创建的输入流(这是一种常见的写法,需要理解记忆)
br=new BufferedReader(isr);
//实例化输出流,传输socket的输出
pw=new PrintWriter(s.getOutputStream(),true);
//将BufferedReader中的一行数据读出
String name=br.readLine();
System.out.println("用户访"+name+"问服务器");
pw.println("我是server,欢迎你"+name);
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println(e.toString());
}finally{
System.out.println("Connection is closing");
}
try {
br.close();
pw.close();
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
这里顺带明确一下throws Exception和try/catch的区别:
throws在声明方法时候,如果不声明throws的话,那么一般的Exception都要在这个方法中终结。所以他必须有相应的catch处理编译时的一场来避免错误的发生。throws Exception是写在方法后面的,属于契约式编程,就是告诉编译器本方法可能会抛出该类型异常,由方法的调用者去处理,当声明了throws之后,异常将会被抛出,就像是石头被丢出去一样。但有些异常不能捕捉,这时候就要用到try/catch了。
在你编写的程序中,有些语句可以会发生异常,这时Java编译器要求你必须 进行捕获,才可以运行。
(1)如果你不想编写捕获异常的具体代码的话,你可以使用 throws Exception 的形式, 把异常再次抛出,交给JVM(Java虚拟机)可以捕获。这是一种比较省事的办法。
(2)如果你想亲编写处理异常的代码的话,可以使用try{ }catch(){ }的形式,进行捕获, 一旦程序发生异常,它就会安照你catch{ }块编写的代码去执行。
以下是服务器端程序,多线程主要体现在客户端,Client与之前几乎相同:
package Client2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client2 {
static String readString(){
//定义静态的读入字符串方法,方法的作用是按行读取输入流数据
BufferedReader br=new BufferedReader(new InputStreamReader(System.in),1);
//读取从控制台输入的字符
String str="";
try {
str=br.readLine();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.toString());
}
return str;
}
public static void main(String[] args) {
// TODO Auto-generated method stub
String host="127.0.0.1";
BufferedReader br=null;
PrintWriter pw=null;
Socket s = null;
//定义输入输出流,socket对象
try {
s=new Socket(host,8888);
InputStreamReader isr=new InputStreamReader(s.getInputStream());
//创建输入流,从socket对象中取得输入的数据
br=new BufferedReader(isr);
pw=new PrintWriter(s.getOutputStream(),true);
System.out.println("请输入您的姓名");
String name=readString();
//调用ReadString方法,将读入的字符存入name
pw.println(name);
//传输name
System.out.println(br.readLine());
//显示从socket中取出的,接收自服务器的数据
}catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
try{
br.close();
pw.close();
s.close();
}catch(IOException e){}
}
}
}
程序运行效果如下:
以下是服务器端程序代码:
package Server2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server2 {
public static void main(String[] args) throws IOException {
System.out.println("Server is starting……");
ServerSocket server=new ServerSocket(8888);
while(true){
Socket s =server.accept();
System.out.println("Accepting connection……");
new ServerThread(s).start();
}
}
}
//定义Server线程
class ServerThread extends Thread{
//在Server线程中有一个socket对象,可以在构造对象时给这个socket对象赋值。
private Socket s;
ServerThread(Socket s){
this.s=s;
}
public void run(){
//线程执行的run方法
BufferedReader br=null;
PrintWriter pw=null;
try {
//socket.getInputStream()获取这个连接的输入流,并且新建一个输入流保存它,连接客户端后这时在isr中已经有数据了
InputStreamReader isr=new InputStreamReader(s.getInputStream());
//使用BufferedReader包裹,创建的输入流(这是一种常见的写法,需要理解记忆)
br=new BufferedReader(isr);
//实例化输出流,传输socket的输出
pw=new PrintWriter(s.getOutputStream(),true);
//将BufferedReader中的一行数据读出
String name=br.readLine();
System.out.println("用户访"+name+"问服务器");
pw.println("我是server,欢迎你"+name);
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println(e.toString());
}finally{
System.out.println("Connection is closing");
}
try {
br.close();
pw.close();
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
这里顺带明确一下throws Exception和try/catch的区别:
throws在声明方法时候,如果不声明throws的话,那么一般的Exception都要在这个方法中终结。所以他必须有相应的catch处理编译时的一场来避免错误的发生。throws Exception是写在方法后面的,属于契约式编程,就是告诉编译器本方法可能会抛出该类型异常,由方法的调用者去处理,当声明了throws之后,异常将会被抛出,就像是石头被丢出去一样。但有些异常不能捕捉,这时候就要用到try/catch了。
在你编写的程序中,有些语句可以会发生异常,这时Java编译器要求你必须 进行捕获,才可以运行。
(1)如果你不想编写捕获异常的具体代码的话,你可以使用 throws Exception 的形式, 把异常再次抛出,交给JVM(Java虚拟机)可以捕获。这是一种比较省事的办法。
(2)如果你想亲编写处理异常的代码的话,可以使用try{ }catch(){ }的形式,进行捕获, 一旦程序发生异常,它就会安照你catch{ }块编写的代码去执行。
以下是服务器端程序,多线程主要体现在客户端,Client与之前几乎相同:
package Client2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client2 {
static String readString(){
//定义静态的读入字符串方法,方法的作用是按行读取输入流数据
BufferedReader br=new BufferedReader(new InputStreamReader(System.in),1);
//读取从控制台输入的字符
String str="";
try {
str=br.readLine();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.toString());
}
return str;
}
public static void main(String[] args) {
// TODO Auto-generated method stub
String host="127.0.0.1";
BufferedReader br=null;
PrintWriter pw=null;
Socket s = null;
//定义输入输出流,socket对象
try {
s=new Socket(host,8888);
InputStreamReader isr=new InputStreamReader(s.getInputStream());
//创建输入流,从socket对象中取得输入的数据
br=new BufferedReader(isr);
pw=new PrintWriter(s.getOutputStream(),true);
System.out.println("请输入您的姓名");
String name=readString();
//调用ReadString方法,将读入的字符存入name
pw.println(name);
//传输name
System.out.println(br.readLine());
//显示从socket中取出的,接收自服务器的数据
}catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
try{
br.close();
pw.close();
s.close();
}catch(IOException e){}
}
}
}
程序运行效果如下:
相关文章推荐
- JAVA-socket通信基础(1)
- Java中利用socket实现简单的服务端与客户端的通信(基础级)
- JAVA-Socket通信基础
- java实现最基础的socket网络通信
- 【Java基础学习笔记】Java中Socket+Swing设计简单通信
- 上机题目(0基础)- Java网络操作-Socket实现client和server端通信二(Java)
- JAVA-socket通信基础(2)
- java基础socket通信
- Java基础知识强化之网络编程笔记02:Socket通信原理图解
- java基础之Socket通信
- JAVA语言基础:Socket 通信和多线程编程
- Java_socket通信基础补充
- JAVA-socket通信基础(1)
- java实现最基础的socket网络通信
- java网络编程基础Socket通信应用
- java网络编程基础——UDP通信之DatagramSocket
- Java网络基础,Socket通信基础
- Java Socket基础(一)
- Java Socket网络编程基础