Socket例子和数据库链接

服务端：

package com.test.dp;

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 MyServer extends Thread{
    private Socket cq;
    public MyServer(Socket cq){
        this.cq=cq;
    }
    public void run(){
        try{
            BufferedReader in=new BufferedReader(new InputStreamReader(cq.getInputStream()));
            PrintWriter out=new PrintWriter(cq.getOutputStream());
            while(true){
                String str=in.readLine();
                System.out.println(str);
                out.println("message:"+str);
                out.flush();
                if(str.equals("exit")){
                    break;
                }
            }
        }catch(IOException e){
            System.out.println(e.toString());
        }
    }
    public static void main(String[] args)throws IOException{
        ServerSocket server=new ServerSocket(8009);
        while(true){
            Socket s=server.accept();
            new MyServer(s).start();
        }
    }
}
客户端：

package com.test.dp;

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

public class MyClient {
    public static void main(String[] args)throws Exception{
        Socket server=new Socket("localhost",8009);
        BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
        PrintWriter out=new PrintWriter(server.getOutputStream());
        BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
        while(true){
            String str=br.readLine();
            out.println(str);
            out.flush();
            if(str.equals("exit"))
            break;
            System.out.println(in.readLine());
        }
        server.close();
    }
}
数据库链接：

Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://127.0.0.1/myDatabase";
String user = "user";
String password = "password";
Connection conn = DriverManager.getConnection(url, user, password);