Chinaunix首页 | 论坛 | 博客
  • 博客访问: 783542
  • 博文数量: 738
  • 博客积分: 7000
  • 博客等级: 少将
  • 技术积分: 5000
  • 用 户 组: 普通用户
  • 注册时间: 2008-09-12 09:00
文章分类

全部博文(738)

文章存档

2011年(1)

2008年(737)

我的朋友

分类:

2008-09-12 09:09:02


  网络联机的过程介绍
  先介绍一下基本的网络程序联机的原理,如图所述在Server端要先开启一个连接阜准备接收Client的联机,当一收到Client端的联机的时候便可以将Server的位置及连接(Socket)传给Client然后Client便取联机的信息再将资料及 Socket一起透过网络(Socket记载着IP Address及Port)将讯息送到Server端,就可以开始和作交易。
  
 

  
图Client-Server联机示意图

  
  先撰写一个简单的Server。
  
  import java.io.*;
  import java.net.*;
  public class netServer {
  String clientMessage;
  ServerSocket sSocket;
  //宣告使用ServerSocket的类别
  Socket csocket;
  //取得Client联机封包的Socket,各为别想太多就是Client端的联机
  public netServer() {
  try {
  sSocket = new ServerSocket(900,200);
  //开启Port 900,并限定Client联机的数量为200,若开启正常则开始等待Client端的联机
  csocket = sSocket.accept();
  //Client端已经联机上了取得Socket
  System.out.println("取得一个Client端从 "+csocket.getInetAddress().getHostAddress());
  //显示出Client IP
  }
  catch(IOException ioe) {
  System.out.println("开启Server异常!!!");
  }
  }
  public static void main(String[] args) {
  new netServer();
  }
  }
  
  编译成功后打java netServer画面如下图所示就会开始等待接受Client端的要求。
  
 

  
图netServer开始等待Client端发出要求

  
  接着我们切换到DOS模式(再开一个DOS窗口)输入telnet 127.0.0.1 900(注意空格)画面会一闪就过去了。接着我们观察Server的画面是否有出现取得一个Client端从127.0.0.1如下图所示。接着我们就开始撰写PocketPC中的Client
  

  
图netServer开始等待Client端发出要求

  
  注意,目前Server的程序皆在PC端执行,待下个Client范例开始才移到PocketPC中执行。下面打造一个Hello NetWork。接下来我们撰写个输入您的姓名,Server会打对您打招呼的程序。这个程序的原理是在Server端执行一个无线回圈,然后提供服务如接受到 Client传来的讯息之后就传回一个讯息Hello的讯息给Client,另外我们为了达到一次能够同时服务多个使用者所以我们使用了Thread的技术。
  
  Server端程序:
  
  import java.io.*;
  import java.net.*;
  public class netHelloServer {
  String clientMessage; ServerSocket sSocket;
  //宣告使用ServerSocket的类别
  Socket csocket;
  //取得Client联机封包的Socket,各为别想太多就是Client端的联机
  public netHelloServer() {
  try {
  sSocket = new ServerSocket(900,200);
  //开启Port 900,并限定Client联机的数量为200,若开启正常则开始等待Client端的联机
  while(true) {
  csocket=sSocket.accept();
  Thread t=new MyThread(csocket);
  t.start();
  }
  }
  catch(IOException ioe) {
  System.out.println("开启Server异常!!!");
  }
  }
  public static void main(String[] args) {
  new netHelloServer();
  }
  }
  class MyThread extends Thread { Socket conn;
  String tempStr; DataInputStream dis; DataOutputStream dos;
  //建构者
  public MyThread(Socket inSocket) { conn = inSocket; }
  public void run() {
  try{
  System.out.println("Server go connect from:"+conn.getInetAddress().getHostName());
  dos = new DataOutputStream(conn.getOutputStream());
  dos.writeUTF("输入您的姓名的资料"); //get the request conntent
  dis = new DataInputStream(conn.getInputStream());
  tempStr = dis.readUTF();
  //响应一下
  dos.writeUTF("您输入的资料为"+tempStr+"系统正在为您准备中请稍后...");
  //复杂的动作可以写在这边
  dos.writeUTF(tempStr+" 您好...");
  System.out.println("Server recivews data ="+tempStr);
  conn.close();
  //断线
  }
  catch(IOException e) {
  System.out.println(e);
  }
  }
  }
  
  Client端的程序
  
  import java.awt.*;
  import java.awt.event.*;
  import java.net.*;
  import java.io.*;
  public class HelloClient extends Frame {
  Label lb1 = new Label("请输入姓名");
  TextField tf1 = new TextField("",14);
  Label lb2 = new Label("请输入Server的IP");
  TextField tf2 = new TextField("",14);
  TextArea ta1 = new TextArea("");
  Button btn1 = new Button("送出讯息");
  Button btn2 = new Button("离开");
  Panel pl1 = new Panel();
  Panel pl2 = new Panel();
  static Socket csocket = null;
  MouseClickevent bce = new MouseClickevent();
  public HelloClient() { //窗口设定
  btn1.addMouseListener (bce);
  btn2.addMouseListener (bce);
  pl1.setLayout(new GridLayout(2,1));
  pl1.add(lb1); pl1.add(tf1); pl1.add(lb2); pl1.add(tf2);
  add(pl1,BorderLayout.NORTH);
  add(ta1,BorderLayout.CENTER);
  pl2.add(btn1); pl2.add(btn2);
  add(pl2,BorderLayout.SOUTH);
  setSize(240,320);
  setVisible(true);
  }
  public static void main(String[] args) {
  new HelloClient();
  }
  //以下为按钮事件处理
  class MouseClickevent implements MouseListener {
  public void mouseClicked(MouseEvent e) {}
  public void mousePressed(MouseEvent e) {
  if(e.getSource() == btn1) {
  if(!tf2.getText().equals("")&&!tf1.getText().equals(""))
  try{
  //csocket = new Socket("127.0.0.1",900);
  csocket = new Socket(tf2.getText(),900);
  DataInputStream dis = new DataInputStream(csocket.getInputStream());
  String data = dis.readUTF();
  //System.out.println("\nClient get datafrom server = "+data);
  ta1.append("\n送一个讯息到Server: "+data); //write response to server
  DataOutputStream dos = new DataOutputStream(csocket.getOutputStream());
  //dos.writeUTF("Bye! all done");
  dos.writeUTF(tf1.getText());
  data = "";
  data = dis.readUTF();
  //System.out.println("Client get datafrom server = "+data);
  ta1.append("\n收到Server的讯息: "+data);
  data = dis.readUTF();
  //System.out.println("Client get datafrom server = "+data);
  ta1.append("\n收到Server的讯息: "+data); csocket.close();
  }
  catch(IOException IOe) {
  System.out.println(e);
  }
  }
  else if(e.getSource() == btn2) {
  //System.out.println("Btn2 is Clicked");
  System.exit(1);
  }
  }
  public void mouseReleased(MouseEvent e) {}
  public void mouseEntered(MouseEvent e) {}
  public void mouseExited(MouseEvent e) {}
  }
  }
【责编:admin】

--------------------next---------------------

阅读(366) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~