灯火互联
管理员
管理员
  • 注册日期2011-07-27
  • 发帖数41778
  • QQ
  • 火币41290枚
  • 粉丝1086
  • 关注100
  • 终身成就奖
  • 最爱沙发
  • 忠实会员
  • 灌水天才奖
  • 贴图大师奖
  • 原创先锋奖
  • 特殊贡献奖
  • 宣传大使奖
  • 优秀斑竹奖
  • 社区明星
阅读:1516回复:0

用Socket编程,读服务器几个字符,再写入本地显示

楼主#
更多 发布于:2012-09-08 09:37


服务器
[java] package com.zhangry.interview.java.socket;

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 {
    private ServerSocket ss;
    private Socket socket;
    private BufferedReader in;
    private PrintWriter out;
    public Server(){
         try {
            ss = new ServerSocket(8888);
            while(true){
                socket = ss.accept();
                String remoteIP =  socket.getInetAddress().getHostAddress();
                String remotePort = ":"+socket.getLocalPort();
                System.out.println("客户端接入 ! IP :"+remoteIP+remotePort);
                in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String line = in .readLine();
                System.out.println("客户端说 :"+ line);
                out= new PrintWriter(socket.getOutputStream(),true);
                out.println("你的信息已收到!");
                out.close();
                in.close();
                socket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    public static void main(String[] args){
        new Server();
    }
}
package com.zhangry.interview.java.socket;
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 {
    private ServerSocket ss;
    private Socket socket;
    private BufferedReader in;
    private PrintWriter out;
    public Server(){
         try {
            ss = new ServerSocket(8888);
            while(true){
                socket = ss.accept();
                String remoteIP =  socket.getInetAddress().getHostAddress();
                String remotePort = ":"+socket.getLocalPort();
                System.out.println("客户端接入 ! IP :"+remoteIP+remotePort);
                in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String line = in .readLine();
                System.out.println("客户端说 :"+ line);
                out= new PrintWriter(socket.getOutputStream(),true);
                out.println("你的信息已收到!");
                out.close();
                in.close();
                socket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
  
    public static void main(String[] args){
        new Server();
    }
}


客户端
[java] package com.zhangry.interview.java.socket;

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 {
    Socket socket;
    BufferedReader in;
    PrintWriter out;
    public Client(){
        try {
            System.out.println("Try to connect to 127.0.0.1:8888");
            socket = new Socket("127.0.0.1",8888);
            System.out.println("已经成功连接至服务器");
            System.out.println("请输入要发向服务器的话:");
            BufferedReader line = new BufferedReader(new InputStreamReader(System.in));
            out = new PrintWriter(socket.getOutputStream(),true);
            out.println(line.readLine());
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            System.out.println(in.readLine());
            out.close();
            in.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    public static void main(String[] args){
        new Client();
    }
}


喜欢0 评分0
游客

返回顶部