java socket入门 实例源码下载

【实例简介】很简单的java socket例子 需要用到mysql数据库

【实例截图】

【核心代码】

客户端：

package net.food.apple;

import java.io.*;
import java.net.*;
import java.util.Scanner;
public class Client 
{
	public static void main(String[] args)
	{
		Test T=new Test();
		System.out.println("\t\t\t*—*欢迎使用*—*");
		T.dayin();
		try
		{
			Socket client=new Socket("192.168.0.1",1111);//接口注意  不要被占用了

			InputStream is=client.getInputStream();//这边的两个流跟上面服务器的差不多的作用
			BufferedReader bf=new BufferedReader(new InputStreamReader(is));
			OutputStream os=client.getOutputStream(); 
			PrintStream ps=new PrintStream(os);
			Scanner scanner=new Scanner(System.in);
			boolean flag=true;
			while(flag)//这句话可以让客户端不停的说话
			{ 
				String S=scanner.next();//客户端给服务端发送的内容
				S="客户端说:" S;
				String time=T.getTime();
				S=time S;
				T.cunru(S);
				T.jiami(S);
				String S2=T.jiami(S);
				ps.println(S2);
				String S1=bf.readLine();
				String S3=T.jiemi(S1);
				System.out.println(S3);
			}
			client.close();
		} 
		catch (UnknownHostException e) 
		{
			e.printStackTrace();
		}
		catch (IOException e) 
		{
			e.printStackTrace();
		}
	}
}

服务器端：

package net.food.apple;

import java.io.*;
import java.net.*;
import java.util.Scanner;
public class Server 
{ 
	public static void main(String[] args)
	{
		Test T=new Test();
		System.out.println("\t\t\t*—*欢迎使用*—*");
		T.dayin();
		try {
			ServerSocket server=new ServerSocket(30000);//定义客户端的端口号1111
			Socket client=server.accept();//定义一个Socket对象
			InputStream is=client.getInputStream();//服务器接受信息输入流，也就是接受从服务器段发送过来的消息
			BufferedReader br=new BufferedReader(new InputStreamReader(is));//用bufferedreader包装下输入流
			OutputStream os=client.getOutputStream();//这是用来给服务器发送消息的输出流
			PrintStream ps=new PrintStream(os);
			Scanner scanner=new Scanner(System.in);//从键盘输入字符串
			boolean flag=true;//定义一个死循环，让服务器不停的接受从客户端发送来的字符串
			while(flag)
			{ 
				String S1=br.readLine();//s是从客户端接受到得字符串
				//解密
				T.jiemi(S1);
				String S3=T.jiemi(S1);
				System.out.println(S3);
				String S=scanner.next();//s2是写给客户端的字符串
				S="服务端说：" S;
				String time=T.getTime();
				S=time S;
				T.cunru(S);
				String S2=T.jiami(S);
				ps.println(S2); //给客户端发送
			}
			client.close(); 
		} catch (IOException e) {
			e.printStackTrace();
		} 
	}
}