基于Java Socket客户端、服务端聊天雏形
2012-02-29 16:15
411 查看
Server.java
package org.sunchao; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; /** * Socket服务端代码 * * @author Administrator * */ public class Server { private static final int PORT = 8888; private Socket socket; public static void main(String[] args) { Server server = new Server(); ConnectThread connect = server.new ConnectThread(); new Thread(connect).start(); } /** * 服务端等待连接线程 * * @author Administrator * */ class ConnectThread implements Runnable { @Override public void run() { try { System.out.println("Waiting client to connect..."); ServerSocket serverSocket = new ServerSocket(PORT); socket = serverSocket.accept(); // socket连接之后开始启动接收与发送消息的线程 ReceiveThread receive = new ReceiveThread(); SendThread send = new SendThread(); new Thread(receive).start(); new Thread(send).start(); } catch (Exception e) { e.printStackTrace(); } finally { } } } /** * 服务端接收消息线程 * * @author Administrator * */ class ReceiveThread implements Runnable { @Override public void run() { try { String info; InputStream is = socket.getInputStream(); DataInputStream dis = new DataInputStream(is); while (true) { info = dis.readUTF(); System.out.println("Client:" + info); if (info.equals("bye")) { break; } } } catch (Exception e) { e.printStackTrace(); } finally { } } } /** * 服务端发送消息线程 * * @author Administrator * */ class SendThread implements Runnable { @Override public void run() { try { OutputStream os = socket.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); InputStreamReader isr = new InputStreamReader(System.in); // 从键盘读入数据 BufferedReader br = new BufferedReader(isr); String info; while (true) { info = br.readLine(); dos.writeUTF(info); if (info.equals("bye")) { break; } } } catch (Exception e) { e.printStackTrace(); } finally { } } } }
Client.java
package org.sunchao; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.Socket; /** * Socket客户端代码 * * @author Administrator * */ public class Client { private static final String IP = "192.168.0.107"; private static final int PORT = 8888; private Socket socket; public static void main(String[] args) { Client client = new Client(); ConnectThread connect = client.new ConnectThread(); new Thread(connect).start(); } /** * 客户端连接服务端线程 * * @author Administrator * */ class ConnectThread implements Runnable { @Override public void run() { try { socket = new Socket(IP, PORT); // socket连接之后开始启动接收与发送消息的线程 ReceiveThread receive = new ReceiveThread(); SendThread send = new SendThread(); new Thread(receive).start(); new Thread(send).start(); } catch (Exception e) { e.printStackTrace(); } finally { } } } /** * 客户端接收消息线程 * * @author Administrator * */ class ReceiveThread implements Runnable { @Override public void run() { try { String info; InputStream is = socket.getInputStream(); DataInputStream dis = new DataInputStream(is); while (true) { info = dis.readUTF(); System.out.println("Server:" + info); if (info.equals("bye")) { break; } } } catch (Exception e) { e.printStackTrace(); } finally { } } } /** * 客户端发送消息线程 * * @author Administrator * */ class SendThread implements Runnable { @Override public void run() { try { OutputStream os = socket.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); InputStreamReader isr = new InputStreamReader(System.in); // 从键盘读入数据 BufferedReader br = new BufferedReader(isr); String info; while (true) { info = br.readLine(); dos.writeUTF(info); if (info.equals("bye")) { break; } } } catch (Exception e) { e.printStackTrace(); } finally { } } } }
相关文章推荐
- 基于socket的客户端和服务端聊天机器人
- Java Socket通信之客户端服务端交互聊天案例
- java socket 服务端与客户端聊天
- 基于socket的客户端和服务端聊天简单使用 附Demo
- 基于websocket实现与图灵机器人即时聊天,服务端向客户端推送消息
- [iPhone高级] 基于XMPP的IOS聊天客户端程序
- Python实现基于TCP UDP协议的IPv4 IPv6模式客户端和服务端功能示例
- 写一个Tomcat+Okhttp实现的聊天websocket聊天框架(一)-- 完成客户端和服务端的通信
- [iPhone高级] 基于XMPP的IOS聊天客户端程序(IOS端一)
- 基于Volley和Gson的http网络请求设计(客户端和服务端)
- java 基于tcp客户端服务端发送接收数据
- 聊天程序服务端和客户端代码分享
- [iPhone高级] 基于XMPP的IOS聊天客户端程序(XMPP服务器架构)
- 基于XMPP的IOS聊天客户端程序
- 基于服务端和客户端之间的通信
- [MFC]服务端客户端一对一聊天
- Windows下TCP聊天服务器与客户端雏形的实现
- 基于Tcp通信的聊天程序微风IM(c#开源) -技术分析(三) 客户端下线
- 基于Python的TCP服务端/客户端简单应用示例
- [iPhone高级] 基于XMPP的IOS聊天客户端程序(IOS端二)