socket实现实时消息发送包含图片文字

socket实现实时消息发送,通过json格式传输数据格式信息，发送图片以及文字信息

import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketTimeoutException;


/**
 * ami发送信息给tom
 * @author 刘程 Exp
 * @version $FileName: amiYQClient.java $Date: 2014-10-24 下午2:46:38 -0400 2014
 * @since 1.0
 */
public class amiYQClient {
	public Socket s;

	public  void sendLoginInfo（） {
		try {
			s = new Socket（）;
			try {
				s.connect（new InetSocketAddress（“127.0.0.1“ 6789） 2000）;
			} catch （SocketTimeoutException e） {
				// 连接服务器超时
			}
			String programStr = “{“;
			programStr += “\“msgType\““ + “:“ + “1“;
			programStr += “\“fromUser\““ + “:“+ “‘ami‘“;
			programStr += “\“toUser\““ + “:“+ “‘tom‘“;
			programStr +=“}“; 
//			OutputStream oos = s.getOutputStream（）;
//			oos.write（programStr.getBytes（））;
//			InputStream is = s.getInputStream（）;
//			byte [] bt = new byte[1024];
//			int length = is.read（bt）;
//			String msgContent = new String （bt0length）;
			DataInputStream dis = new DataInputStream（s.getInputStream（））;
			DataOutputStream dos = new DataOutputStream（s.getOutputStream（））;
			dos.writeUTF（programStr）;
			String msgContent = dis.readUTF（）;
			if （msgContent.equals（“OK“）） {
				// 创建一个该账号和服务器保持连接的线程
				ClientConServerThread ccst = new ClientConServerThread（s）;
				// 启动该通信线程
				ccst.start（）;
				// 加入到管理类中
				ManageClientConServer.addClientConServerThread（“ami“ ccst）;
			} 
		} catch （IOException e） {
			e.printStackTrace（）;
		} 
	}
	
	public static void sendADbuddy（） {
		try {
			String programStr = “{“;
			programStr += “\“msgType\““ + “:“ + “2“;
			programStr += “\“fromUser\““ + “:“ + “‘ami‘“;
			programStr += “\“toUser\““ + “:“ + “‘tom‘“;
			programStr += “}“;
			DataOutputStream oos = new DataOutputStream（ManageClientConServer.getClientConServerThread（“ami“）.getS（）
					.getOutputStream（））;
			oos.writeUTF（programStr）;
		} catch （Exception e） {
			e.printStackTrace（）;
		}
	}
	
	public static void sendImg（）{
		try {
			DataOutputStream out = new DataOutputStream（ManageClientConServer.getClientConServerThread（“ami“）.getS（）
					.getOutputStream（））;
			String savePath = “d:\\log\\2.jpg“;
			File file = new File（savePath）;
			DataInputStream  dis =  new DataInputStream（new BufferedInputStream（new FileInputStream（savePath）））;
			//DataOutputStream out = new DataOutputStream（socket.getOutputStream（））;  
			//发送消息头
			String programStr = “{“;
			programStr += “\“msgType\““ + “:“ + “3“;
			programStr += “\“fromUser\““ + “:“ + “‘ami‘“;
			programStr += “\“toUser\““ + “:“ + “‘tom‘“;
			programStr += “}“;
			out.writeUTF（programStr）;  
			out.flush（）;
			out.writeUTF（file.getName（））;
			out.flush（）;
			int length=0;
			byte [] sendBytes = new byte[1024];
			while （（length = dis.read（sendBytes0 sendBytes.length）） > 0） {

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件        792  2015-01-09 10:49  socket\.classpath

     文件        382  2015-01-09 10:48  socket\.project

     文件        598  2015-01-09 10:48  socket\.settings\org.eclipse.jdt.core.prefs

     文件       3693  2015-01-09 10:49  socket\bin\amiYQClient.class

     文件       2788  2015-01-09 10:49  socket\bin\ClientConServerThread.class

     文件       3685  2015-01-09 10:49  socket\bin\JimYQClient.class

     文件       2410  2015-01-09 10:50  socket\bin\MainServer.class

     文件       1035  2015-01-09 10:49  socket\bin\ManageClientConServer.class

     文件       3888  2015-01-09 10:49  socket\bin\TomYQClient.class

     文件     231320  2014-10-14 10:11  socket\commons-beanutils-1.8.0.jar

     文件     571259  2013-12-11 10:43  socket\commons-collections-3.2.jar

     文件     586337  2014-10-14 10:11  socket\commons-httpclient-3.0.jar

     文件     261809  2011-11-30 22:55  socket\commons-lang-2.4.jar

     文件      62050  2013-12-11 10:44  socket\commons-logging-1.1.3.jar

     文件      86487  2014-10-14 10:11  socket\ezmorph-1.0.6.jar

     文件     253797  2013-12-11 10:44  socket\json-lib-2.3-jdk15.jar

     文件      88210  2013-12-11 10:43  socket\servlet-api.jar

     文件       3680  2015-01-09 10:48  socket\src\amiYQClient.java

     文件       1962  2015-01-09 10:48  socket\src\ClientConServerThread.java

     文件       3671  2015-01-09 10:48  socket\src\JimYQClient.java

     文件       1702  2015-01-09 10:50  socket\src\MainServer.java

     文件        432  2015-01-09 10:48  socket\src\ManageClientConServer.java

     文件       3925  2015-01-09 10:48  socket\src\TomYQClient.java

     目录          0  2015-01-09 10:48  socket\.settings

     目录          0  2015-01-09 10:49  socket\bin

     目录          0  2015-01-09 10:48  socket\src

     目录          0  2015-01-09 10:49  socket

----------- ---------  ---------- -----  ----

              2175912                    27



............此处省略0个文件信息