oracle调用java 使用socket监听端口测试

　　由于上一篇文章的简单调用成功，开心死了，呵呵！然后就自己写了一个在程序内部创建一个sockate来监听10000端口，把服务端写在程序这边，然后把客户端写在oracle里面，然后启动服务端监听，使用oracle存储过程来达到时时监听的效果！
　　现在java程序里面写了一个socket的测试，然后在把客户端发到oracle里面在做第二次测试。
　　
　　
　　1.服务端ServerThread
　　package socket;
　　import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
　　public class ServerThread extends Thread {
 private Socket socket;
　　public ServerThread(Socket socket) {
  this.socket = socket;
 }
　　public void run() {
  try {
   InputStream is = socket.getInputStream();
   OutputStream os = socket.getOutputStream();
   BufferedReader br = new BufferedReader(new InputStreamReader(is));
   PrintStream ps = new PrintStream(os);
   while (true) {
    String temp = br.readLine();// 客户要用println
    ps.println("服务器相应:" + temp);// 处理下
    if (temp.equals("bye")) {
     break;
    }
   }
   ps.close();
   br.close();
   socket.close();
  } catch (Exception rr) {
   rr.printStackTrace();
  }
 }
}
　　2.启动服务端监听TestServer
　　package socket;
　　import java.net.ServerSocket;
import java.net.Socket;
import java.io.*;
　　public class TestServer extends Thread {
 private ServerSocket ss = null;
　　public TestServer() {
  try {
   ss = new ServerSocket(10000);
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
　　public void run() {
  while (true) {
   try {
    Socket so = ss.accept();
    ServerThread st = new ServerThread(so);
    st.start();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
 }
　　public static void main(String[] args) throws Exception {
  new TestServer().start();
 }
　　}
　　3.启动客户端测试
　　
　　package socket;
　　import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
　　public class TestClient {
　　public static String sendMes(String msg) {
  String rmsg = "";
  try {
   Socket client = new Socket("192.168.1.120", 10000);
   BufferedReader br = new BufferedReader(new InputStreamReader(client
     .getInputStream()));
   PrintWriter out = new PrintWriter(new OutputStreamWriter(client
     .getOutputStream(), "GBK"), true);
   out.println(msg);
   out.flush();
   rmsg = br.readLine();
   System.out.println(rmsg);
   client.close();
  } catch (Exception e) {
   System.out.println(e.getMessage());
   return e.getMessage();
  }
  return rmsg;
 }
　　public static void main(String[] args) {
  sendMes("端午节快乐!!");
 }
　　}
　　现在第一步测试成功。
　　
　　重点在这里了（不知道在哪里写下面的代码的话，那就等下到附件里面去看图片就明白了！记住你的工程是必须修改一下我的监听ip的）
　　
　　create or replace and compile java source named TestClient as
　　import java.io.BufferedReader;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
　　public class TestClient {
　　public static String sendMes(String msg) {
  String rmsg = "";
  try {
   Socket client = new Socket("192.168.1.120", 10000);
   BufferedReader br = new BufferedReader(new InputStreamReader(client
     .getInputStream()));
   PrintWriter out = new PrintWriter(new OutputStreamWriter(client
     .getOutputStream(), "GBK"), true);
   out.println(msg);
   out.flush();
   rmsg = br.readLine();
   System.out.println(rmsg);
   client.close();
  } catch (Exception e) {
   System.out.println(e.getMessage());
   return e.getMessage();
  }
  return rmsg;
 }
　　public static void main(String[] args) {
  sendMes("端午节快乐!!");
 }
　　}
　　
　　
　　
　　创建函数：
　　create or replace function sendMsg(name VARCHAR2) return VARCHAR2 as
language java name 'TestClient.sendMes (java.lang.String) return java.lang.String ';
　　
　　
　　现在执行：select sendMsg( ' 13012345678|你好! ' ) from dual;
　　会报错：什么错呢？？
　　SQL> select sendMsg( ' 13012345678|你好! ' ) from dual;
 
SENDMSG('13012345678|你好!')
--------------------------------------------------------------------------------
the Permission (java.net.SocketPermission 192.168.1.120:10000 connect,resolve) h
　　
　　允许连接的权限！
　　
　　解决办法：
　　Connected to Oracle Database 10g Enterprise Edition Release 10.2.0.1.0
Connected as zjcdc
 
SQL>  exec sys.dbms_java.grant_permission( 'ZJCDC', 'SYS:java.net.SocketPermission', '192.168.1.120:10000', 'connect,resolve' );
 
PL/SQL procedure successfully completed
 
SQL> select sendMsg( ' 13012345678|你好! ' ) from dual;
 
SENDMSG('13012345678|你好!')
--------------------------------------------------------------------------------
服务器相应: 13012345678|你好!