无限地吸取知识

快乐就是一生中最大的享受!

  BlogJava :: 首页 :: 联系 :: 聚合  :: 管理
  3 Posts :: 0 Stories :: 2 Comments :: 0 Trackbacks

今天复习了一下网络底层的socket编程,socket编程的大致步骤如下:
1、创建服务器端SocketServer,并定义SocketServer的监听端口;
2、ServerSocket调用accept( )方法,是指处于阻塞;
3、创建客户端的Socket,并设置服务器的IP和端口;
4、客户端发送连接请求,建立连接;
5、分别取得服务器和客户端Socket的InputStream和OutputStream;
6;利用Socket和ServerSocket进行数据传输。

其中比较重要的只是点是文件的I/O操作,以及Socket的几个主要API:

1、getInputStream();    //返回Socket接收到的InputStream
2、getOutputStream(); //返回Socket向外传输(另一端为接收)的OutputStream
3、ServerSocket 的accept() //使服务器处于阻塞状态,直到客户端连接

/*
*服务器端代码
*
*/

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 Server
{
    
public static void main(String[] args)
    {
        
new Server();
    }

    
public Server()
    {
        
try
        {
            ServerSocket ss 
= new ServerSocket(8888);
            
while (true)
            {
                
// 服务器接收消息
                Socket s = ss.accept();
                InputStreamReader isr 
= new InputStreamReader(s
                        .getInputStream());
                BufferedReader in 
= new BufferedReader(isr);
                String line 
= in.readLine();
                System.out.println(
"Client发送的消息是:  " + line);

                
// 把成功信息反馈回客户端
                PrintWriter out = new PrintWriter(s.getOutputStream(), true);
                out.println(
"已经接受到消息了!");

                out.close();
                in.close();
                isr.close();
                s.close();
            }
        }
        
catch (IOException e)
        {
            e.printStackTrace();
        }

    }
}

/*
*
*客户端代码
*/
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 Client
{
    
public static void main(String[] args)
    {
        
new Client();
    }

    
public Client()
    {
        
try
        {
            System.out.println(
"正在连接Server中");

            Socket socket 
= new Socket("localhost"8888);

            System.out.println(
"连接成功!");
            System.out.println();

            
// 向服务器发消息
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader br 
= new BufferedReader(new InputStreamReader(
                    System.in));
            System.out.print(
"请输入信息:");
            out.println(br.readLine());

            
// 接受服务器端消息
            BufferedReader in = new BufferedReader(new InputStreamReader(socket
                    .getInputStream()));
            System.out.println(
"Server回复的消息:  " + in.readLine());

            br.close();
            out.close();
            in.close();
            socket.close();
        }
        
catch (UnknownHostException e)
        {
            e.printStackTrace();
        }
        
catch (IOException e)
        {
            e.printStackTrace();
        }
    }
}
posted on 2007-09-15 17:13 Sylar 阅读(5945) 评论(1)  编辑  收藏 所属分类: Java基础类

Feedback

# re: Socket编程实现简单的服务器与客户端互发消息 2009-07-01 17:06 jadmin
如果是多个客户端呢  回复  更多评论
  


只有注册用户登录后才能发表评论。


网站导航: