TCP聊天

一、项目创建

二、代码

Client类

1. package tcp;

   import java.io.BufferedReader;
   import java.io.IOException;
   import java.io.InputStreamReader;
   import java.io.PrintWriter;
   import java.net.Socket;
   import java.util.Scanner;

   public class Client {
   public static void main(String[] args) {

   try {
   Socket socket =new Socket(“127.0.0.1”,8888);
   System.out.println(“连接成功！”);
   new ClientSend(socket).start();
   new Clientreive(socket).start();
   } catch (IOException e) {
   e.printStackTrace();
   }
   }
   }
   /**
   * 用于发送消息线程类
   */
   class ClientSend extends Thread{
   @Override
   public void run() {
   this.sendMsy();
   }
   private Socket socket;
   public ClientSend(Socket socket){
   this.socket =socket;
   }
   /**
   * 发送消息
   */
   private void sendMsy(){
   Scanner scanner =null;
   PrintWriter pw =null;
   try{
   scanner =new Scanner(System.in);
   pw =new PrintWriter(this.socket.getOutputStream());
   while(true){
   String str =scanner.nextLine();
   pw.println(str);
   pw.flush();
   }
   }catch (Exception e){
   e.printStackTrace();
   }finally {
   if (scanner!=null){
   scanner.close();
   }
   if (pw!=null){
   pw.close();
   }
   if (socket!=null){
   try {
   socket.close();
   } catch (IOException e) {
   e.printStackTrace();
   }
   }
   }
   }
   }

   /**
   *用于接收消息线程类
   */
   class Clientreive extends Thread{
   private Socket socket=null;
   public Clientreive(Socket socket){
   this.socket =socket;
   }

   @Override
   public void run() {
   this.receiveMsg();
   }
   /**
   * 用于接收对方消息
   */
   private void re服务器托管网ceiveMsg(){
   BufferedReader br =null;
   try{
   br =new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
   while(true){
   String mr = br.readLine();
   System.out.println(“小明：”+mr);
   }
   }catch (Exception e){
   e.printStackTrace();
   }finally {
   if (br!=null){
   try {
   br.close();
   } catch (IOException e) {
   e.printStackTrace();
   }
   }

   }
   }
   }
   Server类

   package tcp;

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

   /**
   * 发送消息线程
   */
   class Send extends服务器托管网 Thread{
   private Socket socket;
   public Send(Socket socket){
   this.socket =socket;
   }
   @Override
   public void run() {
   this.sendMsy();
   }
   /**
   * 发送消息
   */
   private void sendMsy(){
   Scanner scanner =null;
   PrintWriter pw =null;
   try{
   scanner =new Scanner(System.in);
   pw =new PrintWriter(this.socket.getOutputStream());
   while(true){
   String str =scanner.nextLine();
   pw.println(str);
   pw.flush();
   }
   }catch (Exception e){
   e.printStackTrace();
   }finally {
   if (scanner!=null){
   scanner.close();
   }
   if (pw!=null){
   pw.close();
   }
   if (socket!=null){
   try {
   socket.close();
   } catch (IOException e) {
   e.printStackTrace();
   }
   }
   }
   }
   }

   /**
   * 接收消息的线程
   */
   class receive extends Thread{
   private Socket socket=null;
   public receive(Socket socket){
   this.socket =socket;
   }

   @Override
   public void run() {
   this.receiveMsg();
   }
   /**
   * 用于接收对方消息
   */
   private void receiveMsg(){
   BufferedReader br =null;
   try{
   br =new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
   while(true){
   String mr = br.readLine();
   System.out.println(“小红说：”+mr);
   }
   }catch (Exception e){
   e.printStackTrace();
   }finally {
   if (br!=null){
   try {
   br.close();
   } catch (IOException e) {
   e.printStackTrace();
   }
   }

   }
   }
   }

   public class Server {
   public static void main(String[] args) {
   ServerSocket serverSocket =null;
   try{
   serverSocket =new ServerSocket(8888);
   System.out.println(“服务端已启动等待连接”);
   Socket socket = serverSocket.accept();
   System.out.println(“连接成功！”);
   new Send(socket).start();
   new receive(socket).start();
   }catch(Exception e){
   e.printStackTrace();
   }finally {
   if (serverSocket!=null){
   try {
   serverSocket.close();
   } catch (IOException e) {
   e.printStackTrace();
   }
   }
   }
   }
   }

   三、运行结果

2. 先运行服务端

4. 再运行客服端

5. 

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: 基于单片机的全自动洗衣机仿真设计(#0088)

功服务器托管网能描述 1、采用51/52单片机作为主控芯片； 2、支持四种洗衣(流程)模式： 标准模式：进水-洗涤-排水–进水-漂洗1-排水–进水-漂洗2-排水–脱水； 经济模式：进水-洗涤-排水–进水-漂洗-排水–脱水； 单独洗涤：进水-洗涤-排水…