实验四-基于Socket的CS程序

1、精选优质文档-倾情为你奉上淮海工学院计算机工程学院实验报告书课程名： 计算机网络 题 目： 基于Socket的C/S程序开发 班 级： G 学 号： 姓 名： 评语：成绩： 指导教师： 批阅时间： 年 月 日专心-专注-专业一、 实验目的理解和巩固传输层与套接字的基本知识，掌握利用套接字实现面向连接的数据传输的一般方法，深入理解客户/服务器工作模式，学会简单的客户/服务器程序的开发。二、 实验内容利用Java语言提供的Socket技术，建立一个C/S模式的应用，允许客户端用户输入2个整数，服务器端接收这2个整数，并计算出它们的和、差、积、商，最后送回客户端。服务器端ServerSocket类（

2、.ServerSocket ）构造方法:public ServerSocket(int port) throws IOExceptionS_1接受连接请求：public Socket accept() throws IOExceptionS_2客户端Socket类（.Socket）构造方法：public Socket(String host, int port) throws UnknownHostException, IOException C_1读取数据：public InputStream getInputStream() throws IOExceptio

3、nS_5，C_3发送数据：public OutputStream getOutputStream() throws IOExceptionS_3，C_4服务器端编程创建ServerSocket对象ServerSocket server=new ServerSocket(8000);监听来自客户端的请求Socket linkSocket=server.accept();与客户端进行通信利用linkSocket.getInputStream() 接收客户端数据；对读取的数据进行加、减、乘、除计算；利用linkSocket.getoutputStream() 向客户端发送计算结果；监听结束时关闭服务

4、器server.close();客户端编程建立连接Socket client=new Socket(“ServerComputerName”, 8000);与服务器进行通信从键盘读入两个整数；利用client.getoutputStream() 向服务器端发送数据；利用client.getInputStream() 接收服务器端结果；显示从服务器端得到的结果；释放连接Client.close();要求：在一台主机上安装并运行服务器端程序，在另一台计算机上安装并运行客户端程序，测试所编写的程序能否完成规定的功能。 三、 实验步骤与源程序源程序：服务器：import .*;import java.

5、util.*;import java.io.*;import java.awt.*;import java.awt.event.*;import javax.swing.*;public class Serverpublic Server() ServerSocket server=null;Server_thread thread;Socket you=null;while(true)try server=new ServerSocket(8755); catch(IOException e1) System.out.println("正在监听"); /ServerSoc

6、ket对象不能重复创建 try System.out.println("等待客户呼叫");you=server.accept();System.out.println("已连接到客户");System.out.println("客户的地址:"+you.getInetAddress(); catch (IOException e) System.out.println("正在等待客户"); if(you!=null) new Server_thread(you).start(); /为每个客户启动一个专门的线程 pu

7、blic static void main(String args) new Server(); class Server_thread extends ThreadSocket socket;DataOutputStream out=null;DataInputStream in=null;String s=null;boolean quesion=false;Server_thread(Socket t) socket=t;try out=new DataOutputStream(socket.getOutputStream();in=new DataInputStream(socket.

8、getInputStream();catch (IOException e)public void run()while(true) double a=new double2; int i=0;trys=in.readUTF();/堵塞状态，除非读取到信息quesion=false;StringTokenizer fenxi=new StringTokenizer(s,",");while(fenxi.hasMoreTokens() && quesion=false)String temp=fenxi.nextToken();try ai=Double.va

9、lueOf(temp).doubleValue();i+; catch(NumberFormatException e) out.writeUTF("请输入数字字符");quesion=true;if(quesion=false)double s=a0+a1; double p=a0-a1;double q=a0*a1; double r=a0/a1;out.writeUTF(" "+a0+"+"+a1+"="+s);out.writeUTF(" "+a0+"-"+a1+&q

10、uot;="+p);out.writeUTF(" "+a0+"*"+a1+"="+q);out.writeUTF(" "+a0+"/"+a1+"="+r);System.out.println("客服端数据："+a0+"和"+a1);System.out.println("完成客户端运算");catch (IOException e)System.out.println("客户离开");

11、 return; 客户端：import .*;import java.io.*;import java.awt.*;import java.awt.event.*;import javax.swing.*;public class Client extends Frame implements Runnable,ActionListener DataInputStream in = null;DataOutputStream out = null;Panel p;Label lab1,lab2,lab3;TextField tf1,tf2,tf3;Button connection,send;

12、Socket socket = null; Thread thread; TextArea text; public Client() super("客户端：");setLayout(new FlowLayout();setSize(300,250); /设置窗口大小setLocation(200,200);/设置窗口显示位置setResizable(false);p=new Panel();p.setLayout(null); p.setBounds(0,0,300,250);addWindowListener(new WindowAdapter()public void

13、 windowClosing(WindowEvent e) System.exit(0); );text = new TextArea();lab1=new Label("输入IP地址:"); lab1.setBounds(5,5,60,25);lab2=new Label("第一个数字:"); lab2.setBounds(5,35,60,25);lab3=new Label("第二个数字:"); lab3.setBounds(5,65,60,25);tf1=new TextField(10); tf1.setBounds(80,5

14、,100,25);tf2=new TextField(10); tf2.setBounds(80,35,100,25);tf3=new TextField(10); tf3.setBounds(80,65,100,25); connection=new Button("连接服务器");connection.setBounds(200,5,90,25);connection.addActionListener(this);send=new Button("发送数据");send.setBounds(200,65,90,25);send.addActionL

15、istener(this);text=new TextArea(200,50);text.setBounds(5,100,290,110);p.add(lab1); p.add(lab2); p.add(lab3);p.add(tf1); p.add(tf2); p.add(tf3);p.add(connection); p.add(send);p.add(text); add(p);setVisible(true);socket=new Socket();thread = new Thread(this);public void actionPerformed(ActionEvent e)

16、if(e.getSource()=connection)InetAddress address=null;InetSocketAddress socketAddress=null;try /请求和服务器建立套接字连接：if(socket.isConnected() else address=InetAddress.getByName(tf1.getText();socketAddress=new InetSocketAddress(address,8755);socket.connect(socketAddress,2000);/*等待2秒中in =new DataInputStream(so

17、cket.getInputStream();out = new DataOutputStream(socket.getOutputStream(); send.setEnabled(true);JOptionPane.showMessageDialog(this,"连接成功!","成功！",JOptionPane.INFORMATION_MESSAGE);thread.start(); catch(IOException ex) System.out.println("time out"+ex);System.out.println(

18、socketAddress.getHostName()+":"+socketAddress.getPort(); JOptionPane.showMessageDialog(this,"连接超时!","错误！",JOptionPane.ERROR_MESSAGE);new Client();dispose();if(e.getSource()=send) String s=tf2.getText()+","+tf3.getText();if(s!=null) try out.writeUTF(s); catch(IOException e1)public void run