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 += "
";
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();
}
}

<?xml version="1.0" encoding="utf-8"?>
<linearlayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical">
<edittext
android:id="@+id/chat_name_text"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:hint="用户名"
android:text="admin"/>
<edittext
android:id="@+id/chat_pwd_text"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:hint="密码"
android:text="123123123a"
android:inputtype="numberpassword" />
<button
android:id="@+id/chat_login_btn"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:hint="登录" />
</linearlayout>

<?xml version="1.0" encoding="utf-8"?>
<linearlayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical"
tools:context=".activity.mainactivity">
<scrollview
android:id="@+id/scrollview"
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="0.9">
<linearlayout
android:id="@+id/chat_ly"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical">
</linearlayout>
</scrollview>
<linearlayout
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:orientation="horizontal">
<edittext
android:id="@+id/chat_et"
android:layout_width="0dp"
android:layout_height="match_parent"
android:layout_weight="0.8" />
<button
android:id="@+id/send_btn"
android:layout_width="0dp"
android:layout_height="match_parent"
android:layout_weight="0.2"
android:text="发送" />
</linearlayout>
</linearlayout>

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 += "
";
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();
}
}