java实现socket客户端连接服务端_java

本例只做简单功能演示，代码并不严谨，只是说明客户端如何实现连接服务端简单代码。

代码在集成Eclipse工具下测试编译运行环境如下图所示：

客户端echoClient.java代码：

package com.zhengzz.echo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

class EchoC{

  private Socket socket;

  public EchoC() {
    // TODO Auto-generated constructor stub
    try {
      socket = new Socket("localhost", 60000);
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

  public void Client() {
    try {
      BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);
      BufferedReader lbr = new BufferedReader(new InputStreamReader(System.in));

      String linestr = null;
      while ((linestr = lbr.readLine()) != null) {

        pw.println(linestr);

        System.out.println(br.readLine());

        if (linestr.equals("bye#")) {
          break;
        }
      }

    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

public class echoClient {

  public static void main(String[] args) {
    new EchoC().Client();
  }

}

服务端echoServer.java代码：

package com.zhengzz.echo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

class EchoS{

  private ServerSocket serverSocket;

  public EchoS() {

    try {
      serverSocket = new ServerSocket(60000);
    } catch (IOException e) {
      e.printStackTrace();
    }

  }

  public void Server() {
    while (true) {
      try {
        Socket socket = serverSocket.accept();

        System.out.println("client:" + socket.getInetAddress() + ":" + socket.getLocalPort());

        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);

        String linestr;

        while ((linestr = br.readLine()) != null) {

          System.out.println(linestr);

          pw.println("--->" + linestr);

        }
      } catch (IOException e) {
        System.out.println("连接断开：（");
      }

    }
}
}

public class echoServer {

  public static void main(String[] args) {
    new EchoS().Server();
  }

}

我在Eclipse工具下直接调试结果如下：

下面我们再来看一个 HelloWord 级别的 Java Socket 通信的例子。通讯过程：

        先启动 Server 端，进入一个死循环以便一直监听某端口是否有连接请求。然后运行 Client 端，客户端发出连接请求，服务端监听到这次请求后向客户端发回接受消息，连接建立，启动一个线程去处理这次请求，然后继续死循环监听其他请求。客户端输入字符串后按回车键，向服务器发送数据。服务器读取数据后回复客户端数据。这次请求处理完毕，启动的线程消亡。如果客户端接收到 "OK" 之外的返回数据，会再次发送连接请求并发送数据，服务器会为这次连接再次启动一个线程来进行响应。。。直到当客户端接收到的返回数据为 "OK" 时，客户端退出。

        服务端源代码：

package com.defonds.socket.begin; 

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket; 

public class Server {
  public static final int PORT = 12345;//监听的端口号   

  public static void main(String[] args) {
    System.out.println("服务器启动...\n");
    Server server = new Server();
    server.init();
  }  

  public void init() {
    try {
      ServerSocket serverSocket = new ServerSocket(PORT);
      while (true) {
        // 一旦有堵塞, 则表示服务器与客户端获得了连接
        Socket client = serverSocket.accept();
        // 处理这次连接
        new HandlerThread(client);
      }
    } catch (Exception e) {
      System.out.println("服务器异常: " + e.getMessage());
    }
  }  

  private class HandlerThread implements Runnable {
    private Socket socket;
    public HandlerThread(Socket client) {
      socket = client;
      new Thread(this).start();
    }  

    public void run() {
      try {
        // 读取客户端数据
        DataInputStream input = new DataInputStream(socket.getInputStream());
        String clientInputStr = input.readUTF();//这里要注意和客户端输出流的写方法对应,否则会抛 EOFException
        // 处理客户端数据
        System.out.println("客户端发过来的内容:" + clientInputStr);  

        // 向客户端回复信息
        DataOutputStream out = new DataOutputStream(socket.getOutputStream());
        System.out.print("请输入:\t");
        // 发送键盘输入的一行
        String s = new BufferedReader(new InputStreamReader(System.in)).readLine();
        out.writeUTF(s);  

        out.close();
        input.close();
      } catch (Exception e) {
        System.out.println("服务器 run 异常: " + e.getMessage());
      } finally {
        if (socket != null) {
          try {
            socket.close();
          } catch (Exception e) {
            socket = null;
            System.out.println("服务端 finally 异常:" + e.getMessage());
          }
        }
      }
    }
  }
}

客户端源代码：

package com.defonds.socket.begin; 

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket; 

public class Client {
  public static final String IP_ADDR = "localhost";//服务器地址
  public static final int PORT = 12345;//服务器端口号  

  public static void main(String[] args) {
    System.out.println("客户端启动...");
    System.out.println("当接收到服务器端字符为 \"OK\" 的时候, 客户端将终止\n");
    while (true) {
      Socket socket = null;
      try {
        //创建一个流套接字并将其连接到指定主机上的指定端口号
        socket = new Socket(IP_ADDR, PORT);  

        //读取服务器端数据
        DataInputStream input = new DataInputStream(socket.getInputStream());
        //向服务器端发送数据
        DataOutputStream out = new DataOutputStream(socket.getOutputStream());
        System.out.print("请输入: \t");
        String str = new BufferedReader(new InputStreamReader(System.in)).readLine();
        out.writeUTF(str);  

        String ret = input.readUTF();
        System.out.println("服务器端返回过来的是: " + ret);
        // 如接收到 "OK" 则断开连接
        if ("OK".equals(ret)) {
          System.out.println("客户端将关闭连接");
          Thread.sleep(500);
          break;
        }  

        out.close();
        input.close();
      } catch (Exception e) {
        System.out.println("客户端异常:" + e.getMessage());
      } finally {
        if (socket != null) {
          try {
            socket.close();
          } catch (IOException e) {
            socket = null;
            System.out.println("客户端 finally 异常:" + e.getMessage());
          }
        }
      }
    }
  }
}

        注意： Socket 输出流写数据方法是 writeUTF 时，输入流读取相关数据要用 readUTF。否则会抛 EOFException 异常。

以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索java
， socket
服务端
socket客户端和服务端、socket 服务端 客户端、websocket 服务端实现、websocket客户端实现、java客户端和服务端，以便于您获取更多的相关知识。

时间： 2024-08-04 08:18:02

java实现socket客户端连接服务端_java的相关文章

c# socket 多线程，为什么我的客户端连接服务端的时候，总是接收不到服务器返回的确认信息呢？

问题描述 socket多线程服务器程序,提供给客户服务,但是客户登录的时候,总是发生服务端返回信息失败,是为什么?是因为服务器的带宽被占用没了吗?如果服务器的带宽不够了,会出现这样的问题吗?该怎么解决呢? 解决方案 解决方案二:写的太简单了,无法回答.Socket连接成功没?协议传输对不对?登录认证通过不?解决方案三:客户端少的时候连接正常当客户端连接的多了(客户端以下载文件为主)会提示服务器返回信息失败解决方案四:帮帮我吧!!!!解决方案五:你描述的不够清楚啊解决方案六:服务端返回信息失败这个

redis客户端连接服务端the version of redis server is too low to support this function错误

redis作为一个内存数据库,使用得当可以大大的提升系统运行的效率,据说能读的速度是110000次/s,写的速度是81000次/s,我们的其中一个系统就用到了这个. 由于之前负责这个的同事离职,只好临时抱佛脚进行简单的学习,学习过程中也不免遇到一些问题. 之前linux测试机上有安装3.0版本的redis,我也找到离职的同事要到了相应的redisclient客户端工具,然后为了方便学习,自己下载了windows版本的redis,3.2版本. 点击下载:http://download.csdn.n

java读取用户登入退出日志信息上传服务端_java

本文实例为大家分享了读取用户登入出日志并上传服务端的具体实现代码,供大家参考,具体内容如下 该客户端运行在给用户提供unix服务的服务器上.用来读取并收集该服务器上用户的上下线信息,并进行配对整理后发送给服务端汇总. 具体实现代码: 1. DMSServer.java package com.dms; import java.io.BufferedReader; import java.io.File; import java.io.FileOutputStream; import java.i

java实现微信支付（服务端）_java

废话不多说,直接看代码. RequestHandler requestHandler = new RequestHandler(super.getRequest(),super.getResponse()); //获取token //两小时内有效,两小时后重新获取 Token = requestHandler.GetToken(); //更新token 到应用中 requestHandler.getTokenReal(); System.out.println("微信支付获取token=====

聊天室-关于java的聊天程序,分服务端和客户端，请java大神帮我调试一下,我检查没编写错误

问题描述 关于java的聊天程序,分服务端和客户端,请java大神帮我调试一下,我检查没编写错误 //服务端 package chatApp; import java.net.*; import java.io.*; import java.util.*; public class chatserverthree implements Runnable { public static final int PORT=1234; protected ServerSocket listen; stat

java-Java Socket 读取TCP服务端数据包不完整

问题描述 Java Socket 读取TCP服务端数据包不完整 Java Socket 读取TCP服务端数据包不完整:除了利用数据包大小循环读取输入流的得到完整的数据外,还有其他什么方法? 数据包在网络传输的过程中,数据传递到客户端基本处于"无序"态.除了开辟一块内存按数据包的顺序存放外,还有其他更好的方案么? 解决方案 TCP 因为是长连接的,肯定是有序的.数据接收不完整,这种现象在通讯中很常见的,是必须代码处理. 解决方案二: TCP是有序的吧?UDP才是无序的. 解决方案三: T

io流-socket 客户端读取服务端发送的 序列化流 报错

问题描述 socket 客户端读取服务端发送的 序列化流 报错 客户端 服务端 请大神指教,实在找不到原因了,对这块儿也不是很熟 解决方案 socket调用了一次getInputStream时,但又需要把这个socket的相关信息作为参数传递给别的对象时,应注意:不用直接把socket传过去,应该把对应的ObjectInputStream或ObjectOutputStream对象传递过去. 解决方案二: 直接读写Object,使用java自己的序列化不可以吗?

socket-Android使用Socket与windows服务端之间怎么传输整数啊？

问题描述 Android使用Socket与windows服务端之间怎么传输整数啊? 服务端: try { OutputStream os = s.getOutputStream(); os.write(new Random().nextInt(441) +20); os.flush(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } 安卓客户端: BufferedReader

求教，要用java写个app的服务端，请问需要使用哪些技术或组件？

问题描述 求教,要用java写个app的服务端,请问需要使用哪些技术或组件? 好像需要用到xmpp,数据传递打算使用json,然后框架准备使用springmvc+mybties,但是我不清楚该怎么实现接收app传过来的数据,还有就是怎么将数据传递给app. 好像说进行接口交互,但是这个大概是怎么实现或运行的,有没有大神介绍下,有例子链接更好哈! 解决方案 这个我来告诉你,因为我现在就在用JAVA做手机APP的服务器. 首先你不要被什么框架啊这些给迷惑了,如果你连原理都不知道就去弄这些框架,会把你