Java Socket聊天室编程(一)之利用socket实现聊天之消息推送

 public class SocketUrls{ // ip地址 public final static String IP = "192.168.1.110"; // 端口号 public final static int PORT = 8888; }

 public class Main { public static void main(String[] args) throws Exception { new ChatServer().initServer(); } }

 public class Main { public static void main(String[] args) throws Exception { new ChatServer().initServer(); } }

 public class MessageBean extends UserInfoBean { private long messageId;// 消息id private long groupId;// 群id private boolean isGoup;// 是否是群消息 private int chatType;// 消息类型;1,文本；2，图片；3，小视频；4，文件；5，地理位置；6，语音；7，视频通话 private String content;// 文本消息内容 private String errorMsg;// 错误信息 private int errorCode;// 错误代码 //省略get/set方法 }

 public class ChatServer { // socket服务 private static ServerSocket server; public Gson gson = new Gson(); /** * 初始化socket服务 */ public void initServer() { try { // 创建一个ServerSocket在端口8080监听客户请求 server = new ServerSocket(SocketUrls.PORT); createMessage(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 创建消息管理，一直接收消息 */ private void createMessage() { try { System.out.println("等待用户接入 : "); // 使用accept()阻塞等待客户请求 Socket socket = server.accept(); System.out.println("用户接入 : " + socket.getPort()); // 开启一个子线程来等待另外的socket加入 new Thread(new Runnable() { public void run() { createMessage(); } }).start(); // 向客户端发送信息 OutputStream output = socket.getOutputStream(); // 从客户端获取信息 BufferedReader bff = new BufferedReader(new InputStreamReader(socket.getInputStream())); // Scanner scanner = new Scanner(socket.getInputStream()); new Thread(new Runnable() { public void run() { try { String buffer; while (true) { // 从控制台输入 BufferedReader strin = new BufferedReader(new InputStreamReader(System.in)); buffer = strin.readLine(); // 因为readLine以换行符为结束点所以，结尾加入换行 buffer += "\n"; output.write(buffer.getBytes("utf-8")); // 发送数据 output.flush(); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }).start(); // 读取发来服务器信息 String line = null; // 循环一直接收当前socket发来的消息 while (true) { Thread.sleep(500); // System.out.println("内容 : " + bff.readLine()); // 获取客户端的信息 while ((line = bff.readLine()) != null) { MessageBean messageBean = gson.fromJson(line, MessageBean.class); System.out.println("用户 : " + messageBean.getUserName()); System.out.println("内容 : " + messageBean.getContent()); } } // server.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("错误 : " + e.getMessage()); } } }

 public class ChatAppliaction extends Application { public static ChatServer chatServer; public static UserInfoBean userInfoBean; @Override public void onCreate() { super.onCreate(); } }

 public class LoginActivity extends AppCompatActivity { private EditText chat_name_text, chat_pwd_text; private Button chat_login_btn; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_login); chat_name_text = (EditText) findViewById(R.id.chat_name_text); chat_pwd_text = (EditText) findViewById(R.id.chat_pwd_text); chat_login_btn = (Button) findViewById(R.id.chat_login_btn); chat_login_btn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { if (getLogin(chat_name_text.getText().toString().trim(), chat_pwd_text.getText().toString().trim())) { getChatServer(); Intent intent = new Intent(LoginActivity.this, MainActivity.class); startActivity(intent); finish(); } } }); } private boolean getLogin(String name, String pwd) { if (TextUtils.isEmpty(name) || TextUtils.isEmpty(pwd)) return false; if (name.equals("admin") && pwd.equals("123123123a")) return true; return false; } private void getChatServer() { ChatAppliaction.chatServer = new ChatServer(); } }

 public class MainActivity extends AppCompatActivity { private LinearLayout chat_ly; private TextView left_text, right_view; private EditText chat_et; private Button send_btn; private ViewGroup.LayoutParams layoutParams = new ViewGroup.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, ViewGroup.LayoutParams.WRAP_CONTENT); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); chat_ly = (LinearLayout) findViewById(R.id.chat_ly); chat_et = (EditText) findViewById(R.id.chat_et); send_btn = (Button) findViewById(R.id.send_btn); send_btn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { ChatAppliaction.chatServer.sendMessage(chat_et.getText().toString().trim()); chat_ly.addView(initRightView(chat_et.getText().toString().trim())); } }); //添加消息接收队列 ChatAppliaction.chatServer.setChatHandler(new Handler() { @Override public void handleMessage(Message msg) { if (msg.what == 1) { //发送回来消息后，更新ui chat_ly.addView(initLeftView(msg.obj.toString())); } } }); } /**靠右的消息 * @param messageContent * @return */ private View initRightView(String messageContent) { right_view = new TextView(this); right_view.setLayoutParams(layoutParams); right_view.setGravity(View.FOCUS_RIGHT); right_view.setText(messageContent); return right_view; } /**靠左的消息 * @param messageContent * @return */ private View initLeftView(String messageContent) { left_text = new TextView(this); left_text.setLayoutParams(layoutParams); left_text.setGravity(View.FOCUS_LEFT); left_text.setText(messageContent); return left_text; } }

 public class ChatServer { private Socket socket; private Handler handler; private MessageBean messageBean; private Gson gson = new Gson(); // 由Socket对象得到输出流，并构造PrintWriter对象 PrintWriter printWriter; InputStream input; OutputStream output; DataOutputStream dataOutputStream; public ChatServer() { initMessage(); initChatServer(); } /** * 消息队列，用于传递消息 * * @param handler */ public void setChatHandler(Handler handler) { this.handler = handler; } private void initChatServer() { //开个线程接收消息 receiveMessage(); } /** * 初始化用户信息 */ private void initMessage() { messageBean = new MessageBean(); messageBean.setUserId(1); messageBean.setMessageId(1); messageBean.setChatType(1); messageBean.setUserName("admin"); ChatAppliaction.userInfoBean = messageBean; } /** * 发送消息 * * @param contentMsg */ public void sendMessage(String contentMsg) { try { if (socket == null) { Message message = handler.obtainMessage(); message.what = 1; message.obj = "服务器已经关闭"; handler.sendMessage(message); return; } byte[] str = contentMsg.getBytes("utf-8");//将内容转utf-8 String aaa = new String(str); messageBean.setContent(aaa); String messageJson = gson.toJson(messageBean); /** * 因为服务器那边的readLine()为阻塞读取 * 如果它读取不到换行符或者输出流结束就会一直阻塞在那里 * 所以在json消息最后加上换行符，用于告诉服务器，消息已经发送完毕了 * */ messageJson += "\n"; output.write(messageJson.getBytes("utf-8"));// 换行打印 output.flush(); // 刷新输出流，使Server马上收到该字符串 } catch (Exception e) { e.printStackTrace(); Log.e("test", "错误：" + e.toString()); } } /** * 接收消息，在子线程中 */ private void receiveMessage() { new Thread(new Runnable() { @Override public void run() { try { // 向本机的8080端口发出客户请求 socket = new Socket(SocketUrls.IP, SocketUrls.PORT); // 由Socket对象得到输入流，并构造相应的BufferedReader对象 printWriter = new PrintWriter(socket.getOutputStream()); input = socket.getInputStream(); output = socket.getOutputStream(); dataOutputStream = new DataOutputStream(socket.getOutputStream()); // 从客户端获取信息 BufferedReader bff = new BufferedReader(new InputStreamReader(input)); // 读取发来服务器信息 String line; while (true) { Thread.sleep(500); // 获取客户端的信息 while ((line = bff.readLine()) != null) { Log.i("socket", "内容 : " + line); Message message = handler.obtainMessage(); message.obj = line; message.what = 1; handler.sendMessage(message); } if (socket == null) break; } output.close();//关闭Socket输出流 input.close();//关闭Socket输入流 socket.close();//关闭Socket } catch (Exception e) { e.printStackTrace(); Log.e("test", "错误：" + e.toString()); } } }).start(); } }