怎么向服务器发送消息。
谁能给我看看:
客户端:
public void startConnect()
{
try
{
Socket sock=new Socket("127.0.0.1",1001); if(sock!=null) //connection successed
{
processMsg("Connect successfully!");
}
out=new PrintWriter(sock.getOutputStream()); in=new BufferedReader(new InputStreamReader(sock.getInputStream())); }
catch(IOException ex)
{
processMsg(ex.toString());
processMsg("Connect failed!");
}
readThread1=new Thread(this);
readThread1.start(); } public void run()
{
String msg;
isTrue=true;
while(isTrue)
{
try
{
msg=in.readLine();
if(msg.equals("Server exit!")) //server exit
{
processMsg(msg);
stopRun();//终止线程
}
else if(msg!=null)
{
processMsg(msg);
}
Thread.sleep(1000);
}
catch(IOException e)
{
processMsg(e.toString());
}
catch(InterruptedException ei)
{
processMsg(ei.toString());
}
}
//endConnect();
try //服务器退出关闭连接和相关的"流"
{
sock.close();
in.close();
out.close();
}catch(IOException ioe){}
}
}
谁能给我看看:
客户端:
public void startConnect()
{
try
{
Socket sock=new Socket("127.0.0.1",1001); if(sock!=null) //connection successed
{
processMsg("Connect successfully!");
}
out=new PrintWriter(sock.getOutputStream()); in=new BufferedReader(new InputStreamReader(sock.getInputStream())); }
catch(IOException ex)
{
processMsg(ex.toString());
processMsg("Connect failed!");
}
readThread1=new Thread(this);
readThread1.start(); } public void run()
{
String msg;
isTrue=true;
while(isTrue)
{
try
{
msg=in.readLine();
if(msg.equals("Server exit!")) //server exit
{
processMsg(msg);
stopRun();//终止线程
}
else if(msg!=null)
{
processMsg(msg);
}
Thread.sleep(1000);
}
catch(IOException e)
{
processMsg(e.toString());
}
catch(InterruptedException ei)
{
processMsg(ei.toString());
}
}
//endConnect();
try //服务器退出关闭连接和相关的"流"
{
sock.close();
in.close();
out.close();
}catch(IOException ioe){}
}
}
URL url = new URL(theUrl);
InetAddress address = InetAddress.getByName(url.getHost());
Socket client = new Socket(address,
url.getPort() == -1 ? 80 : url.getPort());
BufferedOutputStream sender = new BufferedOutputStream(client.
getOutputStream()); String cmd = "POST " + getURLFormat(url) + " HTTP/1.0\r\n" +
"User-Agent: myselfHttp/1.0\r\n" +
"Accept: www/source; text/html; image/gif;\r\n";
cmd += "Content-type: application/x-www-form-urlencoded\r\n";
cmd += "Content-length: " + content.length() + "\r\n\r\n";
cmd += content + "\r\n";
sender.write(cmd.getBytes(), 0, cmd.length());
sender.flush();
client.close();
}
catch (UnknownHostException ex) {
ex.printStackTrace();
}
catch (MalformedURLException ex) {
ex.printStackTrace();
}
catch (IOException ex) {
ex.printStackTrace();
} } /****************************************************************************
*
* @param target URL
* @return String
****************************************************************************/
private static String getURLFormat(URL target) { String spec = "http://" + target.getHost();
if (target.getPort() != -1){
spec += ":" + target.getPort();
} return spec += target.getFile();
}